kue demo

app.js

'use strict';

const kue = require('kue');

kue.createQueue({
  prefix: 's9',
  redis: {
    host: 'localhost',
    db: 1
  }
});

kue.app.listen(8000);

consumer.js

'use strict';

const kue = require('kue');
const queue = kue.createQueue({
  prefix: 's9',
  redis: {
    host: 'localhost',
    db: 1
  }
});

queue.process('push', (job, done) => {
  setTimeout(() => {
    console.log('push notification' + job.data.uid);
    done();
  }, 2000);
});

package.json

{
  "name": "kue-demo",
  "version": "1.0.0",
  "description": "",
  "main": "index.js",
  "scripts": {
    "test": "xo"
  },
  "author": "",
  "license": "ISC",
  "dependencies": {
    "kue": "^0.11.4"
  }
}

producer.js

'use strict';

const kue = require('kue');
const queue = kue.createQueue({
  prefix: 's9',
  redis: {
    host: 'localhost',
    db: 1
  }
});

let sequence = 0;

setInterval(() => {
  sequence += 1;

  ((sequence) => {
    const job = queue.create('push', {
      uid: sequence
    }).removeOnComplete(true).delay(1000).priority('high').save();

    job.on('start', () => {
      console.log('#' + sequence + ' start', new Date());
    }).on('complete', () => {
      console.log('#' + sequence + ' complete', new Date());
    }).on('complete', () => {
      console.log('#' + sequence + ' remove', new Date());
    });
  })(sequence);
}, 1000);