node package manager
Stop wasting time. Easily manage code sharing in your team. Create a free org »

cutie-sqs

cutie-sqs

SQS backend for cutie.

build status coverage license version downloads

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