RabbitMQ Connector
Verwendung
Der RabbitMQ Listener Connector empfängt Nachrichten von einem RabbitMQ-Server, dem sogenannten Message-Broker, und übergibt die Nachrichten an das nächste Modul im Workflow.
Voraussetzungen
Sie haben Zugriff auf einen passend konfigurierten RabbitMQ-Server.
Komponenten
-
Produzent
Der Produzent ist ein Programm, das Nachrichten sendet, die von einer oder mehreren Queues, von einer oder mehreren Exchanges empfangen werden können.
-
Exchanges empfangen Nachrichten, die von einem Produzenten gesendet wurden, und leiten diese an verbundene Queues oder an andere verbundene Exchanges. Welche Nachrichten an welche Queues/Exchanges weitergeleitet werden, ist abhängig vom gewählten Exchange-Typ sowie davon, welche Routing-Keys oder Headers konfiguriert sind.
-
Queue
Die Queue ist ein temporärer Speicher, der die vom Produzenten gesendeten Nachrichten enthält. Die Nachrichten können auch von einer mit der Queue verbundenen Exchange empfangen werden. Es gibt keine Einschränkungen der Anzahl der Nachrichten, die sie enthalten kann.
-
Konsument
Der Empfänger ist ein Programm, das Nachrichten von der Queue empfängt.
Connector Typen
-
Input Connector
Der Input Connector holt Nachrichten von einer Message Queue.
-
Output Connector
Der Output Connector sendet Nachrichten an Exchanges.
Dialog Verbindungskonfiguration
Verbindungskonfiguration
-
URL
URL des RabbitMQ-Servers
-
Port
Portnummer, um auf den RabbitMQ-Server zuzugreifen, Standard:
5672
Der angegebene Port darf nicht von anderen Anwendungen benutzt werden.
-
Virtual host
Mandantenspezifischer Name zum Einschränken des Zugriffs auf Queues, die der Connector lesen kann
-
Verschlüsselung aktivieren
TLS-Verschlüsselung wird unterstützt. Klicken Sie auf , um eine Truststore-Datei hinzuzufügen.
Authentifizierung
-
Statische Zugangsdaten verwenden
-
Login
Benutzername
-
Passwort
Passwort
-
-
Aus dem Credentials Manager auswählen
Für die Authentifizierung können Sie auch Zugangsdaten verwenden, die im Credentials Manager verwaltet werden. Siehe Credentials Manager für die Authentifizierung verwenden.
Verbindungstest
Klicken Sie auf den Button Verbindung testen, um zu versuchen, mit den oben konfigurierten Zugangsdaten eine Verbindung zum RabbitMQ-Server herzustellen.
Dialog Exchange-Konfiguration
Kommunikationseinstellungen
-
Exchange-Typ
-
Default
Beim Exchange-Typ Default werden Nachrichten nur von der im Feld Queue-Name im Abschnitt Queue-*Einstellungen angegebenen Queue gelesen.
-
Fanout
Beim Exchange-Typ Fanout werden Nachrichten von allen Queues der im Feld Exchange-Name im Abschnitt Exchange-Einstellungen angegebenen Exchange gelesen.
-
Topic
Beim Exchange-Typ Topic werden Nachrichten von einer oder mehreren Queues der im Feld Exchange-Name im Abschnitt Exchange-Einstellungen angegebenen Exchange gelesen. Nachrichten werden gelesen anhand der in der gleichnamigen Liste definierten Routing-Keys.
-
Headers
Beim Exchange-Typ Headers werden Nachrichten von einer oder mehreren Queues der im Feld Exchange-Name im Abschnitt Exchange-Einstellungen angegebenen Exchange gelesen. Nachrichten werden gelesen anhand der in der gleichnamigen Liste definierten Headers.
Sowohl in der Liste der Routing-Keys als auch in der Liste der Headers können Sie die folgenden Icons nutzen: -
Klicken Sie auf das Icon Eintrag hinzufügen , um einen neuen Eintrag zu erstellen.
-
Klicken Sie auf das Icon Eintrag löschen , um einen neuen Eintrag zu entfernen.
-
Klicken Sie auf das Icon Suchen , um einen neuen Eintrag zu suchen.
-
Exchange Einstellungen (nicht verfügbar für den Exchange-Typ Default)
-
Exchange-Name
Geben Sie den Exchange-Namen ein, von dem Nachrichten gelesen werden sollen.
-
Durable (bleibt bei einem Neustart des Brokers erhalten)
Aktivieren Sie diese Option, wenn die Exchange erhalten bleiben soll.
-
Automatisch löschen, wenn unbenutzt
Aktivieren Sie diese Option, wenn die Exchange automatisch gelöscht werden soll, wenn sie ungenutzt ist.
Zusätzlich können Sie eine Queue konfigurieren.
Routing-Keys (nur für den Exchange-Typ Topic)
Die Routing-Keys fungieren als Nachrichtenattribute. In der Exchange entscheidet der Routing-Key wie die Nachricht übertragen wird.
Headers (nur für den Exchange-Typ Headers)
Zum Angeben eines oder mehrerer Schlüssel-Wert-Paare und eines Routing-Keys als Header-Attribute zum Filtern von Nachrichten.
Wenn Sie mehr als ein Schlüssel-Wert-Paar definiert haben, müssen Sie auch den Schlüssel Wenn Sie den Schlüssel Wenn Sie den Schlüssel |
Eigenschaften der Nachricht (nur für den Output Connector)
Eigenschaften der Nachricht können dem Output Connector im Dialog Exchange-Konfiguration hinzugefügt werden. Das Hinzufügen dieser Eigenschaften ist optional. Werte für die Eigenschaften können in der Spalte Wert oder über das Variablen-Mapping hinzugefügt werden.
Queue-Einstellungen
-
Queue-Typ
Wählen Sie eine der folgenden Optionen:
-
Classic
-
Quorum
-
Stream
-
-
Queue-Name
Geben Sie den Queue-Namen ein, von wo Nachrichten gelesen werden sollen.
Die folgenden Optionen sind nur für den Queue-Typ Classic verfügbar. |
-
Durable (bleibt bei einem Neustart des Brokers erhalten)
Aktivieren Sie diese Option, wenn die Queue erhalten bleiben soll.
-
Automatisch löschen, wenn unbenutzt
Aktivieren Sie diese Option, wenn die Queue automatisch gelöscht werden soll, wenn sie ungenutzt ist.
-
Exclusiv (nur für eine Verbindung)
Aktivieren Sie diese Option, wenn die Queue gleichzeitig nur von einem Konsumenten genutzt werden soll. Solange ein Konsument mit dieser Queue verbunden ist, werden Verbindungsversuche anderer Konsumenten zurückgewiesen.
Ausführungseinstellungen
Synchroner Modus
-
Aktiviert
Der Listener liest Nachrichten von einer Queue/Exchange und startet den Workflow. Ist der Workflow beendet, sendet der Listener eine Quittung zurück an den Server. Wenn die Workflowausführung fehlschlägt, bleibt die Nachricht auf dem Server erhalten.
-
Deaktiviert
Der Listener sendet eine Quittung, nachdem er die Nachricht vom Server gelesen hat, und startet den Workflow. Wenn die Workflowausführung fehlschlägt, kann die Nachricht aus dem Queue Manager wiederhergestellt und der Workflow erneut gestartet werden.