#nodejs Implementing a Job Queue with Node.js & kue / examples / video.js

simple-queue.js

var kue = require('kue')
  , jobs = kue.createQueue()
  ;

function newJob (name){

    name = name || 'Default_Name';
    var job = jobs.create('video conversion', {
        title:  name + '\'s to avi', user: 1, frames: 200
    });

    job
    .on('complete', function (){
        console.log('Job', job.id, 'converting', job.data.title, job.data.user, 'is done');
    })
    .on('failed', function (){
        console.log('Job', job.id, 'converting', job.data.title, job.data.user,'has failed');
    })

    job.save(function(err){
        if( !err ) console.log( job.id );
    });
  
}

jobs.process('video conversion', function (job, done){

  done && done();
});



function create() {
    var name = ['tobi', 'loki', 'jane', 'manny'][Math.random() * 4 | 0];
    console.log('- creating job for %s', name);  
    newJob(name);
}

setInterval(create, 3000);