class

LavinMQ::Federation::Upstream::ExchangeLink

Inherits LavinMQ::Federation::Upstream::Link < LavinMQ::SortableJSON < Reference < Object

Constructors

new(upstream : Upstream, federated_ex : AMQP::Exchange, upstream_q : String, upstream_exchange : String)
Source

Instance methods

bound(b : AMQP::BindingDetails)

Called when a binding is added to the federated exchange. no_wait: this runs in the frame-processing fiber, so waiting for the upstream's bind-ok deadlocks two-way or ring federation. Errors close the channel and the reconnect replays all bindings.

Source
delete

Permanently remove the link, including any resources it created on the upstream broker. Use when the federation, federated resource or upstream itself is being deleted.

Source
federated_ex
Source
name
Source
unbound(b : AMQP::BindingDetails)

Called when a binding is removed from the federated exchange

Source
upstream_q
Source