class

LavinMQ::AMQP::DelayedRetryQueue

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

Internal queue that holds messages rejected from its primary queue until their backoff delay expires, then publishes them back for redelivery. Created and deleted together with the primary queue.

Class methods

create(vhost : VHost, primary_queue : Queue)

Source

Instance methods

delay(msg : Message) : Bool

Source

restart!

Only the primary queue's restart replaces a retry queue

Source