Skip to main content

AMQP 0.9

Consumes messages from an AMQP 0.9 queue (e.g. RabbitMQ).

FieldTypeDefaultDescription
URLsarrayList of broker URLs to connect to. The first successful connection is used
QueuestringName of the AMQP queue to consume from
Consumer Tagstring""Identifier for the consumer connection
Auto AckbooleanfalseAcknowledge messages on receipt, skipping downstream acknowledgment
Prefetch Countinteger10Maximum number of pending messages to have in-flight at a time
Nack Reject Patternsarray[]Regular expressions matched against processing errors. Messages whose errors match are dropped instead of requeued
Queue Declare — EnabledbooleanfalseDeclare the queue during connection if it does not exist
Queue Declare — DurablebooleantrueWhether the declared queue survives broker restarts
Queue Declare — Auto DeletebooleanfalseWhether the declared queue is deleted when the last consumer disconnects