@mqueue/sqs v0.0.2

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

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

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

// ...

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

Compatibility

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