class

LavinMQ::AMQP::DirectExchange

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

Instance methods

bind(destination : Destination, routing_key, arguments = nil) : Bool

This macro will find the "bind" method of classes inheriting from this class and redefine them to raise AccessRefused exception if the first argument isn't a type in LavinMQ::AMQP namespace.

TODO remove this when LavinMQ::MQTT::Session no longer inherit from LavinMQ::AMQP::Queue and LavinMQ::MQTT::Exchange no longer inherit from lavinMQ::AMQP::Exchange

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
type
Source
unbind(destination : Destination, routing_key, arguments = nil) : Bool
Source