Mit dem AMQP-Eingangsagenten empfangen Sie Nachrichten von einem Broker. Derzeit stehen ausschließlich AMQP-1.0-Aliase zur Verfügung.
Voraussetzung
Der Eingangsagent ist nur auswählbar, wenn mindestens eine AMQP-Verbindung eingerichtet ist.
Klickpfad
Integration > Profile > Phase 1 > Eingangsagent wechseln > AMQP
Einstellungen

Einstellung | Beschreibung |
|---|---|
Verbindungs-Alias | Auswahl eines Alias. Pflichtfeld. Derzeit stehen ausschließlich AMQP-1.0-Aliase zur Verfügung. |
Queue/Topic | Name der abzufragenden Queue bzw. des Topics. Pflichtfeld. Manche Broker verlangen ein zusätzliches Präfix, z. B. |
Endpunkttyp | Legt fest, ob als Quelle eine Queue oder ein Topic abgefragt wird. Pflichtfeld. |
Client-ID | Optional. Name des Clients. Bleibt das Feld leer, wird automatisch eine ID generiert. Für eine dauerhafte Topic-Subscription ist eine Client-ID zwingend erforderlich. Im Modus IMMEDIATE steuert die Client-ID zudem, ob Queue-Consumer konkurrieren: Eine gesetzte Client-ID erzeugt einen eigenen Subscriber-Thread, sodass die Consumer einer Queue um die Nachrichten konkurrieren. |
Dauerhafte Subscription ('durable') | Nur bei Endpunkttyp = Topic sichtbar. Aktiviert eine dauerhafte Topic-Subscription. Erfordert eine Client-ID sowie einen Namen der Subscription. |
Name der Subscription | Name der dauerhaften Subscription. Nur sichtbar, wenn Dauerhafte Subscription ('durable') aktiviert ist. |
Servicequalität | Bestimmt, wann eine empfangene Nachricht bestätigt wird (siehe Abschnitt Servicequalität). Pflichtfeld. |
Bestätigungsmodus | Bestimmt Zeitpunkt und Verarbeitungsmodus der Bestätigung (siehe Abschnitt Bestätigungsmodus). Pflichtfeld. |
Shutdown-Timeout (Sek.) | Nur für die synchronen Bestätigungsmodi (AFTER_PROCESSING, RPC) relevant. Muss der Subscriber-Thread neu gestartet werden, wird zunächst für die eingestellte Dauer auf den laufenden Job gewartet. Nach Ablauf wird der Thread neu gestartet und die Nachricht nicht bestätigt – der laufende Job läuft weiter, die unbestätigte Nachricht wird aber vom Broker erneut zugestellt (doppelte Verarbeitung). Standard: 30.
|
Servicequalität

Option | Verhalten |
|---|---|
AT_MOST_ONCE | Eine empfangene Nachricht wird sofort bestätigt. Tritt vor dem Upload ins System ein Fehler auf, kann die Nachricht verloren gehen. |
AT_LEAST_ONCE | Eine empfangene Nachricht wird erst bestätigt, nachdem sie ins System hochgeladen wurde. Tritt zwischen Upload und Bestätigung ein Fehler auf, kann eine Nachricht doppelt verarbeitet werden. Bei RPC führt ein Fehler bei der Bestätigung nach einem erfolgreichen Job – bei dem die RPC-Antwort bereits gesendet wurde – zu einer erneuten Zustellung: Der Job läuft erneut und erzeugt eine zweite Antwort. |
Bestätigungsmodus

Option | Verhalten |
|---|---|
IMMEDIATE | Asynchrone Subscription. Nachrichten werden bestätigt, nachdem der Upload ins System erfolgreich war. Profile mit identischen Einstellungen werden automatisch zum selben Subscriber-Thread zusammengefasst (1:n) – alle diese Profile erhalten die Nachricht. ACHTUNG: Eine gesetzte Client-ID erzeugt einen neuen Subscriber-Thread; bei Queues konkurrieren die Consumer dann (siehe Client-ID). |
AFTER_PROCESSING | Die Nachricht wird erst bestätigt, nachdem der zugehörige Job erfolgreich beendet wurde. Erfordert die Servicequalität AT_LEAST_ONCE. Ein Profil mit diesem Modus erhält immer einen eigenen Subscriber-Thread (1:1), da es sich um einen synchronen Vorgang handelt. |
RPC | Synchroner Vorgang (wartet, bis eine Antwort gesendet wurde) und erhält daher ebenfalls einen eigenen Subscriber-Thread (1:1). |
AMQP Message Properties
Bei eingehenden Verbindungen werden die Eigenschaften einer empfangenen Nachricht in MSG_CALL_*-Variablen bereitgestellt.
Application Properties
Alle benutzerdefinierten Application Properties werden gesammelt und jeweils in einer Variable MSG_CALL_AMQP_APPLICATION_PROPERTY_<key> bereitgestellt. <key> ist der Schlüssel der Property (Groß- und Kleinschreibung wird beachtet). In der Legacy-Implementierung wurden diese als „Header“ bezeichnet.
Beispiel: Eine Application Property
<key>mit dem Wert2345wird alsMSG_CALL_AMQP_APPLICATION_PROPERTY_Keymit dem Wert2345bereitgestellt.
Fixed Properties
Auch die vordefinierten Properties werden – sofern gesetzt – in der jeweiligen MSG_CALL_*-Variable bereitgestellt (ist eine Property nicht gesetzt, wird keine Variable angelegt).
Die vollständige Liste der Variablen finden Sie unter System-Variablen.