sbnoti

servicebus-notifications-reader

(or sbnoti because Azure has problems with large path names -__-)

Notifications Reader for Azure Service Bus

Usage:

Promise = require("bluebird")
NotificationsReader = require("sbnoti")

reader = new NotificationsReader
  connectionString: "the azure connection string"
  topic: "the topic name"
  subscription: "the subscription name"
  # optional:
  filters: [
    { name: "theNameOfTheCustomFilter", expression: "created = True" }
  ]
  # more optional (the values are the defaults):
  log: false
  deadLetter: false
  concurrency: 25
  receiveBatchSize: 5
  waitForMessageTime: 3000

reader.run (message) =>
  # do something with message
  
  Promise.resolve "message processed ok"
  # or...
  Promise.reject "error processing the message"