The Outbox Pattern in Node.js.

In Simple Words: Write business state mutations and domain event payloads into an outbox database table within the same atomic database transaction. A separate background worker tails the outbox table and publishes events to RabbitMQ or Kafka.

await prisma.$transaction(async (tx) => {
  const order = await tx.order.create({ data: { userId, amount } });
  await tx.outbox.create({
    data: {
      eventType: 'ORDER_PLACED',
      payload: JSON.stringify(order)
    }
  });
});