Logo: Relish

  1. Sign up
  2. Sign in

Project: Message-driver 0.7

Connecting to Multiple Brokers

Background
Given
I am connected to a broker named :my_broker
Scenarios
  • @all_adapters
Declaring Destinations and Publishing on a secondary broker
Given
I configure my broker as follows
MessageDriver::Broker.define(:my_broker) do |b|
  b.destination(:multi_broker_destination, "multi.broker.queue")
end
And
I have no messages on :multi_broker_destination
When
I execute the following code
MessageDriver::Client[:my_broker].publish(:multi_broker_destination, "Test Message")
Then
I expect to find the following message on :multi_broker_destination
body
Test Message
  • @bunny
  • @in_memory
Declaring Consumers and Subscriptions on a secondary broker
Given
I have a destination :dest_queue with no messages on it
And
I have a destination :source_queue with no messages on it
And
I have a message consumer
MessageDriver::Client[:my_broker].consumer(:my_consumer) do |message|
  MessageDriver::Client[:my_broker].publish(:dest_queue, message.body)
end
And
I create a subscription
MessageDriver::Client[:my_broker].subscribe(:source_queue, :my_consumer)
When
I send the following messages to :source_queue
body
Test Message 1
Test Message 2
And
I let the subscription process
Then
I expect to find no messages on :source_queue
And
I expect to find the following 2 messages on :dest_queue
body
Test Message 1
Test Message 2

Last published 10 months ago by soupmatt.