AMQP::Client::Channel

new(inner : Amqp::Channel)

basic_ack(delivery_tag : UInt64, multiple : Bool = false) : Nil

basic_cancel(consumer_tag : String, no_wait : Bool = false) : Nil

basic_consume(queue : String, tag : String = "", no_ack : Bool = true, exclusive : Bool = false, block : Bool = false, args arguments = Arguments.new, work_pool : Int32 = 1, &callback : DeliverMessage -> Nil) : String

basic_get(queue : String, no_ack : Bool = true) : GetMessage | Nil

basic_nack(delivery_tag : UInt64, multiple : Bool = false, requeue : Bool = true) : Nil

basic_publish(body : Bytes, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties = Properties.new) : UInt64

basic_publish(body : String, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties = Properties.new) : UInt64

basic_publish(io : IO, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties = Properties.new) : UInt64

basic_publish(body : Bytes, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties = Properties.new, &callback : Bool -> Nil) : UInt64

basic_publish(io : IO, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties = Properties.new, &callback : Bool -> Nil) : UInt64

basic_reject(delivery_tag : UInt64, requeue : Bool = true) : Nil

exchange(name : String, type : String, passive : Bool = false, durable : Bool = true, internal : Bool = false, auto_delete : Bool = false, args arguments = Arguments.new) : Exchange

exchange_delete(name : String, if_unused : Bool = false) : Nil

prefetch(count : UInt16, *, global : Bool = false) : Nil

queue(name : String = "", passive : Bool = false, durable : Bool = true, exclusive : Bool = false, auto_delete : Bool = false, args arguments = Arguments.new) : Queue

queue_bind(queue : String, exchange : String, routing_key : String = "", args arguments = Arguments.new, no_wait : Bool = false) : Nil

queue_declare(name : String = "", passive : Bool = false, durable : Bool = false, exclusive : Bool = false, auto_delete : Bool = false, no_wait : Bool = false, args arguments = Arguments.new)

queue_delete(name : String, if_unused : Bool = false, if_empty : Bool = false) : UInt32

wait_for_confirms(timeout : Time::Span = 60.seconds) : Bool