class

LavinMQ::AMQP::DelayedQueue::DelayedMessageStore::DelayedRequeuedStore

Inherits LavinMQ::MessageStore::RequeuedStore < Reference < Object

Instance methods

clear
Source
first?
Source
insert(sp : SegmentPosition, timestamp : Int64) : Nil
Source
insert(sp : SegmentPosition) : Nil
Source
shift?
Source
size
Source
time_to_next_expiration?
Source

Nested types