STOMP 与 RabbitMQ
通过 WebSocket 上的 STOMP 将您的 Delphi 应用程序连接到 RabbitMQ。发布消息、订阅队列,并与企业级消息基础设施集成。
通过 WebSocket 上的 STOMP 将您的 Delphi 应用程序连接到 RabbitMQ。发布消息、订阅队列,并与企业级消息基础设施集成。
针对 RabbitMQ Web-STOMP 插件优化的 STOMP 1.0 / 1.1 / 1.2 客户端。支持主题、队列、外部声明队列、临时回复队列和事务。
TsgcWSPClient_STOMP_RabbitMQ
STOMP 1.2(通过 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 个事件 — 摘自组件参考文档。
已发布属性:Client、Broker、Versions。
事件:OnRabbitMQMessage、OnRabbitMQReceipt。
已发布属性:HeartBeat。
已发布属性:Authentication。
事件:OnRabbitMQConnected、OnRabbitMQDisconnected、OnRabbitMQError。
方法:WriteData。
该组件实现的协议权威来源。