class LavinMQ::AMQP::PriorityQueue::PriorityMessageStore

Defined in:

lavinmq/amqp/queue/priority_queue.cr

Constructors

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) : Nil
delete delete, delete_file(file) delete_file, 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

Constructor methods inherited from class LavinMQ::Queue::MessageStore

new(queue_data_dir : String, replicator : Clustering::Replicator | Nil, metadata : ::Log::Metadata = ::Log::Metadata.empty) new

Constructor Detail

def self.new(*args, **kwargs) #

def initialize(@data_dir : String, metadata : ::Log::Metadata, @replicator : Clustering::Replicator?)


[View source]

Instance Method Detail

def order_messages #

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

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

[View source]