abstract class LavinMQ::VHost::SPQueue

• LavinMQ::VHost::SPQueue
• Reference
• Object

Included Modules

• Comparable(LavinMQ::VHost::SPQueue)

Direct Known Subclasses

• LavinMQ::VHost::SPReadyQueue
• LavinMQ::VHost::SPUnsortedQueue

Defined in:

lavinmq/vhost/spqueue.cr

Constructors

• .new(ready : Queue::SortedReadyQueue)
• .new(ready : Queue::ReadyQueue)
• .new(sps : Array(SegmentPosition))
• .new(unack : Queue::UnackQueue)

Instance Method Summary

• #<=>(other : self)
• #empty? : Bool
• #lock : Nil
• #peek : SegmentPosition
• #shift : SegmentPosition
• #unlock : Nil

Constructor Detail

Instance Method Detail