Antwortweg AMQP/JMS
Einführung: Phase 6.
Lobster_data bietet eine Schnittstelle für AMQP-Server (Advanced Message Queuing Protocol). Mit diesem Antwortweg werden Daten an diese Schnittstelle gesendet. Wichtiger Hinweis: Dieser Antwortweg kann auch verwendet werden, um an JMS-Server-Queues zu senden.
(1) Auswahl eines AMQP-Aliases.
(2) Auswahl des Typs (Publish, Routing, Topic oder RPC). Der Typ RPC ist synchron, die anderen asynchron. Hinweis: Wenn Sie Style RPC verwenden, dann müssen Sie auch ein Folgeprofil angeben. Ein entsprechendes Eingabefeld erscheint, wenn Sie Typ RPC auswählen. Der Grund ist, dass ein RPC-Aufruf eine Response erzeugt und diese wird dann vom Folgeprofil entgegengenommen. Siehe auch Abschnitt AMQP-Netze mit Style RPC.
(3) Name der Queue, an die gesendet wird, bzw. Name des Topics. Siehe https://www.rabbitmq.com/getstarted.html.
(4) Mit dieser Checkbox markieren Sie, dass es sich bei der angegebenen Queue um eine "durable" Queue handelt (eine solche Queue überlebt einen Neustart des Brokers).
AMQP Message Properties
Um eine Message Property zu setzen, muss man im Profil eine System-Variable der Form AMQP_<Name der Message Property> angelegt werden (Groß- und Kleinschreibung in der Property wird beachtet). Beispiel: Mit der Variable AMQP_TTL können sie die Message Property TTL setzen.
AMQP Message Headers
Wenn Sie AMQP 1.0 verwenden, können Sie Message Header mit System-Variablen der Form AMQP_SYS_<Name des Headers> setzen (Groß- und Kleinschreibung im Header wird beachtet).
JMS Message Properties
Um eine Message Property zu setzen, muss man im Profil eine System-Variable der Form AMQP_<Name der Message Property> angelegt werden (Groß- und Kleinschreibung in der Property wird beachtet). Beispiel: Mit der Variable AMQP_Year können sie die Message Property Year setzen.
JMS Message Headers
Sie können folgende System-Variablen nutzen, um JMS Message Headers zu setzen:
System-Variable AMQP_JMS_CORRELATIONID (für JMS Message Header JMSCorrelationID).
AMQP_JMS_EXPIRATION (JMSExpiration).
AMQP_JMS_PRIORITY (JMSPriority).
AMQP_JMS_REPLYTO (JMSReplyTo).
AMQP_TTL (JMSTimeToLive).
AMQP_TYPE (JMSType).
JMS-Message-Selektoren
Im Eingangsagenten AMQP/JMS ist beschrieben, wie man Nachrichten mit JMS-Message-Selektoren filtern kann. Nehmen wir nun an, Sie möchten mit einem Selektor Year=2019 arbeiten. Legen Sie hierzu im Profil eine System-Variable AMQP_Year vom Typ Integer und dem Wert 2019 an. Wenn Sie nun hier im Antwortweg eine JMS-Nachricht versenden, enthält diese die Message Custom Property Year mit dem Wert 2019 und wird mit Ihrem Message-Selektor gefunden werden.
Message Type
Per Default übergibt der Antwortweg AMQP/JMS Daten an den empfangenden Server als Byte-Nachricht. Um das zu ändern, da manche Server damit nicht zurecht kommen, kann im Profil die System-Variable AMQP_JMS_TEXTMESSAGE mit dem Wert true angelegt werden, dann werden die Daten als Text-Nachricht übergeben. Zudem muss im Antwortweg die Kodierung auf UTF-8 gesetzt sein.