Project: Message-driver 0.4.0

Publisher: Message Driver

Message Consumers

@bunny

These consumers will wrap the acknowledgement of the consumed message
as well as any publishes in a native broker transaction.

Background

Given: I am connected to the broker
And: I have a destination :dest_queue with no messages on it
And: I have a destination :source_queue with no messages on it

Scenarios

Consuming Messages within a transaction
When an error occurs
When a DontRequeue error occurs

Consuming Messages within a transaction

Given

I have a message consumer

MessageDriver::Client.consumer(:my_consumer) do |message|
  MessageDriver::Client.publish(:dest_queue, message.body)
end

And

I create a subscription

MessageDriver::Client.subscribe(:source_queue, :my_consumer, ack: :transactional)

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

@no_ci When an error occurs

Given

I have a message consumer

MessageDriver::Client.consumer(:my_consumer) do |message|
  MessageDriver::Client.publish(:dest_queue, message.body)
  raise "oh nos!"
end

And

I create a subscription

MessageDriver::Client.subscribe(:source_queue, :my_consumer, ack: :transactional)

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 the following 2 messages on :source_queue

body

Test Message 1

Test Message 2

And

I expect to find no messages on :dest_queue

When a DontRequeue error occurs

Given

I have a message consumer

MessageDriver::Client.consumer(:my_consumer) do |message|
  MessageDriver::Client.publish(:dest_queue, message.body)
  raise MessageDriver::DontRequeueError, "don't requeue me"
end

And

I create a subscription

MessageDriver::Client.subscribe(:source_queue, :my_consumer, ack: :transactional)

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 no messages on :dest_queue

Last published over 7 years ago by soupmatt.

Message Consumers

Message-driver settings