class

LavinMQ::AMQP::DelayedQueue

Inherits LavinMQ::AMQP::Queue < LavinMQ::AMQP::Argument::DeadLettering < LavinMQ::AMQP::ArgumentTarget < LavinMQ::AMQP::QueueStats < LavinMQ::Stats < LavinMQ::SortableJSON < LavinMQ::PolicyTarget < Reference < Object

Base class for the internal queues that hold messages until a per-message delay expires: the delayed exchange queue and the retry queue. Backed by DelayedMessageStore so messages expire in delivery-time order.

Constants

MAX_NAME_LENGTH = 255

Instance methods

ack(sp : SegmentPosition) : Nil
Source
basic_get(no_ack, force = false, & : Envelope -> Nil) : Bool
Source
expire_messages

Routing a released message can fan out to many queues, so it runs outside the lock, on a lease that keeps the message's segment mapped

Source
internal?
Source
publish(message : Message) : PublishResult
Source
reject(sp : SegmentPosition, requeue : Bool)

Consumer-initiated reject (basic.reject and basic.nack): delays via the retry queue if configured

Source
requeue(sp : SegmentPosition)

Broker-initiated requeue (channel close, basic.recover): always instant, never via the retry queue

Source

Nested types