class

LavinMQ::AMQP::Exchange

Inherits LavinMQ::SortableJSON < LavinMQ::Stats < LavinMQ::PolicyTarget < LavinMQ::Exchange < LavinMQ::SortableJSON < Reference < Object

Constants

REPUBLISH_HEADERS = {"x-head", "x-tail", "x-from"}

Constructors

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

Instance methods

alternate_exchange
Source
arguments
Source
auto_delete?
Source
bind(destination : AMQP::Destination, routing_key : String, arguments : AMQP::Table | Nil)
Source
bind(destination : LavinMQ::Queue | LavinMQ::Exchange, routing_key, arguments = nil) : Bool
Source
binding_count

Number of bindings on this exchange. Counted cheaply, without allocating the full bindings_details array.

Source
bindings_details

No return-type restriction: AMQP exchanges return Array(AMQP::BindingDetails) while MQTT::Exchange overrides this to return Array(MQTT::SubscriptionDetails).

Source
close
Source
current_stats_details

Like stats_details but without log

Source
dedup_count
Source
delayed?
Source
details_tuple
Source
durable?
Source
each_destination(routing_key : String, headers : AMQP::Table | Nil, & : LavinMQ::Queue | LavinMQ::Exchange -> )
Source
find_queues(routing_key : String, headers : AMQP::Table | Nil, queues : Set(AMQP::Queue) = Set(AMQP::Queue).new, exchanges : Set(AMQP::Exchange) = Set(AMQP::Exchange).new) : Nil
Source
handle_arguments
Source
in_use?
Source
internal?
Source
match?(type, durable, auto_delete, internal, arguments)
Source
match?(frame : AMQP::Frame)
Source
name
Source
publish(msg : Message, immediate : Bool, queues : Set(AMQP::Queue) = Set(AMQP::Queue).new, exchanges : Set(AMQP::Exchange) = Set(AMQP::Exchange).new) : PublishResult
Source
publish_in_count
Source
publish_out_count
Source
route_msg(msg : Message, queues : Set(AMQP::Queue), exchanges : Set(AMQP::Exchange)) : PublishResult
Source
route_msg(msg : Message) : PublishResult
Source
routes_amqp_messages?

Whether messages routed in from AMQP, e.g. dead-lettered, reach destinations. MQTT exchanges only route MQTT publishes.

Source
stats_details
Source
to_json(json : JSON::Builder)
Source
type
Source
unbind(destination : AMQP::Destination, routing_key : String, arguments : AMQP::Table | Nil)
Source
unbind(destination : LavinMQ::Queue | LavinMQ::Exchange, routing_key, arguments = nil) : Bool
Source
unroutable_count
Source
update_rates
Source
vhost
Source

Nested types