class

LavinMQ::Federation::Upstream::QueueLink

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

Constants

EXCHANGE = ""

Constructors

new(upstream : Upstream, federated_q : AMQP::Queue, upstream_q : String)

Source

Instance methods

federated_q

Source

monitor_consumers

Source

name

Source

stop

Graceful close of the link without removing any upstream resources. Use on broker shutdown — the upstream queue/exchange must survive a restart so buffered messages aren't lost.

Source