Documentation Index

Fetch the complete documentation index at: https://docs.lobster-world.com/llms.txt

Use this file to discover all available pages before exploring further.

Antwortweg AMQP

Prev Next

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_TTL kö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_TYPE

  • AMQP_091BASIC_CONTENT_ENCODING

  • AMQP_091BASIC_MESSAGE_ID

  • AMQP_091BASIC_TIMESTAMP

  • AMQP_091BASIC_EXPIRATION

  • AMQP_091BASIC_APP_ID

  • AMQP_091BASIC_USER_ID

  • AMQP_091BASIC_TYPE

  • AMQP_091BASIC_PRIORITY

  • AMQP_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 Variable AMQP_SYS_CorrelationId vorliegt, wird eine automatisch generierte UUID zugewiesen.

  • Falls keine Zuweisung für MessageId über die Variable AMQP_SYS_MessageId vorliegt, 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 CorrelationId und MessageId

  • 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_FORMAT muss im Profil explizit angelegt sein (Typ: String).

  • Der Variablen AMQP_SYS_MESSAGE_CORRELATION_ID_FORMAT muss beim Ausführen des Antwortwegs einer der unten genannten Werte zugewiesen sein.

Werte für AMQP_SYS_MESSAGE_CORRELATION_ID_FORMAT

Wertzuweisung (String)

Wirkung auf CorrelationId

Wirkung auf MessageId

string

Ausgabe als String

Standardwert: String-Abbild einer automatisch generierten UUID

Ausgabe als String

Standardwert: zufälliger String

long

Ausgabe als Long

Standardwert: Hash-Wert (Long) einer automatisch generierten UUID

Ausgabe als Long

Standardwert: zufälliger String

binary

Ausgabe als Byte Array

Standardwert: Byte Array des String-Abbilds einer  automatisch generierten UUID

Ausgabe als Byte-Array

Standardwert: zufälliger String

Standard

Ausgabe als UUID

Standardwert: automatisch generierte UUID

Ausgabe als UUID

Standardwert: zufälliger String

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_GroupId

  • AMQP_SYS_ContentType

  • AMQP_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).