amqp-consume – Online in der Cloud

PROGRAMM:

NAME/FUNKTION

amqp-consume – Nachrichten aus einer Warteschlange auf einem AMQP-Server konsumieren

ZUSAMMENFASSUNG

amqp-verbrauchen zur Auswahl
Befehl args

Beschreibung

amqp-verbrauchen verbraucht Nachrichten aus einer Warteschlange auf einem AMQP-Server. Für jede Nachricht, die
Wenn die Nachricht eintrifft, wird ein Empfangsbefehl ausgeführt, dem standardmäßig der Nachrichtentext übergeben wird
Eingang.

amqp-verbrauchen kann aus einer vorhandenen Warteschlange konsumieren oder eine neue Warteschlange erstellen. Es kann
Binden Sie die Warteschlange optional an einen vorhandenen Austausch.

Standardmäßig werden Nachrichten mit expliziten Bestätigungen verarbeitet. Es wird nur eine Nachricht gesendet
quittiert werden, wenn der empfangende Befehl erfolgreich beendet wurde (d. h. mit einem Exit-Code von
null). Das AMQP ``nicht ackDer Modus (auch bekannt als Auto-Ack-Modus) kann mit aktiviert werden -A .

Optionen

-q

--Warteschlange=Warteschlange Name
Der Name der Warteschlange, aus der Nachrichten verarbeitet werden sollen.

Besitzt das --Warteschlange Wenn diese Option weggelassen wird, weist der AMQP-Server ihr einen eindeutigen Namen zu
Die Warteschlange und der vom Server zugewiesene Name werden auf stderr angezeigt. dieser Fall
impliziert, dass eine exklusive Warteschlange deklariert werden sollte.

-e

--Austausch=Austausch- Name
Gibt an, dass eine exklusive Warteschlange deklariert und an die angegebene gebunden werden soll
Austausch. Der angegebene Austausch sollte bereits vorhanden sein, es sei denn, der --Austausch-
tippe Mit dieser Option können Sie die Erstellung eines anfordern
Austausch.

-r

--routing-key=Routing Schlüssel
Der Routing-Schlüssel für die Bindung. Wenn es weggelassen wird, wird ein leerer Routing-Schlüssel angenommen.

-d

--erklären Erzwingt die Deklaration einer exklusiven Warteschlange, auch wenn dies andernfalls nicht der Fall wäre.
Das heißt, wenn ein Warteschlangenname mit angegeben wird --Warteschlange Option, aber keine Bindung
Es wird ein Austausch mit dem beantragt --Austausch Möglichkeit. Hinweis: Diese Option ist
veraltet und kann in einer zukünftigen Version entfernt werden. Verwenden Sie die --exklusiv Option zu
explizit eine exklusive Warteschlange deklarieren.

-x

--exklusiv
Deklarierte Warteschlangen sind standardmäßig nicht exklusiv. Diese Option erzwingt die Deklaration von
exklusive Warteschlangen.

-A

--nein-ack=Routing Schlüssel
Aktivieren Sie „nicht ack'' Modus: Der AMQP-Server wird jeden bedingungslos bestätigen
Nachricht, die zugestellt wird, unabhängig davon, ob der Zielbefehl beendet wird
erfolgreich oder nicht.

-c

--zählen=begrenzen
Hören Sie auf zu konsumieren, nachdem die angegebene Anzahl von Nachrichten empfangen wurde.

-p

--prefetch-count=begrenzen
Fordern Sie den Server auf, nur zu senden begrenzen Nachrichten bei a
Zeit.

Wenn ein Wert übergeben wurde --zählen, der an übergebene Wert --prefetch-count
sollte kleiner sein, sonst wird es ignoriert.

If -A/--nein-ack übergeben wird, hat diese Option keine Auswirkung.

Beispiele

Nachrichten aus einer vorhandenen Warteschlange verbrauchen
``meine Warteschlange'', und Ausgabe Nachricht Körper on Standard Ausgabe Katze:" 10

$
amqp-publish -q meine Warteschlange Katze

Binden Sie eine neue exklusive Warteschlange an eine
Austausch ``„myexch“, und senden jeder Nachricht Körper zu Skript Myscript,
Im Prinzip so, wie Sie es von Google Maps kennen. Anerkennung Sie on Server:" 10

$
amqp-verbrauchen -A -e myexch ./myscript

See ebenfalls

librabbitmq-tools(7) beschreibt verbindungsbezogene Optionen, die allen
RabbitMQ C-Client-Tools.

amqp-verbrauchen(1)

Nutzen Sie amqp-consume online über die Dienste von onworks.net