AMQP Subscriber

Der Adaper verwaltet Abonnements für eine AMQP-Warteschlange und definiert den auszuführenden Prozesses.

Eigenschaften (Properties)

Operation

Vom Adapter ausgeführte Operation

Mögliche Werte:

Subscribe: AMQP-Warteschlange abonnieren und den auszuführenden Prozess definieren
Erforderliche Parameter sind host, port, username, password, queue und process. Die Parameter können auch über eine Konfigurationsdatei bereitgestellt werden, die im Parameter storedConfig referenziert wird.
Unsubscribe: AMQP-Warteschlange abkündigen
Erforderliche Parameter sind username und queue. Die Parameter können auch über eine Konfigurationsdatei bereitgestellt werden, die im Parameter storedConfig referenziert wird.

Parameter

`Adapter`	Adapter-Hauptklasse (nicht verändern!) Mögliche Werte: de.softproject.integration.adapter.amqp.AmqpSubscriberAdapter: Hauptklasse (Standard)
`storedConfig`	Bezeichner der Konfiguration, bereitgestellt in der Datei `amqpconfig.xml` Mögliche Werte: Beliebige Zeichenkette mit dem Bezeichner, z. B. `queueEmployeesConfig`
`host`	AMQP Server-Host Mögliche Werte: Server-Host, z. B. `localhost`
`port`	Dedizierter AMQP-Port auf dem Server Mögliche Werte: AMQP-Port-Nummer, z. B. `5672`
`username`	Name des Benutzers, der die Nachricht abonniert bzw. abkündigt Mögliche Werte: Beliebige Zeichenkette mit dem Benutzernamen, z. B. `user`
`password`	Password des Benutzers Mögliche Werte: Beliebige Zeichenkette mit dem Passwort, z. B. `p4ssw0rd`
`queue`	Warteschlange, in der die Nachricht abonniert bzw. abkündigt wird Mögliche Werte: Beliebige Zeichenkette mit dem Namen der Warteschlange, z. B. `employees`
`container`	Container, in dem sich die Warteschlange befindet Mögliche Werte: Beliebige Zeichenkette mit dem Container-Namen z. B. `employeesContainer`
`qos`	Quality of Service der Nachricht Mögliche Werte: `AT_MOST_ONCE`: Die Nachricht wird höchstens ein Mal oder kein einziges Mal zugestellt. `AT_LEAST_ONCE`: Die Nachricht wird mindestens ein Mal zugestellt. `EXACTLY_ONCE`: Die Nachricht wird nur ein Mal zugestellt. Ist der Parameter `qos` nicht angegeben, ist der Standard-Wert `AT_MOST_ONCE`.
`useSsl`	SSL-Verschlüsselung aktivieren Mögliche Werte: `true` / `false` (Standard)
`useSasl`	SASL-Verschlüsselung aktivieren Mögliche Werte: `true` `false` (Standard)
`mechanism`	SASL-Mechanismus des entfernten Endpoints Mögliche Werte: `PLAIN`: Alle Daten werden im Klartext ausgetauscht (Standard). `ANONYMOUS`: Der Dienst kann ohne Authentifizierung genutzt werden. `CRAM-MDS`: Verhindert die Passwort-Übertragung im Klartext. `Digest-MDS`: Zusätzliche Parameter wie Integritätssicherung können verwendet werden.
`process`	Pfad des Technical Processes, der ausgeführt wird, sobald eine Nachricht empfangen wird Mögliche Werte: Prozesspfad, z. B. `x4db://1/Project/Processes/process.wrf`

Statuswerte

`0`	Die Operation wurde erfolgreich ausgeführt (es wird keine Ausgabe generiert)
`-1`	Während der Ausführung der Operation kam es zu einem Fehler (es wird keine Ausgabe generiert)

Konfiguration

Um die benötigten Informationen bereitzustellen, kann eine Konfigurationsdatei verwendet werden, die beim Serverstart geladen wird. Die Konfigurationsdatei amqpconfig.xml muss unter dem Pfad X4DB/0 bereitgestellt werden.

Die Datei hat folgende Struktur:

amqpconfig.xml

XML

<?xml version='1.0' encoding='UTF-8'?>
<RootElement>
    <AMQPConfig name="queueEmployeesConfig">
        <Server host="localhost" port="5672" useSsl="false"/>
        <Client user="user" password="p4ssw0rd"/>
        <Queue container="employeesContainer" name="employees" qos="AT_LEAST_ONCE"/>
    </AMQPConfig>
</RootElement>