class

LavinMQ::MQTT::Exchange

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

Constructors

new(vhost : VHost, name : String)
Source

Instance methods

bind(destination : MQTT::Session, routing_key : String, arguments = nil) : Bool
Source
bind(destination : LavinMQ::Queue | LavinMQ::Exchange, routing_key : String, arguments = nil) : Bool
Source
binding_count

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

Source
bindings_details

The tree is shared with x-mqtt-topic exchanges, so only MQTT::Session entries are this exchange's own bindings.

Source
handle_arguments
Source
publish(packet : Protocol::Publish, ctx : PublishContext) : UInt32
Source
routes_amqp_messages?

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

Source
type
Source
unbind(destination : MQTT::Session, routing_key, arguments = nil) : Bool
Source
unbind(destination : LavinMQ::Queue | LavinMQ::Exchange, routing_key, arguments = nil) : Bool
Source