class AMQP::Client::Exchange
- AMQP::Client::Exchange
- Reference
- Object
Overview
High-level Exchange object
Defined in:
amqp-client/exchange.crInstance Method Summary
-
#bind(exchange : String, routing_key : String, no_wait = false, args arguments = Arguments.new)
Bind the exchange to another 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_confirm(message, routing_key : String, mandatory = false, immediate = false, props properties = Properties.new)
Publish and confirm a message to the exchange
-
#unbind(exchange : String, routing_key : String, no_wait = false, args arguments = Arguments.new)
Unbind the exchange from another exchange
Instance Method Detail
def bind(exchange : String, routing_key : String, no_wait = false, args arguments = Arguments.new)
#
Bind the exchange to another exchange
def publish(message, routing_key : String, mandatory = false, immediate = false, props properties = Properties.new)
#
Publish a message to the exchange
def publish_confirm(message, routing_key : String, mandatory = false, immediate = false, props properties = Properties.new)
#
Publish and confirm a message to the exchange
def unbind(exchange : String, routing_key : String, no_wait = false, args arguments = Arguments.new)
#
Unbind the exchange from another exchange