Skip to main content

AMQP 0.9

Publishes messages to an AMQP 0.9 exchange (e.g. RabbitMQ).

FieldTypeDefaultDescription
URLsarrayList of broker URLs to connect to. The first successful connection is used
ExchangestringName of the AMQP exchange to publish to. Supports interpolation functions
Routing Keystring""Binding key attached to each message. Supports interpolation functions
Typestring""Type property attached to each message. Supports interpolation functions
Content Typestringapplication/octet-flowContent type attribute for published messages
PersistentbooleanfalseSend messages with persistent delivery mode so they survive broker restarts
Max In Flightinteger64Maximum number of messages to have in flight at a given time
Exchange Declare — EnabledbooleanfalseDeclare the exchange during connection if it does not exist
Exchange Declare — TypestringdirectType of exchange to declare: direct, fanout, topic, or x-custom
Exchange Declare — DurablebooleantrueWhether the declared exchange survives broker restarts