TsgcWSPClient_MQTT › Eventos › OnMQTTPublishEx

OnMQTTPublishEx Evento

Se dispara al recibir un PUBLISH; entrega la carga como TsgcWSMQTTPublishData (Value, Bytes, Stream) junto con el TsgcWSMQTTMessage sin procesar.

Sintaxis

property OnMQTTPublishEx: TsgcWSMQTTPublishExEvent;
// TsgcWSMQTTPublishExEvent = procedure(Connection: TsgcWSConnection; aTopic: String; aData: TsgcWSMQTTPublishData; PublishProperties: TsgcWSMQTTPUBLISHProperties; aMessage: TsgcWSMQTTMessage) of object

Valor Predeterminado

—

Observaciones

Variante extendida de OnMQTTPublish para cargas binarias e inspección de bajo nivel. Se activa para cada PUBLISH entrante después de que el protocolo de enlace QoS a nivel de transporte ha finalizado (QoS 0 inmediatamente; QoS 1 tras PUBACK; QoS 2 tras PUBREC → PUBREL → PUBCOMP). Parámetros:

• aTopic — nombre del tema que el broker coincidió.
• aData — un TsgcWSMQTTPublishData que expone el payload de tres formas: Value (String), Bytes (TBytes) y Stream (TMemoryStream). Elija el que se ajuste a su contenido (texto, blob binario, consumidor de flujo).
• PublishProperties (MQTT 5) — mismo conjunto que OnMQTTPublish (PayloadFormat, MessageExpiryInterval, TopicAlias, ResponseTopic, CorrelationData, UserProperties, SubscriptionIdentifier, ContentType).
• aMessage — el objeto TsgcWSMQTTMessage sin procesar, útil si necesita el QoS original, el indicador Retain o el PacketIdentifier.

Gestione OnMQTTPublish o OnMQTTPublishEx (el componente entrega los mensajes entrantes al que esté asignado); OnMQTTPublishEx es preferible cuando no se puede garantizar que la carga útil sea UTF-8 válido.

Ejemplo

procedure TForm1.MQTTPublishEx(Connection: TsgcWSConnection;
  aTopic: String; aData: TsgcWSMQTTPublishData;
  PublishProperties: TsgcWSMQTTPUBLISHProperties;
  aMessage: TsgcWSMQTTMessage);
var
  vBytes: TBytes;
begin
  Memo1.Lines.Add(Format('[%s] QoS=%d %d bytes',
    [aTopic, Ord(aMessage.QoS), Length(aData.Bytes)]));

  // read the payload as raw bytes (safe for binary content)
  vBytes := aData.Bytes;

  // or pull it through the stream API
  aData.Stream.Position := 0;
  SaveStreamToFile(aData.Stream, 'payload.bin');
end;

Volver a Eventos