class LavinMQ::DefaultExchange
- LavinMQ::DefaultExchange
- LavinMQ::Exchange
- Reference
- Object
Defined in:
lavinmq/exchange/default.crInstance Method Summary
- #bind(destination, routing_key, headers = nil)
- #do_exchange_matches(routing_key, headers = nil, & : Exchange -> _)
- #do_queue_matches(routing_key, headers = nil, & : Queue -> _)
- #type : String
- #unbind(destination, routing_key, headers = nil)
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 : Queue, routing_key : String, headers : AMQP::Table | Nil)bind(destination : Exchange, routing_key : String, headers : AMQP::Table | Nil) bind, binding_details(key, destination) binding_details, bindings_details bindings_details, clear_policy clear_policy, current_stats_details current_stats_details, delayed? : Bool delayed?, details_tuple details_tuple, do_exchange_matches(routing_key : String, headers : AMQP::Table | Nil, & : Exchange -> _) do_exchange_matches, do_queue_matches(routing_key : String, headers : AMQP::Table | Nil, & : Queue -> _) do_queue_matches, durable? : Bool durable?, exchange_bindings : Hash({String, AMQ::Protocol::Table?}, Set(LavinMQ::Exchange)) exchange_bindings, exchange_matches(routing_key : String, headers = nil, &blk : Exchange -> _) exchange_matches, 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_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=, queue_bindings : Hash({String, AMQ::Protocol::Table?}, Set(LavinMQ::Queue)) queue_bindings, queue_matches(routing_key : String, headers = nil, &blk : Queue -> _) queue_matches, 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 : Queue, routing_key : String, headers : AMQP::Table | Nil)
unbind(destination : Exchange, 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