class LavinMQ::DefaultExchange
- LavinMQ::DefaultExchange
- LavinMQ::Exchange
- Reference
- Object
Defined in:
lavinmq/exchange/default.crInstance Method Summary
- #bind(destination, routing_key, headers = nil)
- #bindings_details : Iterator(BindingDetails)
- #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 : 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