![Introducing Enhanced Alert Actions and Triage Functionality](https://cdn.sanity.io/images/cgdhsj6q/production/fe71306d515f85de6139b46745ea7180362324f0-2530x946.png?w=800&fit=max&auto=format)
Product
Introducing Enhanced Alert Actions and Triage Functionality
Socket now supports four distinct alert actions instead of the previous two, and alert triaging allows users to override the actions taken for all individual alerts.
sqs-consumer
Advanced tools
Readme
Build SQS-based applications without the boilerplate. Just define a function that receives an SQS message and call a callback when the message has been processed.
npm install sqs-consumer
var Consumer = require('sqs-consumer');
var app = new Consumer({
queueUrl: 'https://sqs.eu-west-1.amazonaws.com/account-id/queue-name',
region: 'eu-west-1',
handleMessage: function (message, done) {
// do some work with `message`
done();
}
});
app.on('error', function (err) {
console.log(err.message);
});
app.start();
done()
is called.done(err)
with an error object will cause the message to be left on the queue. An SQS redrive policy can be used to move messages that cannot be processed to a dead letter queue.batchSize
option detailed below.new Consumer(options)
Creates a new SQS consumer.
queueUrl
- String - The SQS queue URLregion
- String - The AWS regionhandleMessage
- Function - A function to be called whenever a message is receieved. Receives an SQS message object as its first argument and a function to call when the message has been handled as its second argument (i.e. handleMessage(message, done)
).batchSize
- Number - The number of messages to request from SQS when polling (default 1
). This cannot be higher than the AWS limit of 10.sqs
- Object - An optional AWS SQS object to use if you need to configure the client manuallyconsumer.start()
Start polling the queue for messages.
consumer.stop()
Stop polling the queue for messages.
Each consumer is an EventEmitter
and emits the following events:
Event | Params | Description |
---|---|---|
error | err | Fired when an error occurs interacting with the queue or processing the message. |
message_received | message | Fired when a message is received. |
message_processed | message | Fired when a message is successfully processed and removed from the queue. |
FAQs
Build SQS-based Node applications without the boilerplate
The npm package sqs-consumer receives a total of 460,007 weekly downloads. As such, sqs-consumer popularity was classified as popular.
We found that sqs-consumer demonstrated a healthy version release cadence and project activity because the last version was released less than a year ago. It has 2 open source maintainers collaborating on the project.
Did you know?
Socket for GitHub automatically highlights issues in each pull request and monitors the health of all your open source dependencies. Discover the contents of your packages and block harmful activity before you install or update your dependencies.
Product
Socket now supports four distinct alert actions instead of the previous two, and alert triaging allows users to override the actions taken for all individual alerts.
Security News
Polyfill.io has been serving malware for months via its CDN, after the project's open source maintainer sold the service to a company based in China.
Security News
OpenSSF is warning open source maintainers to stay vigilant against reputation farming on GitHub, where users artificially inflate their status by manipulating interactions on closed issues and PRs.