SQS Task Queue

Are you using Kue with Redis backend?

This a quick way to replace Kue with Amazon SQS backend.

Instead of:

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

Do like this:

var AWS = require('aws-sdk')
var sqs = new AWS.SQS({
  region: '',
  accessKeyId: '',
  secretAccessKey: ''
})

var SQSWorker = require('sqs-taskqueue'),
  queue = new SQSWorker(
    sqs,
    'https://sqs.ap-northeast-1.amazonaws.com/XXXXXXXXXX/',
    'yourapp'
  );

The rest they are the same!!!

For example:

var job = queue.create('email', {
    title: 'welcome email for tj'
  , to: '[email protected]'
  , template: 'welcome-email'
}).save( function(err){
   if( !err ) console.log( job.id );
});