Skip to content

Instantly share code, notes, and snippets.

@amir-mamedov
Created August 21, 2012 13:43
Show Gist options
  • Save amir-mamedov/9750c752deaabe8a42a1 to your computer and use it in GitHub Desktop.
Save amir-mamedov/9750c752deaabe8a42a1 to your computer and use it in GitHub Desktop.
var kue = require('kue')
, express = require('express');
var jobs = kue.createQueue();
function create() {
var name = ['tobi', 'loki', 'jane', 'manny'][Math.random() * 4 | 0];
console.log('- creating job for %s', name);
jobs.create('video conversion', {
title: 'converting ' + name + '\'s to avi'
, user: 1
, frames: 200
}).save();
setTimeout(create, Math.random() * 3000 | 0);
}
create();
jobs.process('video conversion', 3, function(job, done){
var frames = job.data.frames;
console.log("job process %d", job.id);
function next(i) {
// pretend we are doing some work
convertFrame(i, function(err){
if (err) return done(err);
// report progress, i/frames complete
job.progress(i, frames);
if (i == frames) done()
else next(i + 1);
});
}
next(0);
});
function convertFrame(i, fn) {
setTimeout(fn, Math.random() * 100);
}
// start the UI
var app = express();
app.use(express.basicAuth('foo', 'bar'));
app.use(kue.app);
app.listen(3000);
console.log('UI started on port 3000');
node app.js
- creating job for tobi
UI started on port 3000
job process 13
job process 14
job process 15
- creating job for jane
- creating job for loki
/home/tenkoff/node/kue/node_modules/kue/node_modules/redis/index.js:487
throw err;
^
TypeError: Object #<HTTPServer> has no method 'render'
at ServerResponse.res.render (/home/tenkoff/node/kue/node_modules/express/lib/response.js:677:7)
at exports.jobs (/home/tenkoff/node/kue/node_modules/kue/lib/http/routes/index.js:23:11)
at try_callback (/home/tenkoff/node/kue/node_modules/kue/node_modules/redis/index.js:484:9)
at RedisClient.return_reply (/home/tenkoff/node/kue/node_modules/kue/node_modules/redis/index.js:555:13)
at HiredisReplyParser.RedisClient.init_parser (/home/tenkoff/node/kue/node_modules/kue/node_modules/redis/index.js:256:14)
at HiredisReplyParser.EventEmitter.emit (events.js:88:17)
at HiredisReplyParser.execute (/home/tenkoff/node/kue/node_modules/kue/node_modules/redis/lib/parser/hiredis.js:43:18)
at RedisClient.on_data (/home/tenkoff/node/kue/node_modules/kue/node_modules/redis/index.js:440:27)
at Socket.<anonymous> (/home/tenkoff/node/kue/node_modules/kue/node_modules/redis/index.js:70:14)
at Socket.EventEmitter.emit (events.js:88:17)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment