Project: Message-driver 0.1.0

Publisher: Message Driver

Scenarios

@bunny Queue isn't found on the broker

When

I execute the following code:

MessageDriver::Broker.dynamic_destination("missing_queue", passive: true)

Then

I expect it to raise a MessageDriver::QueueNotFound error

Given

the following broker configuration:

MessageDriver::Broker.define do |b|
  b.destination :my_queue, "broker_down_queue", arguments: {:'x-expires' => 10000 }
end

When

I execute the following code:

publish(:my_queue, "Test Message 1")

And

the broker goes down

And

I execute the following code:

publish(:my_queue, "Test Message 2")

Then

I expect it to raise a MessageDriver::ConnectionException error

When

the broker comes up

And

I execute the following code:

publish(:my_queue, "Test Message 3")

Then

I expect to have no errors

And

I expect to find 2 messages on :my_queue with:

body

Test Message 1

Test Message 3

Last published about 7 years ago by soupmatt.