class LavinMQ::Federation::UpstreamStore

Included Modules

Defined in:

lavinmq/federation/upstream_store.cr

Constant Summary

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

Constructors

Instance Method Summary

Constructor Detail

def self.new(vhost : VHost) #

[View source]

Instance Method Detail

def add(upstream : Upstream) #

[View source]
def create_upstream(name, config) #

[View source]
def create_upstream_set(name, config) #

[View source]
def delete_upstream(name) #

[View source]
def delete_upstream_set(name) #

[View source]
def each(&) #
Description copied from module Enumerable(LavinMQ::Federation::Upstream)

Must yield this collection's elements to the block.


[View source]
def get_set(name) #

[View source]
def link(name, resource : Queue | Exchange) #

[View source]
def link_set(name, resource : Exchange | Queue) #

[View source]
def stop_all #

[View source]
def stop_link(resource : Queue | Exchange) #

[View source]