AMQP Publisher | X4Documentation

Dieser Adapter ermöglicht das Veröffentlichen von Nachrichten in einem AMQP-Topic.

Eigenschaften (Properties)

Operation

Vom Adapter ausgeführte Operation

Mögliche Werte:

Publish: Nachrichten in einem AMQP-Topic veröffentlichen

Parameter

`Adapter`	Adapter-Hauptklasse (nicht verändern!) Mögliche Werte: de.softproject.integration.adapter.amqp.AmqpPublisherAdapter : Hauptklasse (Standard)
`storedConfig`	Bezeichner der Konfiguration, bereitgestellt in der Datei `amqpconfig.xml` Mögliche Werte: Beliebige Zeichenkette mit dem Bezeichner, z. B. `queueEmployeesConfig` Dieser Parameter ist erforderlich, wenn Sie die Datei `amqpconfig.xml` verwenden.
`host`	AMQP Server-Host Mögliche Werte: Server-Host, z. B. `localhost` Dieser Parameter ist erforderlich, wenn Sie die Datei `amqpconfig.xml` nicht verwenden.
`port`	Dedizierter AMQP-Port auf dem Server Mögliche Werte: AMQP-Port-Nummer, z. B. `5672` Dieser Parameter ist erforderlich, wenn Sie die Datei `amqpconfig.xml` nicht verwenden.
`username`	Name des Benutzers, der die Nachricht veröffentlicht Mögliche Werte: Beliebige Zeichenkette mit dem Benutzernamen, z. B. `user`
`password`	Passwort des Benutzers Mögliche Werte: Beliebige Zeichenkette mit dem Passwort, z. B. `p4ssw0rd`
`queue`	Warteschlange, in der die Nachricht veröffentlicht wird Mögliche Werte: Beliebige Zeichenkette mit dem Namen der Warteschlange, z. B. `employees` Dieser Parameter ist erforderlich, wenn Sie die Datei `amqpconfig.xml` nicht verwenden.
`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. Wenn der Parameter `qos` nicht angegeben ist, ist der Standardwert `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.
`durable`	Nachricht als dauerhaft definieren Mögliche Werte: `true` (Standard) `false`
`priority`	Prioritätsstufe der Nachricht Mögliche Werte: Beliebige Ganzzahl zwischen `0` und `255`, z. B. `3`
`ttl`	Zeitspanne in Millisekunden, nach der die Nachricht verworfen werden soll Mögliche Werte: Beliebige Ganzzahl, die die Zeitspanne in Millisekunden angibt, z. B. `4500`

Statuswerte

1	Die Operation wurde erfolgreich ausgeführt.
`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:

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>

Input

Der AMQP Publisher erwartet folgende Input-Struktur, wobei nur ein Element pro Nachricht erlaubt ist:

Einfache Typen:

XML

<Messages>
	<Message>
		<Element type="String" value="Good morning!!"/>
	</Message>
	<Message>
		<Element type="Int" value="18"/>
	</Message>
</Messages>

Folgende einfache Typen sind erlaubt: Binary, Boolean, Byte, Char, Decimal32, Decimal64, Decimal128, Double, Float, Long, Short, String, Symbol, Timestamp (nach dem Muster yyyy-[m]m-[d]d hh:mm:ss), UByte, UInt, ULong, UShort, Uuid.

Komplexe Typen:

Liste:

XML

<Messages>
	<Message>
		<Element type="List">
			<Element type="Int" value="1"/>
			<Element type="Short" value="3"/>
			<Element type="Boolean" value="false"/>
		</Element>
	</Message>
</Messages>

Map:

XML

<Messages>
    <Message>
        <Element type="Map">
            <Entries>
                <Entry>
                    <Key type="Int" value="2"/>
                    <Value type="String" value="Hello!!"/>
                </Entry>
				<Entry>
                    <Key type="Int" value="5"/>
                    <Value type="String" value="Goodbye!!"/>
                </Entry>
            </Entries>
        </Element>
    </Message>
</Messages>