class LavinMQ::Federation::UpstreamStore
- LavinMQ::Federation::UpstreamStore
- Reference
- Object
Included Modules
- Enumerable(LavinMQ::Federation::Upstream)
Defined in:
lavinmq/federation/upstream_store.crConstant Summary
-
Log =
::Log.for("federation.upstream_store")
Constructors
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
def each(&)
#
Description copied from module Enumerable(LavinMQ::Federation::Upstream)
Must yield this collection's elements to the block.