abstract class LavinMQ::MessageStore::RequeuedStore

• LavinMQ::MessageStore::RequeuedStore
• Reference
• Object

Direct Known Subclasses

• LavinMQ::AMQP::DelayedExchangeQueue::DelayedMessageStore::DelayedRequeuedStore
• LavinMQ::MessageStore::PublishOrderedRequeuedStore

Defined in:

lavinmq/message_store/requeued_store.cr

Instance Method Summary

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

Instance Method Detail