class LavinMQ::DurableDelayedExchangeQueue
Defined in:
lavinmq/queue/delayed_exchange_queue.crInstance Method Summary
Constructor methods inherited from class LavinMQ::DelayedExchangeQueue
new(*args)
new
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,
basic_get_unacked : Deque(LavinMQ::UnackedMessage)
basic_get_unacked,
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, notify_observers(event : LavinMQ::QueueEvent, data : Object | Nil = nil) notify_observers, 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, register_observer(observer : LavinMQ::Observer(LavinMQ::QueueEvent)) register_observer, 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, unregister_observer(observer : LavinMQ::Observer(LavinMQ::QueueEvent)) unregister_observer, update_rates : Nil update_rates, vhost : LavinMQ::VHost vhost