Instance methods inherited from class LavinMQ::DurableQueue

durable? durable?

Instance methods inherited from class LavinMQ::Queue

ack(sp : SegmentPosition) : Nil ack, ack_count : UInt64 ack_count, add_consumer(consumer : Client::Channel::Consumer) add_consumer, apply_policy(policy : Policy | Nil, operator_policy : OperatorPolicy | Nil) apply_policy, arguments : AMQ::Protocol::Table arguments, auto_delete? : Bool auto_delete?, basic_get(no_ack, force = false, & : Envelope -> Nil) : Bool basic_get, bindings bindings, close : Bool close, closed? : Bool closed?, confirm_count : UInt64 confirm_count, consume_get(consumer, & : Envelope -> Nil) : Bool consume_get, consumer_count consumer_count, consumer_timeout : UInt64 | Nil consumer_timeout, consumers : Array(LavinMQ::Client::Channel::Consumer) consumers, current_stats_details current_stats_details, delete : Bool delete, deliver_count : UInt64 deliver_count, details_tuple details_tuple, durable? durable?, empty? : Bool empty?, empty_change : Channel(Bool) empty_change, exclusive? : Bool exclusive?, get_count : UInt64 get_count, get_no_ack_count : UInt64 get_no_ack_count, has_exclusive_consumer? : Bool has_exclusive_consumer?, has_priority_consumers? : Bool has_priority_consumers?, immediate_delivery? immediate_delivery?, in_use? in_use?, inspect(io : IO) inspect, last_get_time : Time::Span last_get_time, match?(durable, exclusive, auto_delete, arguments)
match?(frame) match?, message_count message_count, message_count_log : Deque(UInt32) message_count_log, name : String name, operator_policy : OperatorPolicy | Nil operator_policy, pause! pause!, paused? : Bool paused?, paused_change : Channel(Bool) paused_change, policy : Policy | Nil policy, publish(msg : Message) : Bool publish, publish_count : UInt64 publish_count, purge(max_count : Int = UInt32::MAX) : UInt32 purge, purge_and_close_consumers : UInt32 purge_and_close_consumers, read(sp : SegmentPosition) : Envelope read, redeclare redeclare, redeliver_count : UInt64 redeliver_count, reject(sp : SegmentPosition, requeue : Bool) reject, reject_count : UInt64 reject_count, resume! resume!, return_unroutable_count : UInt64 return_unroutable_count, rm_consumer(consumer : Client::Channel::Consumer) rm_consumer, single_active_consumer : Client::Channel::Consumer | Nil single_active_consumer, single_active_consumer_change : Channel(LavinMQ::Client::Channel::Consumer) single_active_consumer_change, state : LavinMQ::QueueState state, stats_details stats_details, to_json(json : JSON::Builder, consumer_limit : Int32 = -1) to_json, unacked_bytesize : UInt64 unacked_bytesize, unacked_count : UInt32 unacked_count, unacked_count_log : Deque(UInt32) unacked_count_log, update_rates : Nil update_rates, vhost : LavinMQ::VHost vhost

Constructor methods inherited from class LavinMQ::Queue

new(vhost : VHost, name : String, exclusive : Bool = false, auto_delete : Bool = false, arguments : AMQ::Protocol::Table = AMQP::Table.new) new

Class methods inherited from class LavinMQ::Queue

generate_name generate_name

Instance methods inherited from module LavinMQ::SortableJSON

details_tuple details_tuple, to_json(json : JSON::Builder) to_json

Macros inherited from module LavinMQ::Stats

rate_stats(stats_keys, log_keys = [] of ::String) rate_stats

Instance methods inherited from module Observable

notify_observers(event : Symbol, data : Object | Nil = nil) notify_observers, register_observer(observer : Observer) register_observer, unregister_observer(observer : Observer) unregister_observer

Instance methods inherited from module LavinMQ::PolicyTarget

apply_policy(policy : Policy | Nil, operator_policy : OperatorPolicy | Nil) apply_policy, clear_policy clear_policy, operator_policy : OperatorPolicy | Nil operator_policy, policy : Policy | Nil policy