Instance methods inherited from class AvalancheMQ::Queue

ack(sp : SegmentPosition, persistent : Bool) : Nil ack, ack_count : UInt64 ack_count, add_consumer(consumer : Client::Channel::Consumer) add_consumer, any? : Bool any?, apply_policy(policy : Policy) apply_policy, arguments : Hash(String, AMQ::Protocol::Field) arguments, auto_delete : Bool auto_delete, basic_get(no_ack) : Envelope | Nil basic_get, clear_policy clear_policy, close : Bool close, closed? : Bool? closed?, compact compact, confirm_count : UInt64 confirm_count, consumer_available consumer_available, consumer_count consumer_count, consumers : AvalancheMQ::ConsumerStore consumers, delete : Bool delete, deliver_count : UInt64 deliver_count, details_tuple details_tuple, durable : Bool durable, empty? : Bool empty?, exclusive : Bool exclusive, flow=(flow : Bool) flow=, fsync_ack fsync_ack, fsync_enq fsync_enq, get_count : UInt64 get_count, get_no_ack_count : UInt64 get_no_ack_count, has_exclusive_consumer? : Bool has_exclusive_consumer?, immediate_delivery? immediate_delivery?, in_use? in_use?, inspect(io : IO) inspect, internal=(internal : Bool) internal=, internal? : Bool internal?, last_get_time : Time::Span last_get_time, match?(durable, exclusive, auto_delete, arguments)
match?(frame) match?, message_available message_available, message_count message_count, message_count_log : Deque(UInt32) message_count_log, metadata(sp) : MessageMetadata | Nil metadata, name : String name, pause! pause!, policy : Policy | Nil policy, publish(sp : SegmentPosition, persistent = false) : Bool publish, publish_count : UInt64 publish_count, purge : UInt32 purge, read(sp : SegmentPosition) read, ready : AvalancheMQ::Queue::ReadyQueue ready, redeclare redeclare, redeliver_count : UInt64 redeliver_count, refresh_ttl_timeout refresh_ttl_timeout, 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, basic_cancel = false) rm_consumer, state : AvalancheMQ::QueueState state, stats_details stats_details, to_json(builder : JSON::Builder) to_json, unacked : AvalancheMQ::Queue::UnackQueue unacked, unacked_count unacked_count, unacked_count_log : Deque(UInt32) unacked_count_log, update_rates update_rates, vhost : AvalancheMQ::VHost vhost

Constructor methods inherited from class AvalancheMQ::Queue

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

Class methods inherited from class AvalancheMQ::Queue

generate_name generate_name

Instance methods inherited from module AvalancheMQ::SortableJSON

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

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 AvalancheMQ::PolicyTarget

apply_policy(p : Policy) apply_policy, clear_policy clear_policy, policy : Policy | Nil policy