@mqueue/fastq v0.0.2

fastq for MQueue

An fastq adapter for MQueue, adding support for fastq queues with a multi-backend setup with MQueue.

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

const fastq = new FastqQueue.Outgoing();
const outgoingQueue = new MQueue.Outgoing(fastq);

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

// ...

const incomingQueue = new MQueue.Incoming(new FastqQueue.Incoming(fastq));

Compatibility

• Single-Node NodeJS Applications