AMQP 1.0 プロトコル
高度なメッセージングのための OASIS 標準です。Delphi から Azure Service Bus、Apache Qpid、その他あらゆる AMQP 1.0 準拠ブローカーに接続できます。
高度なメッセージングのための OASIS 標準です。Delphi から Azure Service Bus、Apache Qpid、その他あらゆる AMQP 1.0 準拠ブローカーに接続できます。
AMQP 1.0 サブプロトコルクライアントです。WebSocket または生 TCP キャリア上で、セッション、送信側 / 受信側リンク、Azure Service Bus 向けの Claims-Based-Security トークンをサポートします。
TsgcWSPClient_AMQP1
Windows, macOS, Linux, iOS, Android
Professional / Enterprise
CreateSession の後、CreateSenderLink / CreateReceiverLink を実行して送受信を行います。CBS ヘルパーは Azure Service Bus の SAS / OAuth をラップします。
uses
sgcWebSocket, sgcWebSocket_Protocol_AMQP1_Client, sgcAMQP1_Classes;
var
WSClient: TsgcWebSocketClient;
AMQP1: TsgcWSPClient_AMQP1;
oSession: TsgcAMQP1Session;
oSender: TsgcAMQP1SenderLink;
begin
WSClient := TsgcWebSocketClient.Create(nil);
WSClient.Host := 'broker.example.com';
WSClient.Port := 5673;
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;
oSender := AMQP1.CreateSenderLink(oSession, '/queue/orders');
// Receivers handle pushed deliveries through OnAMQPMessage
AMQP1.CreateReceiverLink(oSession, '/queue/orders');
end;公開プロパティ 5 件、メソッド 12 件、イベント 14 件 — コンポーネントリファレンスから抜粋しています。
公開プロパティ: Client、Broker、Guid。
イベント: OnAMQPMessage、OnAMQPMessageSent、OnAMQPMessageSentAck。
イベント: OnAMQPSASLAuthentication。
メソッド: CreateSession、CloseSession。
イベント: OnAMQPConnect、OnAMQPDisconnect、OnAMQPClose。
メソッド: WriteData。
このコンポーネントが実装するプロトコルの一次資料です。
コンポーネントリファレンスへのディープリンク、すぐに実行可能なデモプロジェクト、そして体験版のダウンロードはこちらです。
| デモプロジェクト — Demos\Protocols\AMQP\100 すぐに実行可能なサンプルプロジェクトです。sgcWebSockets パッケージに同梱されています。下記より体験版をダウンロードしてください。 | 開く | |
| 技術ドキュメント (PDF) 本コンポーネントのみを対象とした機能解説、クイックスタート、Delphi および C++ Builder のコードサンプル、一次資料への参照を収録しています。 | 開く | |
| ユーザーマニュアル (PDF) ライブラリ内のすべてのコンポーネントを網羅した総合マニュアルです。 | 開く |