queues

Collection of queue wrappers with a common interface.

queues

Collection of queue wrappers with a common interface.

For IronMQ:

var queues = require('queues');
 
var provider = queues.iron(config);
 
var q = provider.get('notifications');
 
// set a backoff strategy 
q.idleBackoff('linear', 5);
 
q.connect();
 
q.on('message', function(msg) {
  // handle message 
});
 
q.post({ arg1: 'hello' });