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' });