Generic template for event consumer

complex1.js

//keys are generated from the collection names.
var orderedAlarmsChangeConsumer = queue({exchange, "name":"ordered.alarms", exclusive:false}).consume(
  'canAlarms.insert': function(data) {
      if(data.canAlarms[0].archiveRequested){
        return createAndSendCanAlarms(data)
    },
    'canAlarms.delete': function ... ,
    'canAlarams.update': function ... ,
    'trackingData.insert': function... ,
    'trackingData.delete':function ... ,
    'trackingData.update':function ... ,
    'equipment.#': function ... ,
    'foo.bar.baz': function ... 
  },
)

complex2.js

queue({exchange, "name":"consoleLogs", keys: ['log.warn', 'log.info']}).consume(
  function(data, msg) {
    console.log(data)
    return Promise.resolve()
  }
)

queue({exchange, "name":"errorFile", keys: ['log.error', 'log.critical']}).consume(
  function(data) {
      return sendEmail(data)
  }
)