@google-cloud/pubsub for MQueue

An Google Cloud Pub-Sub adapter for MQueue, adding support for Google Cloud Pub/Sub with a multi-backend setup with MQueue.

npm install --save @mqueue/queue @mqueue/google-cloud-pubsub
# or use pnpm/yarn

import MQueue from "@mqueue/queue"; // or require("@mqueue/queue");
import { PubSubQueue } from "@mqueue/google-cloud-pubsub"; // or require("@mqueue/google-cloud-pubsub");

const outgoingQueue = new MQueue.Outgoing(
  await PubSubQueue.Outgoing.connect(...),
);

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

// ...

const incomingQueue = new MQueue.Incoming(
  await PubSubQueue.Incoming.connect(...),
);

// 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

• Google Cloud Pub/Sub

License

MIT © Dom Webber