Skip to content

AMQP event bridge

AMQP Event Bridge

The AMQP protocol and the corresponding brokers are perfectly for PURISTA.

The package @purista/amqpbridge provides an event bridge for the AMQP protocol. This means you can use RabbitMQ as message broker. This is the recommended message broker. Also, Apache ActiveMQ should work.

By using the AMQP event bridge, the system will scale and load balance any task across all instances. It also allows you, to choose a more flexible way of deployment, as you are now able to split your monolith into small pieces.

You can:

  • spin up multiple monolith instances
  • you can split your monolith by services and run multiple service instances (microservice style)
  • you can split even more down to single function and subscription level
  • you are able to connect other systems via the amqp broker


  • allows scaling
  • full subscription support
  • support of durable queues
  • retry mechanism
  • dead letter queues


  • needs managing of an AMQP broker
  • no auto-reconnect


The AMQP event bridge uses the unified configuration schema as all event bridges.

Usage example

The easiest way to start - simply start a RabbitMQ docker container:

docker run --rm -it --hostname my-rabbit -p 15672:15672 -p 5672:5672 rabbitmq:3-management

Add the AMQP bridge to your code:

import { AmqpBridge, AmqpBridgeConfig } from '@purista/amqpbridge'

// create and init our eventbridge

const config:AmqpBridgeConfig = {
    url: 'amqp://'

const eventBridge = new AmqpBridge( config )
await eventBridge.start()

Brokers and tools


PURISTA is using the AMQP header feature to add the OpenTelemetry information to each message, as recommended: