TsgcWSPClient_STOMP_RabbitMQ › Events › OnRabbitMQMessage

OnRabbitMQMessage Event

Fires when a MESSAGE frame is received for an active RabbitMQ subscription; delivers the body, the typed Headers and the originating Subscription item.

Syntax

property OnRabbitMQMessage: TsgcWSRabbitMQSTOMPMessageEvent;
// TsgcWSRabbitMQSTOMPMessageEvent = procedure(Connection: TsgcWSConnection; MessageText: String; Headers: TsgcWSRabbitMQSTOMPHeadersMessage; Subscription: TsgcWSBrokerSTOMPSubscriptionItem) of object

Default Value

—

Remarks

Raised every time the RabbitMQ broker dispatches a MESSAGE frame to one of the client's subscriptions (queue, topic, exchange or temporary queue). Parameters:

• MessageText — the body of the MESSAGE frame (the payload delivered by the publisher).
• Headers — a TsgcWSRabbitMQSTOMPHeadersMessage object exposing Destination, MessageId (unique identifier assigned by the broker, required when calling ACK or NACK), Subscription id, ACK value (present only when the subscription uses client or client-individual acknowledgment mode; the handler MUST call ACK or NACK passing this value), ContentType, plus the RabbitMQ-specific Redelivered, Persistent, Priority, Expiration and Timestamp properties and the complete RawHeaders string with all user-defined and vendor-specific headers (including AMQP "x-" arguments).
• Subscription — the TsgcWSBrokerSTOMPSubscriptionItem that received the message, matching the entry returned by Subscribe.

Example

procedure TForm1.RabbitMQMessage(Connection: TsgcWSConnection;
  MessageText: String; Headers: TsgcWSRabbitMQSTOMPHeadersMessage;
  Subscription: TsgcWSBrokerSTOMPSubscriptionItem);
begin
  Memo1.Lines.Add(Format('[%s] %s', [Headers.Destination, MessageText]));

  // acknowledge when the subscription requires it
  if Headers.ACK <> '' then
    RabbitMQ.ACK(Headers.MessageId, Headers.Subscription);
end;

Back to Events