Module rabbitmq 

RabbitMQ AMQP 0-9-1 source and sink. RabbitMQ source and sink over AMQP 0-9-1 (the lapin client).

The source consumes one classic or quorum queue with manual acknowledgements and releases a message only after the checkpoint containing it is durable (at-least-once). The sink publishes to one exchange with publisher confirms and, by default, mandatory routing. Routing, TTL, dead-lettering, delivery limits, priorities, and queue limits stay broker-native: exchanges and bindings route, and policies or declaration arguments own the rest.

Re-exports

pub use sink::RabbitMqSink;

pub use source::RabbitMqSource;

Modules

config

RabbitMQ source and sink configuration.

metadata

Typed AMQP delivery metadata: selectable columns appended after the decoded payload columns.

sink

RabbitMQ sink: publisher-confirmed, optionally mandatory publishes to one exchange.

source

RabbitMQ source: one manual-acknowledgement consumer on an existing (or opt-in declared) classic or quorum queue.

Functions

register_rabbitmq_sink

Registers the RabbitMQ sink connector.

register_rabbitmq_source

Registers the RabbitMQ source connector.