Klickpfad
Integration > Profile > Phase 6 > Neuer Antwortweg > AMQP/JMS > [AMQP/JMS] Einstellungen
Einstellungen
Dieser Abschnitt beschreibt die Felder des Antwortwegs AMQP.

Einstellung | Beschreibung |
|---|---|
Alias | Auswahl eines AMQP-Aliases. |
Typ | Auswahl des Typs (Publish, Routing, Topic oder RPC). RPC ist synchron, alle anderen asynchron. |
Queue/Topic | Name der Queue, an die gesendet wird, oder Name des Topics. Siehe z. B. RabbitMQ. |
RoutingKey | Der Routing Key ist ein Message-Attribut, das der Server verwendet, um zu entscheiden, wie die Nachricht an Queues weitergeleitet werden soll. Details siehe Dokumentation des verwendeten AMQP-Servers (z. B. RabbitMQ). Gilt nicht für Publish. |
Persistent/Durable | Markiert die angegebene Queue als "durable" (eine solche Queue überlebt einen Neustart des Brokers). Gilt nicht für RPC. |
Gesamten Job als gescheitert melden, wenn dieser Antwortweg fehlgeschlagen ist | Normalerweise gilt ein Job nicht notwendigerweise als gescheitert, wenn ein einzelner Antwortweg fehlschlägt (siehe Abschnitt Verhalten im Fehlerfall). Diese Option erzwingt, dass der gesamte Job als gescheitert gilt, wenn dieser Antwortweg fehlschlägt. |
Zusätzlicher Text bei Fehler | Optionaler, zusätzlicher Log-Text für den Fehlerfall. |
Einstellungen für Typ: RPC
Bei Typ RPC ist ein Folge-Profil erforderlich. Das Folge-Profil nimmt die vom RPC-Aufruf erzeugte Response entgegen.

