class LavinMQ::PriorityQueue::PriorityMessageStore
Defined in:
lavinmq/queue/priority_queue.crConstructors
Instance Method Summary
Instance methods inherited from class LavinMQ::Queue::MessageStore
[](sp : SegmentPosition) : BytesMessage
[],
avg_bytesize : UInt32
avg_bytesize,
bytesize : UInt64
bytesize,
close : Nil
close,
delete(sp) : Nildelete delete, empty? empty?, empty_change : Channel(Bool) empty_change, first? : Envelope | Nil first?, purge(max_count : Int = UInt32::MAX) : UInt32 purge, push(msg) : SegmentPosition push, requeue(sp : SegmentPosition) requeue, shift?(consumer = nil) : Envelope | Nil shift?, size : UInt32 size, unmap_segments(except : Enumerable(UInt32) = StaticArray(UInt32, 0).new(0_u32)) unmap_segments