class

LavinMQ::AMQP::ConsistentHashExchange

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

Constructors

new(*args, **kwargs)

Source

Instance methods

bind(destination : Destination, routing_key : String, arguments : AMQP::Table | 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

each_destination(routing_key : String, headers : AMQP::Table | Nil, & : LavinMQ::Queue | LavinMQ::Exchange -> )

Source

type

Source

unbind(destination : Destination, routing_key : String, arguments : AMQP::Table | Nil)

Source