class LavinMQ::Shovel::AMQPDestination

Defined in:

lavinmq/shovel/shovel.cr

Constructors

Instance Method Summary

Instance methods inherited from class LavinMQ::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 : LavinMQ::Shovel::DeleteAfter = DEFAULT_DELETE_AFTER, prefetch : UInt16 = DEFAULT_PREFETCH, ack_mode : LavinMQ::Shovel::AckMode = DEFAULT_ACK_MODE, consumer_args : Hash(String, JSON::Any) | Nil = nil, direct_user : User | Nil = nil) #

[View source]

Instance Method Detail

def push(msg, source) #

[View source]
def start #

[View source]
def started? : Bool #

[View source]
def stop #

[View source]