@mqueue/azure-service-bus

Azure Service Bus for MQueue

An Azure Service Bus adapter for MQueue, adding support for Azure Service Bus queues with a multi-backend setup with MQueue. Note: Azure Service Bus is also compatible with AMQP v1.0 and thus compatible with the Rhea MQueue adapter (which it uses under-the-hood), however, you may achieve a better experience (particularly with Azure authentication and identity) by using the specialised adapter.

npm install --save @mqueue/queue @mqueue/azure-service-bus
# or use pnpm/yarn

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

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

// ...

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

License

MIT © Dom Webber