class

AMQP::Client::Exchange

Inherits Reference < Object

High-level Exchange object

Instance methods

bind(exchange : String, routing_key : String, no_wait = false, args arguments : NamedTuple = NamedTuple.new)
Source
bind(exchange : String, routing_key : String, no_wait = false, args arguments = Arguments.new)

Bind the exchange to another exchange self is the destination exchange and the argument is the source exchange

Source
delete(if_unused = false)

Delete the exchange

Source
name

Name of the exchange

Source
publish(message, routing_key : String, mandatory = false, immediate = false, props properties = Properties.new)

Publish a message to the exchange

Source
publish(message, routing_key : String, mandatory = false, immediate = false, props properties = Properties.new, &blk)

Publish a message to the exchange, block is called when message is confirmed

Source
publish_confirm(message, routing_key : String, mandatory = false, immediate = false, props properties = Properties.new)

Publish and confirm a message to the exchange

Source
publish_confirm(message, routing_key : String, mandatory = false, immediate = false, props properties = Properties.new, &blk)

Publish and confirm a message to the exchange, block is called when message is confirmed

Source
unbind(exchange : String, routing_key : String, no_wait = false, args arguments : NamedTuple = NamedTuple.new)
Source
unbind(exchange : String, routing_key : String, no_wait = false, args arguments = Arguments.new)

Unbind the exchange from another exchange self is the destination exchange and the argument is the source exchange

Source