class

LavinMQ::AMQP::PriorityQueue::PriorityMessageStore

Instance methods

[](sp : SegmentPosition) : BytesMessage

bytesize

delete(sp) : Nil

delete

empty?

envelope(sp : SegmentPosition, redelivered = false) : Envelope

Like #[], as an envelope, with the segment position made from the message

first?

purge(max_count : Int = UInt32::MAX) : UInt32

Deletes all "ready" messages (not unacked)

purge_all

push(msg) : SegmentPosition

requeue(sp : SegmentPosition)

shift?(consumer = nil) : Envelope | Nil

The envelope points into the segment, so it's only valid while the lock guarding the store is held, see #shift_with_lease? for using it outside it

size