Transaction Examples

Atomic operations across queues.

Basic Transaction

await queen.transaction()
  .ack(inputMessage)
  .queue('output')
  .push([{ data: result }])
  .commit()

Multi-stage Pipeline

await queen.queue('stage1').consume(async (msg) => {
  const result = await processStage1(msg.data)
  
  await queen.transaction()
    .ack(msg)
    .queue('stage2')
    .push([{ data: result }])
    .commit()
})

More examples