Einstellung | Beschreibung |
|---|---|
RPC Timeout | Gibt an (in Sekunden), wie lange das sendende Profil auf die RPC-Antwortnachricht wartet, die der AMQP-Broker auf der temporären Reply-Queue bereitstellt. Läuft dieser Timer ab, gilt der RPC-Aufruf selbst als fehlgeschlagen. Beispiel einer Fehlermeldung: „Got no response from AMQP 1.0 rpc call within 20000ms". |
Folge-Profil | Das angegebene Profil muss aktiv sein und einen Eingangsagenten des Typs Message haben. |
Max. Verarbeit./Aufbw | Gibt die maximale Gesamtzeit (in Sekunden) für die Ausführung des Antwortwegs an, einschließlich Senden, Verarbeitung und etwaiger Wiederholungsversuche (Retries). Das konkrete Verhalten hängt vom Message-Typ ab (siehe Message-Typen). Die minimale Lebenszeit der Message beträgt 12 Stunden (unabhängig vom eingestellten Wert). Mit dem Retry-Mechanismus steuert dieser Wert zugleich das Wiederholungsverhalten aus den Verbindungs-Einstellungen (zulässige Ausführungszeit über alle Wiederholungsversuche hinweg). |
Message-Typ | Art der Message. Mögliche Werte: Synchron, Asynchron, Persistent (siehe Message-Typen). |
Message-Typen
Eine Message kann drei unterschiedliche Typen haben.
Message-Typ | Verhalten |
|---|---|
Synchron | Das Profil sendet die Message und macht erst dann weiter, wenn die Antwort erfolgt ist. Es wartet, bis das Ziel-Profil seine Verarbeitung (erfolgreich oder mit Fehler) beendet hat. Wird dabei die unter Max. Verarbeit./Aufbw eingestellte Zeit überschritten, bricht der Antwortweg mit Fehler ab, obwohl das Ziel-Profil vielleicht später erfolgreich endet. |
Asynchron | Das Profil sendet die Message und macht sofort weiter; die Antwort ist für die weitere Profilausführung unerheblich. Das Profil wartet nicht auf das Ziel-Profil, sondern der Antwortweg endet erfolgreich nach Übergabe der Daten. Die unter Max. Verarbeit./Aufbw. eingestellte Zeit ist die maximale Lebenszeit der Message; konnte sie in dieser Zeit nicht vom Ziel-Profil angenommen werden, wird sie gelöscht. |
Persistent | Arbeitet analog zu Asynchron. Als Erweiterung wird aber bei fehlender Gegenstelle die Message abgespeichert und versucht alle 50 ms die Message zu senden. Konnte innerhalb der unter Max. Verarbeit./Aufbw. eingestellten Zeit kein Erfolg erreicht werden, geht die Message verloren. |
AMQP Message Properties
Um eine Message Property zu setzen, muss 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_TTLkönnen Sie die Message Property TTL setzen.
Besonderheit AMQP 0.9.1
Wenn Sie AMQP 0.9.1 verwenden, können nur bestimmte Message Properties mit den folgenden System-Variablen gesetzt werden.
AMQP_091BASIC_CONTENT_TYPEAMQP_091BASIC_CONTENT_ENCODINGAMQP_091BASIC_MESSAGE_IDAMQP_091BASIC_TIMESTAMPAMQP_091BASIC_EXPIRATIONAMQP_091BASIC_APP_IDAMQP_091BASIC_USER_IDAMQP_091BASIC_TYPEAMQP_091BASIC_PRIORITYAMQP_091BASIC_CORRELATION_ID
Besonderheit AMQP 1.0
Für die Message Properties MessageId und CorrelationId gilt per Standard:
Falls keine Zuweisung für
CorrelationIdüber die VariableAMQP_SYS_CorrelationIdvorliegt, wird eine automatisch generierteUUIDzugewiesen.Falls keine Zuweisung für
MessageIdüber die VariableAMQP_SYS_MessageIdvorliegt, wird ein zufälliger String zugewiesen.
Dieses Standardverhalten kann man ab LDP Release 26.2.0 bei Bedarf über eine Wertzuweisung (siehe Tabelle „Werte für AMQP_SYS_MESSAGE_CORRELATION_ID_FORMAT".) an eine eigens definierte Profilvariable AMQP_SYS_MESSAGE_CORRELATION_ID_FORMAT übersteuern.
WICHTIG
Voraussetzungen für die Nutzung der Nicht-Standard-Logik für
CorrelationIdundMessageId
Da Variablen nur im Kontext der Phase 3 (Mapping) definiert werden können, muss das Mapping zu diesem Zweck ggf. aktiviert werden.
Die Variable
AMQP_SYS_MESSAGE_CORRELATION_ID_FORMATmuss im Profil explizit angelegt sein (Typ:String).Der Variablen
AMQP_SYS_MESSAGE_CORRELATION_ID_FORMATmuss beim Ausführen des Antwortwegs einer der unten genannten Werte zugewiesen sein.
Werte für AMQP_SYS_MESSAGE_CORRELATION_ID_FORMAT
Wertzuweisung ( | Wirkung auf | Wirkung auf |
|---|---|---|
| Ausgabe als Standardwert: String-Abbild einer automatisch generierten | Ausgabe als Standardwert: zufälliger |
| Ausgabe als Standardwert: Hash-Wert ( | Ausgabe als Standardwert: zufälliger |
| Ausgabe als Byte Array Standardwert: Byte Array des String-Abbilds einer automatisch generierten | Ausgabe als Byte-Array Standardwert: zufälliger |
Standard | Ausgabe als Standardwert: automatisch generierte | Ausgabe als Standardwert: zufälliger |
Hinweis
Das mit vorherigen Versionen übereinstimmende Standardverhalten greift, wenn die Variable nicht existiert, keine Wertzuweisung vorliegt oder ein hier nicht aufgelisteter Wert zugewiesen wurde.
Über die folgenden System-Variablen können Sie weitere Message-Properties setzen:
AMQP_SYS_GroupIdAMQP_SYS_ContentTypeAMQP_SYS_Subject
Body Type
Über die System-Variable AMQP_SYS_BodyType (Typ: String) wird der Body Type des Antwortwegs AMQP/JMS festgelegt. Erlaubte Werte: data, sequence, value. Standardwert: value.
AMQP 1.0 Message Headers
Wenn Sie AMQP 1.0 verwenden, können Sie Message Header mit System-Variablen der Form AMQP_<Name des Headers> setzen (Groß- und Kleinschreibung im Header wird beachtet).