-
-
Save amir-mamedov/9750c752deaabe8a42a1 to your computer and use it in GitHub Desktop.
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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'); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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