STOMP ile ActiveMQ

uses
  sgcWebSocket, sgcWebSocket_Protocol_STOMP_ActiveMQ_Client;

var
  WSClient: TsgcWebSocketClient;
  STOMP: TsgcWSPClient_STOMP_ActiveMQ;
begin
  WSClient := TsgcWebSocketClient.Create(nil);
  WSClient.Host := 'broker.example.com';
  WSClient.Port := 61614;

  STOMP := TsgcWSPClient_STOMP_ActiveMQ.Create(nil);
  STOMP.Client := WSClient;
  STOMP.Authentication.Enabled  := True;
  STOMP.Authentication.UserName := 'admin';
  STOMP.Authentication.Password := 'admin';

  STOMP.OnSTOMPConnected := STOMPConnected;
  STOMP.OnSTOMPMessage   := STOMPMessage;

  WSClient.Active := True;
end;

procedure TForm1.STOMPConnected(Connection: TsgcWSConnection;
  const Session, Server: string);
begin
  STOMP.SubscribeQueue('orders');
  STOMP.PublishQueue('orders', 'hello');
end;