class LavinMQ::AMQP::PriorityQueue::PriorityMessageStore

Defined in:

lavinmq/amqp/queue/priority_queue.cr

Constructors

Instance Method Summary

Instance methods inherited from class LavinMQ::MessageStore

[](sp : SegmentPosition) : BytesMessage [], avg_bytesize : UInt32 avg_bytesize, bytesize : UInt64 bytesize, close : Nil close, closed : Bool closed, delete(sp) : Nil
delete delete, empty : BoolChannel empty, empty? empty?, first? : Envelope | Nil first?, purge(max_count : Int = UInt32::MAX) : UInt32 purge, purge_all purge_all, 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

Constructor methods inherited from class LavinMQ::MessageStore

new(msg_dir : String, replicator : Clustering::Replicator | Nil, durable : Bool = true, metadata : ::Log::Metadata = ::Log::Metadata.empty) new

Constructor Detail

def self.new(max_priority : UInt8, msg_dir : String, replicator : Clustering::Replicator | Nil, durable : Bool = true, metadata : ::Log::Metadata = ::Log::Metadata.empty) #

[View source]

Instance Method Detail

def [](sp : SegmentPosition) : BytesMessage #

[View source]
def close : Nil #

[View source]
def delete(sp) : Nil #

[View source]
def delete #

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

[View source]
def purge(max_count : Int = UInt32::MAX) : UInt32 #
Description copied from class LavinMQ::MessageStore

Deletes all "ready" messages (not unacked)


[View source]
def purge_all #

[View source]
def push(msg) : SegmentPosition #

[View source]
def requeue(sp : SegmentPosition) #

[View source]
def shift?(consumer = nil) : Envelope | Nil #

[View source]