worker.js

var spawn = require('child_process').spawn;
var resque = require('coffee-resque').connect({
  host: 'localhost',
  port: 6379
});

var mathJobs = {
  git: function(url, dest, callback) {
      var clone = spawn('git', ['clone', url, dest]);

      clone.on.('exit', function(code) {
          callback(code);
      });
  },
  cp: function(source, dest, callback) {
      var cp = spawn('cp', [source, dest]);

      cp.on('exit', function(code) {
          callback(code);
      });
  },
  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 mathWorker = resque.worker('math', mathJobs)

// Triggered every time the Worker polls.
mathWorker.on('poll', function(worker, queue) {})

// Triggered before a Job is attempted.
mathWorker.on('job', function(worker, queue, job) {})

// Triggered every time a Job errors.
mathWorker.on('error', function(err, worker, queue, job) {})

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

mathWorker.start();