class

LavinMQ::Federation::Upstream::Link

Inherits LavinMQ::SortableJSON < Reference < Object

Constants

Log = LavinMQ::Log.for("federation.link")

Constructors

new(upstream : Upstream)
Source

Instance methods

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
details_tuple
Source
error
Source
last_changed
Source
name
Source
search_match?(value : String) : Bool
Source
search_match?(value : Regex) : Bool
Source
state
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

Nested types