class AMQP::Client::Queue

• AMQP::Client::Queue
• Reference
• Object

Defined in:

amqp-client/queue.cr

Constructors

• .new(channel : Channel, name : String)

Instance Method Summary

• #bind(exchange : String, routing_key : String, no_wait = false, args = Arguments.new)
• #consumer_count
• #delete(if_unused = false, if_empty = false)
• #get(no_ack = true)
• #message_count
• #name : String
• #publish(io : IO, bytesize : Int, mandatory = false, immediate = false, props = Properties.new)
• #publish(message, mandatory = false, immediate = false, props = Properties.new)
• #publish_confirm(io : IO, bytesize : Int, mandatory = false, immediate = false, props = Properties.new)
• #publish_confirm(message, mandatory = false, immediate = false, props = Properties.new)
• #purge
• #subscribe(tag = "", no_ack = true, exclusive = false, block = false, args = Arguments.new, work_pool = 1, &blk : DeliverMessage -> Nil)
• #unbind(exchange : String, routing_key : String, args = Arguments.new)
• #unsubscribe(consumer_tag)

Constructor Detail

Instance Method Detail