class

AMQP::Client::Queue

Inherits Reference < Object

Constructors

new(channel : Channel, name : String)
Source

Instance methods

bind(exchange : String, routing_key : String = "", no_wait : Bool = false, args arguments = Arguments.new) : self
Source
channel
Source
delete(if_unused : Bool = false, if_empty : Bool = false) : UInt32
Source
get(no_ack : Bool = true) : GetMessage | Nil
Source
name
Source
purge
Source
subscribe(tag : String = "", no_ack : Bool = true, exclusive : Bool = false, block : Bool = false, args arguments = Arguments.new, work_pool : Int32 = 1, &callback : DeliverMessage -> Nil) : String
Source
unsubscribe(consumer_tag : String, no_wait : Bool = true) : self
Source