cr_consumer.js

var cresque = require('coffee-resque');
var util = require('util');

var myJobs = {
  add: function(a, b, callback) { callback(a + b); },
  succeed: function(arg, callback) { callback(); },
  fail: function(arg, callback) { callback(new Error('fail')); }
}

// setup a worker
var worker = cresque.connect({
  host: 'redisHost',
  port: 6379
}).worker('*', myJobs)

// Triggered every time the Worker polls.
worker.on('poll', function(worker, queue) {
  console.log(worker.name + ' polling ' + queue);
});

// Triggered before a Job is attempted.
worker.on('job', function(worker, queue, job) {
  console.log('job ' + util.inspect(job));
});

// Triggered every time a Job errors.
worker.on('error', function(err, worker, queue, job) {
  console.log('error ' + util.inspect(err));
});

// Triggered on every successful Job run.
worker.on('success', function(worker, queue, job, result) {
  console.log('success ' + util.inspect(job) + ' = ' + util.inspect(result));
});

worker.start()