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.

``bash
npm install --save @mqueue/queue @mqueue/sqs


or use pnpm/yarn


`

`ts
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