andela-pubsub

Andela Pubsub

This package houses tech team pubsub implementation.

Usage

To emit an event, use

const pubsub = require('andela-pubsub')
 
pubsub.emit({ data: payload, attributes: { eventType: 'NameOfEvent', ... }}, topicName)

To subscribe to an event, use

const pubsub = require('andela-pubsub')
 
const handlers = {
  EventName: async HandlerFunction
}
 
pubsub.subscribe([ { topicName, subscriptionName }], handlers )
 

To set custom deadline timeout (time needed to process an event), use

const pubsub = require('andela-pubsub')
 
const handlers = {
  EventName: { timeoutInSeconds: xxxx, method: async HandlerFunction }
}
 
pubsub.subscribe([ { topicName, subscriptionName }], handlers )