Slipstream: Parallel Queue Processing
Slipstream provides simple parallel queue (SQS, Redis, etc) processing.
Install
npm install slipstream --save
Example
var Queue = Queue;var Sqs = providersSqs; var queue = batchSize: 5 //every connection to the provider will request 5 messages concurrency: 10 //we can process 10 messages at a time provider: region: 'us-west-1' accessKeyId: 'your access id' secretAccessKey: 'your access key' queueUrl: 'sqs queue url' ; queue; queue; queue; queue;
Tests
npm test