sqs-worker

0.0.2 • Public • Published

sqs-worker

sqs-worker reads messages from Amazon Simple Queue Service and call a function provided by you. It also deletes the message from the queue if you signals that everything went successfully.

Note: It does not guarantee that you don's sees the same message twice, therefore should you design your application to handle that.

Usage

var SQSWorker = require('sqs-worker')
 
var options =
  { url: 'https://sqs.eu-west-1.amazonaws.com/001123456789/my-queue'
  }
 
var queue = new SQSWorker(options, worker)
 
function worker(notifi, done) {
  var message
  try {
    message = JSON.parse(notifi.Data)
  } catch (err) {
    throw err
  }
 
  // Do something with `message`
 
  var success = true
 
  // Call `done` when you are done processing a message.
  // If everything went successfully and you don't want to see it any more,
  // set the second parameter to `true`.
  done(null, success)
}
 

Install

npm install sqs-worker

License

MIT

Package Sidebar

Install

npm i sqs-worker

Weekly Downloads

36

Version

0.0.2

License

MIT

Last publish

Collaborators

  • tellnes