Work in progress

node-consumer

$ npm i --save node-consumer

Example

var optinos = {
  nsqd: [':4150'],
  maxInFlight: 1,
  maxAttempts: 5,
  topic: 'events',
  channel: 'ingestion'
};

Consumer(NSQReader(options))
  .use(findTheNecessaryData())
  .use(calculate())
  .use(saveToDatabase())
  .start()
  .on('error', function (err) {
    // handled error
  });

Context

• .body
• .finish()
• .requeue(ms)

Interfaces

Message

• .getBody()
• .finish()
• .requeue(ms)

QueueReader

• .setupMessageEventHandler(handler)
• .setupErrorEventHandler(handler)