class AMQP::Client::Channel

• AMQP::Client::Channel
• Reference
• Object

Defined in:

Constant Summary

LOG = AMQP::Client::Connection::LOG.for(self)

Constructors

• .new(connection : Connection, id : UInt16)

Instance Method Summary

• #basic_ack(delivery_tag : UInt64, multiple = false) : Nil
• #basic_cancel(consumer_tag) : Nil
• #basic_consume(queue, tag = "", no_ack = true, exclusive = false, block = false, args = Arguments.new, work_pool = 1, &blk : DeliverMessage -> Nil)
• #basic_get(queue : String, no_ack : Bool) : GetMessage | Nil
• #basic_nack(delivery_tag : UInt64, requeue = false, multiple = false) : Nil
• #basic_publish(bytes : Bytes, exchange, routing_key = "", mandatory = false, immediate = false, props = Properties.new)
• #basic_publish(str : String, exchange, routing_key = "", mandatory = false, immediate = false, props = Properties.new)
• #basic_publish(io : IO::Memory | IO::FileDescriptor, exchange, routing_key = "", mandatory = false, immediate = false, props = Properties.new)
• #basic_publish(body : IO | Bytes, bytesize : Int, exchange : String, routing_key = "", mandatory = false, immediate = false, props = Properties.new) : UInt64
• #basic_publish_confirm(io : IO, bytesize : Int, exchange : String, routing_key = "", mandatory = false, immediate = false, props = Properties.new) : Bool
• #basic_publish_confirm(msg, exchange, routing_key = "", mandatory = false, immediate = false, props = Properties.new) : Bool
• #basic_qos(count, global = false) : Nil
• #basic_recover(requeue) : Nil
• #basic_reject(delivery_tag : UInt64, requeue = false) : Nil
• #cleanup
• #close(frame : Frame::Channel::Close) : Nil
• #close : Nil
• #closed? : Bool
• #confirm_select(no_wait = false) : Nil
• #default_exchange
• #direct_exchange(name = "amq.direct", passive = true)
• #exchange(name, type, passive = false, durable = true, exclusive = false, internal = false, auto_delete = false, args = Arguments.new)
• #exchange_bind(source : String, destination : String, routing_key : String, no_wait = false, args = Arguments.new) : Nil
• #exchange_declare(name : String, type : String, passive = false, durable = true, exclusive = false, internal = false, auto_delete = false, no_wait = false, args = Arguments.new) : Nil
• #exchange_delete(name, if_unused = false, no_wait = false) : Nil
• #exchange_unbind(source : String, destination : String, routing_key : String, no_wait = false, args = Arguments.new) : Nil
• #fanout_exchange(name = "amq.fanout", passive = true)
• #flow(active : Bool)
• #has_subscriber?(consumer_tag)
• #header_exchange(name = "amq.header", passive = true)
• #id : UInt16
• #incoming(frame)
• #inspect(io : IO) : Nil

  Appends a String representation of this object which includes its class name, its object address and the values of all instance variables.

• #on_cancel(&blk : String -> Nil)
• #on_close(&blk : UInt16, String -> )
• #on_confirm(msgid, &blk : Bool -> Nil)
• #on_return(&blk : ReturnedMessage -> Nil)
• #open
• #prefetch(count, global = false) : Nil
• #queue(name : String, passive = false, durable = true, exclusive = false, auto_delete = false, args = Arguments.new)

  Declares a queue with a name, by default durable and not auto-deleted

• #queue

  Declares a temporary queue, which won't be durable and auto-deleted when not used anymore

• #queue_bind(queue : String, exchange : String, routing_key : String, no_wait = false, args = Arguments.new) : Nil
• #queue_declare(name : String, passive = false, durable = true, exclusive = false, auto_delete = false, args = Arguments.new)
• #queue_delete(name : String, if_unused = false, if_empty = false)
• #queue_purge(name : String)
• #queue_unbind(queue : String, exchange : String, routing_key : String, args = Arguments.new) : Nil
• #topic_exchange(name = "amq.topic", passive = true)
• #wait_for_confirm(msgid) : Bool

  Block until confirmed

Macro Summary

• expect(clz)

Constructor Detail

Instance Method Detail

class Person
  def initialize(@name : String, @age : Int32)
  end
end

Person.new("John", 32).inspect # => #<Person:0x10fd31f20 @name="John", @age=32>

Macro Detail