Here is the code I got to do what I think you're doing.
Simply this just adds a job when the url /job gets hit a worker job is created that the running worker picks up, waits a half a second and generates a random number. This is the non-socket.io version. You probably shouldn't do it like this, but it works.
The web server (web.js):
var port = 1337;
var app = require('express')()
, server = require('http').createServer(app);
server.listen(port);
var fs = require('fs');
var kue = require('kue')
, jobs = kue.createQueue();
app.get('/',function(req,res) {
fs.readFile(__dirname+'/index.html',function(err,data) {
res.send(data.toString());
});
});
var responses = {};
app.get('/job', function(req, res){
var id = ''+Math.random();
jobs.create('worker-job', {
title: 'worker job'
, res_id: id
, template: 'Some string to look up'
}).save();
responses[id] = res;
});
jobs.process('results',function(job,done) {
responses[job.data.res_id].send(job.data);
delete responses[job.data.res_id];
done();
});
The worker (worker.js):
var kue = require('kue')
, jobs = kue.createQueue();
jobs.process('worker-job',function(job,done) {
setTimeout(function() {
jobs.create('results',{
title:'results job',
status:'complete',
res_id:job.data.res_id,
random:Math.ceil(Math.random()*10000)
}).save();
done();
},400);
});