class LavinMQ::Shovel::AMQPSource

• LavinMQ::Shovel::AMQPSource
• Reference
• Object

Defined in:

Constructors

• .new(name : String, uris : Array(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, batch_ack_timeout : Time::Span = DEFAULT_BATCH_ACK_TIMEOUT)

Instance Method Summary

• #ack(delivery_tag, batch = true)
• #delete_after : LavinMQ::Shovel::DeleteAfter
• #each(&blk : ::AMQP::Client::DeliverMessage -> Nil)
• #last_unacked : UInt64?
• #start
• #started? : Bool
• #stop

Constructor Detail

Instance Method Detail