class

Amqp::Queue

Inherits Reference < Object

High-level queue wrapper for amqp-client.cr-style migration code. New code can use Channel methods directly.

Constructors

new(channel : Channel, name : String)
Source

Instance methods

bind(exchange : String, routing_key : String = "", no_wait : Bool = false, args arguments : Arguments | NamedTuple = Arguments.new) : self
Source
channel
Source
consumer_count
Source
delete(if_unused : Bool = false, if_empty : Bool = false) : UInt32
Source
get(no_ack : Bool = true) : GetMessage | Nil
Source
message_count
Source
name
Source
publish(body : Bytes, mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new) : UInt64
Source
publish(body : String, mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new) : UInt64
Source
publish(io : IO, bytesize : Int, mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new) : UInt64
Source
publish(body : Bytes, mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, &callback : Bool -> Nil) : UInt64
Source
publish(body : String, mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, &callback : Bool -> Nil) : UInt64
Source
publish(io : IO, bytesize : Int, mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, &callback : Bool -> Nil) : UInt64
Source
publish_confirm(body : Bytes, mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, timeout : Time::Span = 30.seconds) : Bool
Source
publish_confirm(body : String, mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, timeout : Time::Span = 30.seconds) : Bool
Source
publish_confirm(io : IO, bytesize : Int, mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, timeout : Time::Span = 30.seconds) : Bool
Source
purge
Source
subscribe(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
unbind(exchange : String, routing_key : String = "", args arguments : Arguments | NamedTuple = Arguments.new) : self
Source
unsubscribe(consumer_tag : String, no_wait : Bool = true) : self
Source