class AMQP::Client::Exchange

Overview

High-level Exchange object

Defined in:

amqp-client/exchange.cr

Instance Method Summary

Instance Method Detail

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

Bind the exchange to another exchange


[View source]
def delete(if_unused = false) #

Delete the exchange


[View source]
def name : String #

Name of the exchange


[View source]
def publish(message, routing_key : String, mandatory = false, immediate = false, props properties = Properties.new) #

Publish a message to the exchange


[View source]
def publish_confirm(message, routing_key : String, mandatory = false, immediate = false, props properties = Properties.new) #

Publish and confirm a message to the exchange


[View source]
def unbind(exchange : String, routing_key : String, no_wait = false, args arguments = Arguments.new) #

Unbind the exchange from another exchange


[View source]