AMQP 1.0 Protocol

uses
  sgcWebSocket, sgcWebSocket_Protocols, sgcAMQP1_Session, sgcAMQP1_Classes;

var
  WSClient: TsgcWebSocketClient;
  AMQP1: TsgcWSPClient_AMQP1;
  oSession: TsgcAMQP1Session;
  oSender:  TsgcAMQP1SenderLink;
begin
  WSClient := TsgcWebSocketClient.Create(nil);
  WSClient.Specifications.RFC6455 := False;
  WSClient.Host := 'broker.example.com';
  WSClient.Port := 5672;

  AMQP1 := TsgcWSPClient_AMQP1.Create(nil);
  AMQP1.Client := WSClient;

  AMQP1.OnAMQPConnect      := AMQPConnect;
  AMQP1.OnAMQPMessage      := AMQPMessage;
  AMQP1.OnAMQPSessionOpen  := AMQPSessionOpen;
  AMQP1.OnAMQPLinkOpen     := AMQPLinkOpen;

  WSClient.Active := True;

  oSession := AMQP1.CreateSession('session-1');
  // Links are addressed by session name, link name and target/source address
  oSender  := AMQP1.CreateSenderLink(oSession.ID,
    'sender-orders', '/queue/orders');
  // Receivers handle pushed deliveries through OnAMQPMessage
  AMQP1.CreateReceiverLink(oSession.ID,
    'receiver-orders', '/queue/orders');
end;