class AMQP::Client::Exchange

• AMQP::Client::Exchange
• Reference
• Object

Overview

High-level Exchange object

Defined in:

amqp-client/exchange.cr

Instance Method Summary

• #bind(exchange : String, routing_key : String, no_wait = false, args arguments : NamedTuple = NamedTuple.new)
• #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

• #delete(if_unused = false)

  Delete the exchange

• #name : String

  Name of the exchange

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

  Publish a message to the exchange

• #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

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

  Publish and confirm a message to the exchange

• #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

• #unbind(exchange : String, routing_key : String, no_wait = false, args arguments : NamedTuple = NamedTuple.new)
• #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

Instance Method Detail