TsgcWSPClient_STOMP_RabbitMQ › Events › OnRabbitMQConnected

OnRabbitMQConnected Event

Fires after the RabbitMQ broker answers the CONNECT frame with a CONNECTED frame; exposes the negotiated session via a typed Headers object.

Syntax

property OnRabbitMQConnected: TsgcWSRabbitMQSTOMPConnectedEvent;
// TsgcWSRabbitMQSTOMPConnectedEvent = procedure(Connection: TsgcWSConnection; Headers: TsgcWSRabbitMQSTOMPHeadersConnected) of object

Default Value

—

Remarks

Raised when RabbitMQ answers the CONNECT / STOMP frame with a CONNECTED frame. This is the first moment at which the STOMP session is fully usable — it is safe to call Subscribe / Send / BeginTransaction from inside this handler. Parameters:

• Connection — the underlying WebSocket connection that received the CONNECTED frame.
• Headers — a TsgcWSRabbitMQSTOMPHeadersConnected object exposing the negotiated protocol Version, Server identification, Session id, HeartBeat settings ("cx,cy" where cx is what the client can send and cy is what the client expects to receive, in milliseconds; "0,0" disables heart-beating) and the complete RawHeaders string for any RabbitMQ-specific fields.

Example

procedure TForm1.RabbitMQConnected(Connection: TsgcWSConnection;
  Headers: TsgcWSRabbitMQSTOMPHeadersConnected);
begin
  Memo1.Lines.Add(Format('RabbitMQ %s connected to %s (session=%s, heart-beat=%s)',
    [Headers.Version, Headers.Server, Headers.Session, Headers.HeartBeat]));

  // now it is safe to subscribe
  RabbitMQ.SubscribeQueue('orders');
end;

Back to Events