Project: Message-driver 0.1.0

Publisher: Message Driver

Publishing a Message within a Transaction

@bunny

Given

the following broker configuration:

MessageDriver::Broker.define do |b|
  b.destination :my_queue, "my_queue", exclusive: true
end

Scenarios

The block completes successfully

When

I execute the following code:

with_message_transaction do
  publish(:my_queue, "Transacted Message 1")
  publish(:my_queue, "Transacted Message 2")
end

Then

I expect to find 2 messages on :my_queue with:

body

Transacted Message 1

Transacted Message 2

An error is raised inside the block

When

I execute the following code:

with_message_transaction do
  publish(:my_queue, "Transacted Message 1")
  raise "an error that causes a rollback"
  publish(:my_queue, "Transacted Message 2")
end

Then

I expect it to raise "an error that causes a rollback"

And

I expect to find no messages on :my_queue

Last published over 4 years ago by soupmatt.

Publishing a Message within a Transaction

Message-driver settings