node.js kue and express

kue-express

import kue from 'kue'
import express from 'express'

const app = express();

const jobs = kue.createQueue()

app.use('/api', kue.app);

app.get('/job', (req, res) => {
  let job = jobs.create( 'email', {
      title: 'emailing '
  })
  job.on('complete', function(){
      res.send("Job complete");
  }).on('failed', function(){
      res.send("Job failed");
  }).on('progress', function(progress){
      console.log('job #' + job.id + ' ' + progress + '% complete');
  })
  job.save((err) => {
    if( !err ) res.json(job.id);
  });
})

jobs.process('email', function(job, done){
  setTimeout(() => {
    done()
  }, 5000);
});

app.listen(8080, function() {
    console.log("Listening on http://localhost:8080");
});

node server.js
node worker.js