class LavinMQ::Federation::Upstream::QueueLink

Included Modules

Defined in:

lavinmq/federation/link.cr

Constant Summary

EXCHANGE = ""

Constructors

Instance Method Summary

Instance methods inherited from module LavinMQ::Observer(LavinMQ::QueueEvent)

on(event : EventT, data : Object | Nil) on

Instance methods inherited from class LavinMQ::Federation::Upstream::Link

details_tuple details_tuple, error : String? error, last_changed : Int64? last_changed, name : String name, run run, search_match?(value : String) : Bool
search_match?(value : Regex) : Bool search_match?, state : LavinMQ::Federation::Upstream::Link::State state, terminate terminate

Constructor methods inherited from class LavinMQ::Federation::Upstream::Link

new(upstream : Upstream) new

Instance methods inherited from module LavinMQ::SortableJSON

details_tuple details_tuple, search_match?(value : String)
search_match?(value : Regex) search_match?, to_json(json : JSON::Builder) to_json

Constructor Detail

def self.new(upstream : Upstream, federated_q : Queue, upstream_q : String) #

[View source]

Instance Method Detail

def name : String #

[View source]
def on(event : QueueEvent, data) #

[View source]
def terminate #
Description copied from class LavinMQ::Federation::Upstream::Link

Does not trigger reconnect, but a graceful close


[View source]