class AvalancheMQ::Shovel::AMQPSource

Defined in:

avalanchemq/shovel/shovel.cr

Constructors

Instance Method Summary

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 ack(delivery_tag, close = false) #

[View source]
def delete_after : AvalancheMQ::Shovel::DeleteAfter #

[View source]
def each(&blk : ::AMQP::Client::DeliverMessage -> Nil) #

[View source]
def last_unacked : UInt64? #

[View source]
def start #

[View source]
def started? : Bool #

[View source]
def stop #

[View source]