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.

  • Exchange

    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 module guide 1147 1, um eine Truststore-Datei hinzuzufügen.

Authentifizierung

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 module guide 1148 1, um einen neuen Eintrag zu erstellen.

    • Klicken Sie auf das Icon Eintrag löschen module guide 1148 2, um einen neuen Eintrag zu entfernen.

    • Klicken Sie auf das Icon Suchen module guide 1148 3, 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 x-match mit einem der Werte any oder all definieren.

Wenn Sie den Schlüssel x-match auf any setzen, gelten die Filterbedingungen als erfüllt, wenn ein Schlüssel-Werte-Paar gültig ist.

Wenn Sie den Schlüssel x-match auf all setzen, gelten die Filterbedingungen als erfüllt, wenn alle Schlüssel-Werte-Paare gültig ist.

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

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.