Sends messages to an AMQP (0.91) exchange. AMQP is a messaging protocol used by various message brokers, including RabbitMQ.
output:amqp_0_9:url: amqp://guest:guest@localhost:5672/exchange: benthos-exchangekey: benthos-keymax_in_flight: 1
The metadata from each message are delivered as headers.
It's possible for this output type to create the target exchange by setting
true, if the exchange already exists
then the declaration passively verifies that the settings match.
TLS is automatic when connecting to an
amqps URL, but custom
settings can be enabled in the
The field 'key' can be dynamically set using function interpolations described here.
This output benefits from sending multiple messages in flight in parallel for
improved performance. You can tune the max number of in flight messages with the
string A URL to connect to.
# Examplesurl: amqp://localhost:5672/url: amqps://guest:guest@localhost:5672/
string An AMQP exchange to publish to.
object Optionally declare the target exchange (passive).
bool Whether to declare the exchange.
string The type of the exchange.
bool Whether the exchange should be durable.
string The binding key to set for each message.
This field supports interpolation functions.
number The maximum number of messages to have in flight at a given time. Increase this to improve throughput.
bool Whether message delivery should be persistent (transient by default).
bool Whether to set the mandatory flag on published messages. When set if a published message is routed to zero queues it is returned.
bool Whether to set the immediate flag on published messages. When set if there are no ready consumers of a queue then the message is dropped instead of waiting.
object Custom TLS settings can be used to override system defaults.
bool Whether custom TLS settings are enabled.
bool Whether to skip server side certificate verification.
string The path of a root certificate authority file to use.
array A list of client certificates to use.
# Examplesclient_certs:- cert: fookey: barclient_certs:- cert_file: ./example.pemkey_file: ./example.key