class LavinMQ::Shovel::Runner

Included Modules

Defined in:

lavinmq/shovel/shovel.cr

Constant Summary

MAX_DELAY = 300
RETRY_THRESHOLD = 10

Constructors

Instance Method Summary

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(source : AMQPSource, destination : Destination, name : String, vhost : VHost, reconnect_delay : Time::Span = DEFAULT_RECONNECT_DELAY) #

[View source]

Instance Method Detail

def delete #

[View source]
def delete_paused_file #

[View source]
def details_tuple #

[View source]
def exponential_reconnect_delay #

[View source]
def name : String #

[View source]
def pause #

[View source]
def paused? #

[View source]
def resume #

[View source]
def run #

[View source]
def running? #

[View source]
def should_stop_loop? #

[View source]
def state : LavinMQ::Shovel::State #

[View source]
def terminate #

Does not trigger reconnect, but a graceful close


[View source]
def terminated? #

[View source]
def vhost : LavinMQ::VHost #

[View source]