class AvalancheMQ::Shovel::AMQPDestination

Defined in:

avalanchemq/shovel/shovel.cr

Constructors

Instance Method Summary

Instance methods inherited from class AvalancheMQ::Shovel::Destination

push(msg, source) push, start start, started? : Bool started?, stop stop

Constructor Detail

def self.new(name : String, uri : URI, queue : String | Nil, exchange : String | Nil = nil, exchange_key : String | Nil = nil, delete_after : AvalancheMQ::Shovel::DeleteAfter = DEFAULT_DELETE_AFTER, prefetch : UInt16 = DEFAULT_PREFETCH, ack_mode : AvalancheMQ::Shovel::AckMode = DEFAULT_ACK_MODE) #

[View source]

Instance Method Detail

def push(msg, source) #

[View source]
def start #

[View source]
def started? : Bool #

[View source]
def stop #

[View source]