var producer = pikaQueue('reverse-string');
 
// Pass in a callback if you wish to receive notification when the job is complete.
producer.queueJob({ data: "Job Data" }, function(err, message) {
  // this callback is optional
  assert.equal(message.data, "ataD boJ");
});

// add a callback to make it a worker
pikaQueue('reverse-string', function(job, cb) {
  var rev = job.data.split('').reverse().join('');
  cb(null, { data: rev });
});

pikaQueue(
  'safety-first',
  {
    safe: true, // jobs will be retried if they fail
    timeout: 30e3, // this is the max amount of time a job should take in milliseconds
    redis: { // you can also pass in a redis host
      port: 6379,
      host: 'localhost'
    }
  },
  function(job, cb) {
    if (Math.random() < 0.5) return;
    cb(null, 'this will run eventually');
  }
);