TsgcWSPClient_STOMP_ActiveMQ ist der auf Apache ActiveMQ abgestimmte STOMP-Client. Er ergänzt Queue- und Topic-Helfer über der Zielnamensgebung von ActiveMQ, typisierte Header-Objekte bei jedem Ereignis und eine Eigenschaft ActiveMQ_Options für die brokerspezifischen Einstellungen, die dauerhafte Abonnements brauchen.
Alles aus dem generischen STOMP-Client gilt weiterhin. Neu hinzu kommen die Ziel-Helfer, die ActiveMQ-benannten Ereignisse und die Broker-Optionen.
TsgcWSPClient_STOMP_ActiveMQ
STOMP 1.0, 1.1 und 1.2
TCP (61613) oder TLS (61612)
Delphi, C++ Builder
Transport: reines TCP und TLS. sgcMQ spricht mit ActiveMQ über reines TCP und TLS. Der STOMP-über-WebSocket-Connector von ActiveMQ ist ein WebSocket-Endpunkt, um ihn zu erreichen, benötigst du also ein sgcWebSockets Paket, das den WebSocket-Client bereitstellt.
Dieses Beispiel nutzt den nativen STOMP-Port von ActiveMQ, 61613. Für eine verschlüsselte Verbindung schaltest du TLS am Träger ein und nutzt den stomp+ssl-Connector des Brokers auf Port 61612.
uses
sgcTCP_Client_WS, sgcWebSocket_Classes, sgcWebSocket_Protocols,
sgcWebSocket_Protocol_STOMP_Broker_Client,
sgcWebSocket_Protocol_STOMP_ActiveMQ_Client;
var
TCPClient: TsgcTCPClient;
STOMP: TsgcWSPClient_STOMP_ActiveMQ;
begin
TCPClient := TsgcTCPClient.Create(nil);
TCPClient.Host := 'broker.example.com';
TCPClient.Port := 61613;
STOMP := TsgcWSPClient_STOMP_ActiveMQ.Create(nil);
STOMP.Client := TCPClient;
STOMP.ActiveMQ_Options.ClientId := 'delphi-consumer-1';
STOMP.Authentication.Enabled := True;
STOMP.Authentication.UserName := 'admin';
STOMP.Authentication.Password := 'admin';
STOMP.OnActiveMQConnected := ActiveMQConnected;
STOMP.OnActiveMQMessage := ActiveMQMessage;
TCPClient.Active := True;
end;
procedure TForm1.ActiveMQConnected(Connection: TsgcWSConnection;
Headers: TsgcWSActiveMQSTOMPHeadersConnected);
begin
STOMP.SubscribeQueue('orders');
STOMP.PublishQueue('orders', '{"id":42}');
end;
procedure TForm1.ActiveMQMessage(Connection: TsgcWSConnection;
MessageText: string; Headers: TsgcWSActiveMQSTOMPHeadersMessage;
Subscription: TsgcWSBrokerSTOMPSubscriptionItem);
begin
Memo1.Lines.Add(Headers.Destination + ': ' + MessageText);
end;// include: sgcTCP_Client_WS.hpp, sgcWebSocket_Protocols.hpp,
// sgcWebSocket_Protocol_STOMP_ActiveMQ_Client.hpp
TsgcTCPClient *TCPClient = new TsgcTCPClient(this);
TCPClient->Host = "broker.example.com";
TCPClient->Port = 61613;
TsgcWSPClient_STOMP_ActiveMQ *STOMP =
new TsgcWSPClient_STOMP_ActiveMQ(this);
STOMP->Client = TCPClient;
STOMP->ActiveMQ_Options->ClientId = "cbuilder-consumer-1";
STOMP->Authentication->Enabled = true;
STOMP->Authentication->UserName = "admin";
STOMP->Authentication->Password = "admin";
STOMP->OnActiveMQConnected = ActiveMQConnected;
STOMP->OnActiveMQMessage = ActiveMQMessage;
TCPClient->Active = true;
// In the OnActiveMQConnected handler:
STOMP->SubscribeQueue("orders");
STOMP->PublishQueue("orders", "{\"id\":42}");Die Member, zu denen du am häufigsten greifst.
SubscribeQueue, PublishQueue und UnSubscribeQueue nehmen den reinen Queue-Namen entgegen und bauen daraus das /queue/-Ziel, mit Argumenten für Dauerhaftigkeit, Exklusivität und Ack-Modus.
SubscribeTopic, PublishTopic und UnSubscribeTopic tun dasselbe für /topic/-Ziele, und genau dort sind dauerhafte Abonnements am wichtigsten.
SubscribeEx, PublishEx und UnSubscribeEx nehmen eine rohe Zielangabe als String entgegen, für alles, was die benannten Helfer nicht abdecken.
ActiveMQ_Options trägt die ActiveMQ-spezifischen Einstellungen, darunter die ClientId, an der der Broker einen wiederkehrenden dauerhaften Abonnenten erkennt.
Die Subscribe-Helfer nehmen ein Durable-Flag entgegen, ein Topic-Abonnent kann sich also trennen und später die Nachrichten abholen, die der Broker für ihn zurückgehalten hat.
OnActiveMQMessage liefert ein TsgcWSActiveMQSTOMPHeadersMessage plus den passenden Abonnementeintrag, damit Ziel, Nachrichten-ID und Ack-Modus als Eigenschaften vorliegen.
Übergib beim Abonnieren einen Ack-Modus und rufe dann ACK oder NACK mit der Nachrichten-ID auf. In ackAuto gilt eine Nachricht für den Broker als zugestellt, sobald sie gesendet wurde.
Jeder Publish-Helfer akzeptiert einen Content-Type, einen optionalen Transaktionsnamen und ein Nachrichtenoptionen-Objekt für ActiveMQ-Header wie Priorität, Persistenz und Ablaufzeit.
Client, Authentication, HeartBeat, Versions und Options verhalten sich genau wie beim generischen STOMP-Client.
| Online-HilfeVollständige API-Referenz und Anwendungsleitfaden. | Öffnen | |
| Generischer STOMP-ClientDie Basiskomponente mit dem Standard-Frame-Satz. | Öffnen | |
| AMQP 1.0-ClientActiveMQ Artemis spricht auch AMQP 1.0. | Öffnen | |
| Kostenlose Testversion herunterladenTeste gegen einen lokalen ActiveMQ-Broker. | Öffnen | |
| PreiseSingle-, Team- und Site-Lizenzen mit vollständigem Quellcode. | Öffnen |