@mqueue/rhea v0.0.2

rhea for MQueue

An rhea adapter (AMQP v1.0) for MQueue, adding support for rhea queues with a multi-backend setup with MQueue.

npm install --save @mqueue/queue @mqueue/rhea
# or use pnpm/yarn

const outgoingQueue = new MQueue.Outgoing(
  await RheaQueue.Outgoing.connect("amqp://rabbitmq:5271", "queue-name"),
);

outgoingQueue.sendMessage({
  headers: {
    "Account-ID": "123",
  },
  body: "...",
});

// ...

const incomingQueue = new MQueue.Incoming(
  await RheaQueue.Incoming.connect("amqp://rabbitmq:5271", "queue-name"),
);

Compatibility

• RabbitMQ v4 and later
• RabbitMQ v3 and earler, with the AMQP v1.0 plugin
• Apache ActiveMQ
• Azure Service Bus - Note: identity and authentication is easier with the dedicated Azure Service Bus queue adapter