cutie-sqs

SQS backend for cutie.

Got jobs you need to run from an SQS queue? Now processing them is easy.

var through2 = require('through2'),
	sqs = require('cutie-sqs');

function work(job, encoding, callback) {
	// Do work here
	...

	// Job is done
	callback(null, job);
}

// Create the job queue
var jobs = sqs('https://my-queue-url');

// Process jobs
jobs.pipe(through2.obj(work));

// Send a job
jobs.write({ message: 'hello world' });