class

Amqp::Channel

Inherits Reference < Object

Constants

EMPTY_PROPERTIES = Properties.new
Log = ::Log.for("amqp.channel")

Instance methods

ack(delivery_tag : UInt64, multiple : Bool = false) : Nil
Source
basic_ack(delivery_tag : UInt64, multiple : Bool = false) : Nil
Source
basic_cancel(consumer_tag : String, no_wait : Bool = false) : Nil
Source
basic_consume(queue : String, tag : String = "", no_ack : Bool = true, exclusive : Bool = false, block : Bool = false, args arguments : Arguments | NamedTuple = Arguments.new, work_pool : Int32 = 1, &callback : DeliverMessage -> Nil) : String
Source
basic_get(queue : String, no_ack : Bool = true) : GetMessage | Nil
Source
basic_nack(delivery_tag : UInt64, requeue : Bool = false, multiple : Bool = false) : Nil
Source
basic_publish(body : Bytes, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new) : UInt64
Source
basic_publish(body : String, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new) : UInt64
Source
basic_publish(io : IO, bytesize : Int, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new) : UInt64
Source
basic_publish(io : IO, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new) : UInt64
Source
basic_publish(body : Bytes, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, &callback : Bool -> Nil) : UInt64
Source
basic_publish(io : IO, bytesize : Int, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, &callback : Bool -> Nil) : UInt64
Source
basic_publish(io : IO, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, &callback : Bool -> Nil) : UInt64
Source
basic_publish(body : String, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, &callback : Bool -> Nil) : UInt64
Source
basic_publish_confirm(body : Bytes, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, timeout : Time::Span = 30.seconds) : Bool
Source
basic_publish_confirm(body : String, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, timeout : Time::Span = 30.seconds) : Bool
Source
basic_publish_confirm(io : IO, bytesize : Int, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, timeout : Time::Span = 30.seconds) : Bool
Source
basic_publish_confirm(io : IO, exchange : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, timeout : Time::Span = 30.seconds) : Bool
Source
basic_qos(count : UInt16, global : Bool = false) : Nil
Source
basic_recover(requeue : Bool = true) : Nil
Source
basic_reject(delivery_tag : UInt64, requeue : Bool = false) : Nil
Source
cancel(consumer_tag : String, *, no_wait : Bool = false) : Nil
Source
close(*, reply_code : UInt16 = 200_u16, reply_text : String = "OK") : Nil
Source
close_reason
Source
closed?
Source
confirm_select
Source
confirms?
Source
confirms_enabled?
Source
consume(queue : String, consumer_tag : String = "", no_local : Bool = false, no_ack : Bool = false, exclusive : Bool = false, arguments : Amqp::Arguments | NamedTuple = Amqp::Arguments.new, buffer : Int32 = 1024) : Subscription
Source
consume(queue : String, *, consumer_tag : String = "", auto_ack : Bool = false, exclusive : Bool = false, no_local : Bool = false, arguments : Amqp::Arguments | NamedTuple = Amqp::Arguments.new, & : DeliverMessage -> _) : Nil
Source
default_exchange
Source
direct_exchange(name : String = "amq.direct", passive : Bool = true) : Exchange
Source
exchange(name : String, type : String, passive : Bool = false, durable : Bool = true, internal : Bool = false, auto_delete : Bool = false, args arguments : Arguments | NamedTuple = Arguments.new) : Exchange
Source
exchange_bind(destination : String, source : String, routing_key : String = "", arguments : Amqp::Arguments | NamedTuple = Amqp::Arguments.new, *, no_wait : Bool = false) : Nil
Source
exchange_declare(name : String, type : String = "direct", passive : Bool = false, durable : Bool = false, auto_delete : Bool = false, internal : Bool = false, arguments : Amqp::Arguments | NamedTuple = Amqp::Arguments.new) : Nil
Source
exchange_delete(name : String, *, if_unused : Bool = false) : Nil
Source
exchange_unbind(destination : String, source : String, routing_key : String = "", arguments : Amqp::Arguments | NamedTuple = Amqp::Arguments.new, *, no_wait : Bool = false) : Nil
Source
fanout_exchange(name : String = "amq.fanout", passive : Bool = true) : Exchange
Source
flow(active : Bool) : Nil
Source
get(queue : String, *, auto_ack : Bool = false) : GetMessage | Nil
Source
header_exchange(name : String = "amq.headers", passive : Bool = true) : Exchange
Source
nack(delivery_tag : UInt64, multiple : Bool = false, requeue : Bool = true) : Nil
Source
on_cancel
Source
on_close
Source
on_return
Source
open?
Source
prefetch(count : UInt16, *, global : Bool = false) : Nil
Source
prepared_publisher(exchange : String, routing_key : String, *, properties : Properties = Properties.new, mandatory : Bool = false, immediate : Bool = false) : PreparedPublisher
Source
publish(exchange : String, routing_key : String, body : Bytes, properties : Properties = Properties.new, mandatory : Bool = false, immediate : Bool = false) : UInt64 | Nil
Source
publish(message : Message, exchange : String, routing_key : String, *, mandatory : Bool = false, immediate : Bool = false) : UInt64 | Nil
Source
publish_async(message : Message, exchange : String, routing_key : String, *, mandatory : Bool = false) : Tuple(UInt64, ::Channel(ConfirmOutcome))
Source
publish_async(body : Bytes, exchange : String, routing_key : String, *, properties : Properties = Properties.new, mandatory : Bool = false) : Tuple(UInt64, ::Channel(ConfirmOutcome))
Source
publish_batch(messages : Array(Message), exchange : String, routing_key : String, *, mandatory : Bool = false, immediate : Bool = false) : Array(UInt64 | Nil)
Source
publish_batch(bodies : Array(Bytes), exchange : String, routing_key : String, *, properties : Properties = Properties.new, mandatory : Bool = false, immediate : Bool = false) : Array(UInt64 | Nil)
Source
publish_confirm(message : Message, exchange : String, routing_key : String, *, mandatory : Bool = false, timeout : Time::Span = 30.seconds) : Bool
Source
publish_confirm(body : Bytes, exchange : String, routing_key : String, *, properties : Properties = Properties.new, mandatory : Bool = false, timeout : Time::Span = 30.seconds) : Bool
Source
publish_confirm_batch(messages : Array(Message), exchange : String, routing_key : String, *, window_size : Int32 = 500, mandatory : Bool = false, immediate : Bool = false, timeout : Time::Span = 30.seconds) : Bool
Source
publish_confirm_batch(bodies : Array(Bytes), exchange : String, routing_key : String, *, properties : Properties = Properties.new, window_size : Int32 = 500, mandatory : Bool = false, immediate : Bool = false, timeout : Time::Span = 30.seconds) : Bool
Source
qos(prefetch_count : UInt16, global : Bool = false, prefetch_size : UInt32 = 0_u32) : Nil
Source
queue(name : String, passive : Bool = false, durable : Bool = true, exclusive : Bool = false, auto_delete : Bool = false, args arguments : Arguments | NamedTuple = Arguments.new) : Queue
Source
queue
Source
queue_bind(queue : String, exchange : String, routing_key : String = "", arguments : Amqp::Arguments | NamedTuple = Amqp::Arguments.new, *, no_wait : Bool = false) : Nil
Source
queue_declare(name : String = "", passive : Bool = false, durable : Bool = false, exclusive : Bool = false, auto_delete : Bool = false, arguments : Amqp::Arguments | NamedTuple = Amqp::Arguments.new, *, no_wait : Bool = false) : QueueInfo
Source
queue_delete(name : String, if_unused : Bool = false, if_empty : Bool = false) : UInt32
Source
queue_purge(name : String) : UInt32
Source
queue_unbind(queue : String, exchange : String, routing_key : String = "", arguments : Amqp::Arguments | NamedTuple = Amqp::Arguments.new) : Nil
Source
reject(delivery_tag : UInt64, requeue : Bool = true) : Nil
Source
subscribe(queue : String, *, consumer_tag : String = "", auto_ack : Bool = false, exclusive : Bool = false, no_local : Bool = false, arguments : Amqp::Arguments | NamedTuple = Amqp::Arguments.new, buffer : Int32 = 16) : Subscription
Source
topic_exchange(name : String = "amq.topic", passive : Bool = true) : Exchange
Source
transaction
Source
tx_commit
Source
tx_rollback
Source
tx_select
Source
wait_for_confirms(timeout : Time::Span = 60.seconds) : Bool

Block until every publish issued so far in this channel has been settled by the broker. Returns true if all were acked, false if any was nacked or the timeout expired. Raises if the channel is closed while waiting.

Source

Nested types