exchange-pubsub

exchange-pubsub

A helper module to simplify @google-cloud/pubsub

Installation

npm i --save exchange-pubsub

Options

• topicBase = leading name of queue topic (default '')
• log = logger to use (defaults to console)
• defaultSubscribeOptions = (same as optional per-subscription options)
  • raw - provide full message to listener. Default = false (just the data)
  • autoAck - automatically acknowledge messages on return from listener. Default = true
• ignoreKeyFilename = don't set default pubSub keyFilename option
• pubSub = see @google-cloud/pubsub
  • projectId will attempt to use process.env.GCLOUD_PROJECT if not set
  • keyFilename will set to 'lib/gcloud-auth.json' if not set and ignoreKeyFilename is not set

Usage

const pubSub = require('exchange-pubsub');
// Optional:
pubSub.setOptions({
  topicBase: 'myTopicBase.',
  log: console,
  defaultSubscribeOptions: {
    raw: false,
    autoAck: true,
  },
});

pubSub.subscribe('myTopic', (msgData => {
  // default is only the message.data property from pubsub
  console.log(msgData); // should be 'my message' in this example
  
  // optionally return false or a Promise
  // if return value resolves to false, message will be nack'd, else ack'd
  // (unless autoAck option is disabled)
}));

pubSub.publish('myTopic', 'my message')
  .then(() => {/* do something */ })
  .catch(e => {/* error */ });

Source: [demo.js](demo.js)