Synadia Connect

AMQP 1.0

NAMERUNTIMETYPEVERSION
amqp_1wombatsinklatest

Sends messages to an AMQP (1.0) server.

Message metadata is added to each AMQP message as string annotations. In order to control which metadata keys are added use the metadata config field.

This output benefits from sending multiple messages in flight in parallel for improved performance. You can tune the max number of in flight messages (or message batches) with the field max_in_flight.


Configuration

NameTypeOptionalSecretDescription
urls[]stringnonoA list of URLs to connect to. The first URL to successfully establish a connection will be used until the connection is closed. If an item of the list contains commas it will be expanded into multiple URLs.
target_addressstringnonoThe target address to write to.
max_in_flightintyesnoThe maximum number of messages to have in flight at a given time. Increase this to improve throughput. The value defaults to 64.
tlstlsnonoCustom TLS settings can be used to override system defaults.
application_properties_mapstringnonoAn optional Bloblang mapping that can be defined in order to set the application-properties on output messages.
saslsaslyesnoEnables SASL authentication.
metadatametadatanonoSpecify criteria for which metadata values are attached to messages as headers.
content_typestringyesnoSpecify the message body content type. The option string will transfer the message as an AMQP value of type string. Consider choosing the option string if your intention is to transfer UTF-8 string messages (like JSON messages) to the destination. The value should be one of opaque_binary or string. The value defaults to "opaque_binary".

TLS Configuration

NameTypeOptionalSecretDescription
enabledboolyesnoWhether custom TLS settings are enabled. The value defaults to false.
skip_cert_verifyboolyesnoWhether to skip server side certificate verification. The value defaults to false.
enable_renegotiationboolyesnoWhether to allow the remote server to repeatedly request renegotiation.
Enable this option if you're seeing the error message local error: tls: no renegotiation. The value defaults to false.
root_casstringyesyesAn optional root certificate authority to use.
This is a string, representing a certificate chain from the parent trusted root certificate,
to possible intermediate signing certificates, to the host certificate. The value defaults to "".
client_certs[]client_certsyesnoA list of client certificates to use. . The value defaults to [].

SASL

NameTypeOptionalSecretDescription
mechanismstringyesnoThe SASL authentication mechanism to use. The value defaults to "none".
userstringyesnoA SASL plain text username. It is recommended that you use environment variables to populate this field. The value defaults to "".
passwordstringyesyesA SASL plain text password. It is recommended that you use environment variables to populate this field. The value defaults to "".

Metadata

NameTypeOptionalSecretDescription
exclude_prefixes[]stringyesnoA list of explicit metadata key prefixes to be excluded. The value defaults to [].
Previous
AMQP 0.9