STOMP と RabbitMQ

STOMP over WebSocket を使用して Delphi アプリケーションを RabbitMQ に接続できます。メッセージのパブリッシュ、キューのサブスクライブ、エンタープライズメッセージングインフラとの連携が可能です。

TsgcWSPClient_STOMP_RabbitMQ

RabbitMQ の Web-STOMP プラグイン向けに最適化された STOMP 1.0 / 1.1 / 1.2 クライアント。トピック、キュー、外部宣言キュー、一時返信キュー、トランザクションに対応しています。

コンポーネントクラス

TsgcWSPClient_STOMP_RabbitMQ

プロトコル

STOMP 1.2 via RabbitMQ Web-STOMP

プラットフォーム

Windows, macOS, Linux, iOS, Android

エディション

Professional / Enterprise

コンポーネントを配置してプロパティを設定し、実行する

TsgcWebSocketClient とペアリングし、Authentication と Options の仮想ホストを設定して、/topic/、/queue/、/amq/queue/、/temp-queue/ のいずれかのデスティネーションにサブスクライブします。

uses
  sgcWebSocket, 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.OnSTOMPConnected := STOMPConnected;
  STOMP.OnSTOMPMessage   := STOMPMessage;

  WSClient.Active := True;
end;

主な機能

公開プロパティ 8 件、メソッド 25 件、イベント 6 件(コンポーネントリファレンスより)。

接続

公開プロパティ:ClientBrokerVersions

メッセージング

イベント:OnRabbitMQMessageOnRabbitMQReceipt

信頼性

公開プロパティ:HeartBeat

セキュリティ

公開プロパティ:Authentication

ライフサイクル

イベント:OnRabbitMQConnectedOnRabbitMQDisconnectedOnRabbitMQError

高度な設定

メソッド:WriteData

仕様と参考資料

このコンポーネントが実装するプロトコルの一次資料です。

ドキュメントとデモ

コンポーネントリファレンスへのディープリンク、すぐに実行可能なデモプロジェクト、そして体験版のダウンロードはこちらです。

デモプロジェクト — Demos\Protocols\STOMP\RabbitMQ すぐに実行可能なサンプルプロジェクトです。sgcWebSockets パッケージに同梱されています。下記より体験版をダウンロードしてください。
技術ドキュメント (PDF) 本コンポーネントのみを対象とした機能解説、クイックスタート、Delphi および C++ Builder のコードサンプル、一次資料への参照を収録しています。
ユーザーマニュアル (PDF) ライブラリ内のすべてのコンポーネントを網羅した総合マニュアルです。

RabbitMQ に接続する準備はできましたか?

体験版をダウンロードして、数分で RabbitMQ と連携しましょう。