Azure Service Bus for MQueue

An AWS SQS adapter for MQueue, adding support for AWS Simple Queue Service queues with a multi-backend setup with MQueue. Note: SQS Incoming queue consumption uses sqs-consumer.

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

import MQueue from "@mqueue/queue"; // or require("@mqueue/queue")
import { SQSQueue } from "@mqueue/fastq"; // or require("@mqueue/fastq");

const outgoingQueue = new MQueue.Outgoing(
  await SQSQueue.Outgoing.connect("/queue1", {
    credentials: { accessKeyId: "x", secretAccessKey: "x" },
    region: "elasticmq", // or applicable AWS region for SQS
    endpoint: "http://elasticmq:9324",
  }),
);

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

// ...

const incomingQueue = new MQueue.Incoming(
  await SQSQueue.Incoming.connect("/queue1", {
    credentials: { accessKeyId: "x", secretAccessKey: "x" },
    region: "elasticmq", // or applicable AWS region for SQS
    endpoint: "http://elasticmq:9324",
  }),
);

// Start listening to the queue
await incomingQueue.consume(async (payload) => {
  const topicOrQueueName = payload.transport.name;
  const headers = payload.message.headers;
  const data = await payload.message.json();
  await payload.accept(); // or await payload.reject();
  // ...
});

Compatibility

• AWS Simple Queue Service (SQS)
• ElasticMQ (SQS-Compatible)

License

MIT © Dom Webber