class

LavinMQ::Federation::Upstream

Inherits Reference < Object

Constructors

new(vhost : VHost, name : String, raw_uri : String, exchange : Nil | String = nil, queue : Nil | String = nil, ack_mode : LavinMQ::Federation::AckMode = DEFAULT_ACK_MODE, expires : Int64 | Nil = DEFAULT_EXPIRES, max_hops : Int64 = DEFAULT_MAX_HOPS, msg_ttl : Int64 | Nil = DEFAULT_MSG_TTL, prefetch : UInt16 = DEFAULT_PREFETCH, reconnect_delay : Time::Span = DEFAULT_RECONNECT_DELAY, consumer_tag = nil)

Instance methods

ack_mode

ack_mode=(ack_mode : LavinMQ::Federation::AckMode)

close

Stop all links without touching upstream resources. Use on broker shutdown.

consumer_tag

delete

Stop all links and remove the resources they created on the upstream broker. Use when the upstream is being explicitly deleted.

dup

Copy the upstream's configuration but give the copy its own, empty link tables. Used by upstream sets that override settings per entry; a plain shallow dup would share @q_links/@ex_links with the original.

exchange

exchange=(exchange : Nil | String)

exchange_bound(federated_exchange : AMQP::Exchange, binding : AMQP::BindingDetails)

exchange_unbound(federated_exchange : AMQP::Exchange, binding : AMQP::BindingDetails)

expires

expires=(expires : Int64 | Nil)

link(federated_exchange : AMQP::Exchange) : ExchangeLink

declare queue on upstream consume queue and publish to downstream exchange declare upstream exchange (passive) declare x-federation-upstream exchange on upstream bind x-federation-upstream exchange to queue get bindings for downstream exchange add bindings from upstream exchange to x-federation-upstream exchange keep downstream exchange bindings reflected on x-federation-upstream exchange

link(federated_q : AMQP::Queue) : QueueLink

When federated_q has a consumer the connections are estabished. If all consumers disconnect, the connections are closed. When the policy or the upstream is removed the link is also removed.

links

log

max_hops

max_hops=(max_hops : Int64)

msg_ttl

msg_ttl=(msg_ttl : Int64 | Nil)

name

prefetch

prefetch=(prefetch : UInt16)

queue

queue=(queue : Nil | String)

reconnect_delay

reconnect_delay=(reconnect_delay : Time::Span)

stop_link(federated_exchange : AMQP::Exchange)

delete x-federation-upstream exchange on upstream delete queue on upstream

stop_link(federated_q : AMQP::Queue)

take_links

Removes all links from this upstream without stopping them

type

unlink(federated_exchange : AMQP::Exchange) : ExchangeLink | Nil

Removes the link from this upstream without stopping it. Links are keyed by name, so only a link that belongs to this very resource is removed, not one of a replacement declared under the same name

unlink(federated_q : AMQP::Queue) : QueueLink | Nil

upstream_exchange_name(federated_exchange : AMQP::Exchange) : String

upstream_queue_name(federated_exchange : AMQP::Exchange) : String

Names the resources an ExchangeLink creates on the upstream broker

uri

uri=(uri : URI)

vhost

Nested types