class

Amqp::Exchange

Inherits Reference < Object

High-level exchange 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
delete(if_unused : Bool = false) : Nil
Source
name
Source
publish(body : Bytes, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new) : UInt64
Source
publish(body : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new) : UInt64
Source
publish(body : Bytes, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, &callback : Bool -> Nil) : UInt64
Source
publish(body : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, &callback : Bool -> Nil) : UInt64
Source
publish_confirm(body : Bytes, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, timeout : Time::Span = 30.seconds) : Bool
Source
publish_confirm(body : String, routing_key : String = "", mandatory : Bool = false, immediate : Bool = false, props properties : Properties = Properties.new, timeout : Time::Span = 30.seconds) : Bool
Source
unbind(exchange : String, routing_key : String = "", no_wait : Bool = false, args arguments : Arguments | NamedTuple = Arguments.new) : self
Source