Logo: Relish

  1. Sign in

Project: Message-driver 0.7

Declaring AMQP exchanges

  • @bunny
  • @read_queues_directly

If you want to create an exchange that doesn't exist on the broker, you can do so by adding
the "declare" option to your destination.

Background
Given
I am connected to the broker
Scenarios
Declaring a direct exchange
When
I execute the following code
MessageDriver::Broker.define do |b|
  b.destination :my_exchange, "my_exchange", type: :exchange, declare: {type: :direct, auto_delete: true}
  b.destination :exchange_bound_queue, "", exclusive: true, bindings: [{source: "my_exchange", routing_key: "exchange_bound_queue"}]
end

publish(:my_exchange, "Test My New Exchange", routing_key: "exchange_bound_queue")
Then
I expect to find the following message on :exchange_bound_queue
body
Test My New Exchange

Last published over 3 years ago by soupmatt.