Instance methods inherited from class LavinMQ::TopicExchange

bind(destination : Destination, routing_key, headers = nil) bind, bindings_details : Iterator(BindingDetails) bindings_details, type : String type, unbind(destination : Destination, routing_key, headers = nil) unbind

Instance methods inherited from class LavinMQ::Exchange

alternate_exchange : String? alternate_exchange, apply_policy(policy : Policy | Nil, operator_policy : OperatorPolicy | Nil) apply_policy, arguments : AMQ::Protocol::Table arguments, auto_delete? : Bool auto_delete?, bind(destination : Destination, routing_key : String, headers : AMQP::Table | Nil) bind, bindings_details : Iterator(BindingDetails) bindings_details, clear_policy clear_policy, current_stats_details current_stats_details, delayed? : Bool delayed?, details_tuple details_tuple, do_publish(msg : Message, immediate : Bool, queues : Set(Queue) = Set(Queue).new, exchanges : Set(Exchange) = Set(Exchange).new) : Int32 do_publish, durable? : Bool durable?, find_queues(routing_key : String, headers : AMQP::Table | Nil, queues : Set(Queue), exchanges : Set(Exchange) = Set(Exchange).new) : Nil find_queues, handle_arguments handle_arguments, in_use? in_use?, internal? : Bool internal?, match?(type, durable, auto_delete, internal, arguments)
match?(frame : AMQP::Frame) match?, name : String name, notify_observers(event : LavinMQ::ExchangeEvent, data : Object | Nil = nil) notify_observers, operator_policy : OperatorPolicy | Nil operator_policy, policy : Policy | Nil policy, publish(msg : Message, immediate : Bool, queues : Set(Queue) = Set(Queue).new, exchanges : Set(Exchange) = Set(Exchange).new) : Int32 publish, publish_in_count : UInt64 publish_in_count, publish_in_count=(publish_in_count : UInt64) publish_in_count=, publish_out_count : UInt64 publish_out_count, publish_out_count=(publish_out_count : UInt64) publish_out_count=, register_observer(observer : LavinMQ::Observer(LavinMQ::ExchangeEvent)) register_observer, stats_details stats_details, to_json(json : JSON::Builder) to_json, type : String type, unbind(destination : Destination, routing_key : String, headers : AMQP::Table | Nil) unbind, unregister_observer(observer : LavinMQ::Observer(LavinMQ::ExchangeEvent)) unregister_observer, unroutable_count : UInt64 unroutable_count, unroutable_count=(unroutable_count : UInt64) unroutable_count=, update_rates : Nil update_rates, vhost : LavinMQ::VHost vhost

Constructor methods inherited from class LavinMQ::Exchange

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

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 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