Project: Message-driver 0.3.0

Publisher: Message Driver

Scenarios

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

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 over 5 years ago by soupmatt.