class LavinMQ::Federation::UpstreamStore

• LavinMQ::Federation::UpstreamStore
• Reference
• Object

Included Modules

• Enumerable(LavinMQ::Federation::Upstream)

Defined in:

lavinmq/federation/upstream_store.cr

Constant Summary

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

Constructors

• .new(vhost : VHost)

Instance Method Summary

• #add(upstream : Upstream)
• #create_upstream(name, config)
• #create_upstream_set(name, config)
• #delete_upstream(name)
• #delete_upstream_set(name)
• #each(&)

  Must yield this collection's elements to the block.

• #get_set(name)
• #link(name, resource : Queue | Exchange)
• #link_set(name, resource : Exchange | Queue)
• #stop_all
• #stop_link(resource : Queue | Exchange)

Constructor Detail

Instance Method Detail