@aptoma/sqs-consumer
v2.1.0
Published
AWS SQS consumer
Downloads
25
Readme
SQS Consumer
Module for consuming AWS SQS queue.
Inspired by https://github.com/bbc/sqs-consumer but allows batchSize
to be higher than 10
Example
const Consumer = require('@aptoma/sqs-consumer');
const app = new Consumer({
queueUrl: 'https://sqs.eu-central-1.amazonaws.com/....',
batchSize: 15,
waitTimeSeconds: 10,
aws: {
region: 'eu-central-1'
},
async handleMessage(message, cb) {
console.log(message);
await doSometing(message);
cb();
}
});
app.on('error', console.error);
(async () => {
await app.start();
})();