class

LavinMQ::Federation::UpstreamStore

Inherits Enumerable < Reference < Object

Constants

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

Constructors

new(vhost : VHost)
Source

Instance methods

add(upstream : Upstream)
Source
await_pending_deletes(uri : URI, queue : String) : Nil

Waits for deletes in flight of this queue on this broker, so a link never declares resources that a retired link is about to remove

Source
create_upstream(name, config)
Source
create_upstream_set(name, config)
Source
delete_upstream(name)
Source
delete_upstream_set(name)
Source
each

Must yield this collection's elements to the block.

Source
exchange_bound(exchange : AMQP::Exchange, binding : AMQP::BindingDetails)
Source
exchange_unbound(exchange : AMQP::Exchange, binding : AMQP::BindingDetails)
Source
get_set?(name)
Source
reconcile_link(resource : AMQP::Queue | Exchange, upstream_name : String | Nil, set_name : String | Nil)

Make the resource's links match its policy after a policy (re)apply. A link whose upstream the policy still names is kept untouched: that keeps the upstream queue, and its buffered messages, alive. The other links are stopped and their upstream resources removed.

Source
stop_all
Source
stop_link(resource : AMQP::Queue | Exchange)
Source

Nested types