@mqueue/queue v0.0.2

mqueue (Multi-Queue)

Simple queue interface with support for multiple backends. Keep your options open.

Installation

Install MQueue and select adapters:

# Install MQueue:
npm install --save @mqueue/queue # + Adapter(s)...
# or use pnpm/yarn

# Install some adapters
npm install --save @mqueue/amqplib
npm install --save @mqueue/azure-service-bus
npm install --save @mqueue/rhea
npm install --save @mqueue/sqs
npm install --save @mqueue/mqtt
npm install --save @mqueue/kafkajs
npm install --save @mqueue/stompjs
npm install --save @mqueue/fastq

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

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

// ...

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

// Example: Switching between AMQP v0.9.1 and SQS for live and production
const isProduction = process.env.NODE_ENV === "production";

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

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

// ...

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

Queue Adapters

• @mqueue/amqplib: AMQP v0.9.1 queue adapter
• @mqueue/sqs: AWS Simple Queue Service (SQS) queue adapter
• @mqueue/rhea: AMQP v1.0 queue adapter
• @mqueue/azure-service-bus: Azure Service Bus queue adapter
• @mqueue/mqtt: MQTT Queue Adapter
• @mqueue/kafkajs: Kafka Queue Adapter
• @mqueue/stompjs: STOMP Queue Adapter

Broadcast Strategies

• @mqueue/multicast: Multi-queue simultaneous publishing/consumption strategy

Compatibility

Why might you need a Message Queue?

• NodeJS v18+, tested on v22+