Module config 

RabbitMQ source and sink configuration.

Connection settings use the AMQP URI natively (heartbeat, frame_max, channel_max, connection_timeout, and auth_mechanism query parameters are interpreted by the client). Every other option is either a native AMQP property/argument or a local resource bound.

Structs

ConnectionConfig

Validated broker connection settings shared by the source and sink.

ExchangeDeclaration

Opt-in, idempotent exchange declaration.

QueueBinding

Opt-in, idempotent queue.bind calls applied at startup.

QueueDeclaration

Opt-in, idempotent queue declaration. Without it the queue must already exist.

RabbitMqSinkConfig

Validated RabbitMQ sink settings.

RabbitMqSourceConfig

Validated RabbitMQ source settings.

Enums

DecodeErrorPolicy

What the source does with a message its codec cannot decode or that exceeds the size bound.

DeliveryMode

AMQP delivery-mode written by the sink.

Valued

Where a per-message value comes from.