class LavinMQ::AMQP::DelayedExchangeQueue::DelayedMessageStore::DelayedRequeuedStore

Defined in:

lavinmq/amqp/queue/delayed_exchange_queue/delayed_requeued_store.cr

Instance Method Summary

Instance methods inherited from class LavinMQ::MessageStore::RequeuedStore

clear : Nil clear, first? : SegmentPosition | Nil first?, insert(sp : SegmentPosition) : Nil insert, shift? : SegmentPosition | Nil shift?

Instance Method Detail

def clear : Nil #

[View source]
def first? : SegmentPosition | Nil #

[View source]
def insert(sp : SegmentPosition, timestamp : Int64) : Nil #

[View source]
def insert(sp : SegmentPosition) : Nil #

[View source]
def shift? : SegmentPosition | Nil #

[View source]
def time_to_next_expiration? : Time::Span | Nil #

[View source]