STOMP with RabbitMQ

uses
  sgcWebSocket, sgcWebSocket_Classes, sgcWebSocket_Protocols,
  sgcWebSocket_Protocol_STOMP_Broker_Client,
  sgcWebSocket_Protocol_STOMP_RabbitMQ_Client;

var
  WSClient: TsgcWebSocketClient;
  STOMP: TsgcWSPClient_STOMP_RabbitMQ;
begin
  WSClient := TsgcWebSocketClient.Create(nil);
  WSClient.Host := 'rabbit.example.com';
  WSClient.Port := 15674;
  WSClient.Options.Parameters := '/ws';

  STOMP := TsgcWSPClient_STOMP_RabbitMQ.Create(nil);
  STOMP.Client := WSClient;
  STOMP.Authentication.Enabled  := True;
  STOMP.Authentication.UserName := 'guest';
  STOMP.Authentication.Password := 'guest';
  STOMP.Options.VirtualHost := '/';

  STOMP.OnRabbitMQConnected := RabbitMQConnected;
  STOMP.OnRabbitMQMessage   := RabbitMQMessage;

  WSClient.Active := True;
end;

procedure TForm1.RabbitMQConnected(Connection: TsgcWSConnection;
  Headers: TsgcWSRabbitMQSTOMPHeadersConnected);
begin
  // /queue/orders is managed by the STOMP gateway
  STOMP.SubscribeQueue('orders');
  STOMP.PublishQueue('orders', 'hello');
end;

procedure TForm1.RabbitMQMessage(Connection: TsgcWSConnection;
  MessageText: String;
  Headers: TsgcWSRabbitMQSTOMPHeadersMessage;
  Subscription: TsgcWSBrokerSTOMPSubscriptionItem);
begin
  Memo1.Lines.Add(Headers.Destination + ': ' + MessageText);
end;