opnotiq

opnotiq is a component to handle actions against operations and notifications queues, a simple pattern we use for decoupling work load from API requests, for accepting operations via non-api calls (i.e through a GCM upstream message) and notify when it's done.

Usage

  var queues = require('queues');

  var options = {
    token: 'xxxxxxxx'
    project_id: 'xxxxxxxx'
  }

  // init queue provider
  var provider = queues.iron(options);

  // init optoniq
  var opnotiq = require('opnotiq')(provider);

  opnotiq.on('notification', function(msg) {
    // handle notification
  });


  opnotiq.postOperation('update-task', {
    // op specific data
  }, function(){
    // callback
  });


  opnotiq.postNotification('attach-project', 9349, {
    // notification specific data
  }, function(){
    // callback
  });