Expand description
RabbitMQ source: one manual-acknowledgement consumer on an existing (or opt-in declared) classic or quorum queue.
Deliveries are handed to the pipeline unacknowledged and acknowledged only after the
checkpoint that contains them is durable. Delivery tags increase monotonically per channel and
deliveries are handed off in tag order, so a cumulative basic.ack(multiple) at the highest
handed-off tag covered by a committed checkpoint acknowledges exactly the committed messages.
A lost channel ends this generation: the broker requeues every unacknowledged delivery and
the engine restarts from its last durable checkpoint (at-least-once; replay may duplicate).
Structsยง
- Rabbit
MqSource - RabbitMQ AMQP 0-9-1 queue source.