kue sample

var kue = require('kue')
var redis = require('redis')

kue.redis.createClient = function () {
  var client = redis.createClient();
  client.select(2, function (status) {
    console.log(status)
  })
  return client;
};

var jobs = kue.createQueue();

jobs.process('email', function (job, done) {
  done()
});

var job = jobs.create('email', {
  title: 'welcome email ', to: 'foo@bar.com', template: 'welcome-email'
})

job.save()

job.on('complete',function () {
  console.log("Job complete");
}).on('failed',function () {
    console.log("Job failed");
  }).on('progress', function (progress) {
    process.stdout.write('\r  job #' + job.id + ' ' + progress + '% complete');
  });


kue.app.listen(3000);