class

LavinMQ::Shovel::Source

Inherits Reference < Object

A Source yields messages to the Runner and settles them on demand. The Runner — not the Destination — decides whether a delivery is acked or requeued, by calling #ack or #reject after a Destination reports its Outcome. See Runner#run.

Instance methods

ack(delivery_tag)

Acknowledge a successfully shoveled message.

Source
delete_after
Source
each

Yields each consumed message. Returns when the source is exhausted (delete-after) or stopped.

Source
reject(delivery_tag, requeue)

Return a message to the source. With requeue: true it stays available for redelivery; with requeue: false it is dropped/dead-lettered.

Source
start
Source
started?

True while the source can settle deliveries. Outcomes that arrive for a stopped source (confirms voided by a destination close during pause or terminate) have nothing to act on and are ignored by the Runner.

Source
stop
Source