Dead-end/testing MQueue adapter
A queue adapter for
MQueue
that goes nowhere - primarily intended for internal and testing purposes.
``bash`
npm install --save @mqueue/queue @mqueue/nullor use pnpm/yarn
`ts
import MQueue from "@mqueue/queue"; // or require("@mqueue/queue");
import { NullQueue } from "@mqueue/null"; // or require("@mqueue/null");
const outgoingQueue = new MQueue.Outgoing(new NullQueue.Outgoing());
outgoingQueue.sendMessage({
headers: {
"Account-ID": "123",
},
body: "...",
});
// ...
const incomingQueue = new MQueue.Incoming(new NullQueue.Incoming());
// 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();
// ...
});
``