@seedalpha/sqs

Wrapper around amazon simple queue service, used as a provider for `seedalpha/JobQueue`

Usage no npm install needed!

<script type="module">
  import seedalphaSqs from 'https://cdn.skypack.dev/@seedalpha/sqs';
</script>

README

Amazon Simple Queue Service

wercker status

Wrapper around amazon simple queue service, used as a provider for seedalpha/JobQueue

Changelog

1.2.0:

  • option timeout as VisibilityTimeout for Amazon SQS

1.1.2:

  • update aws-sdk

1.1.1:

  • ci integration & badge

1.1.0:

  • change name for private repository
  • update version

Prerequisites

$ npm set registry http://npm.sandbox.elasticseed.net
$ npm set always-auth true
$ npm login
$ export AMAZON_ACCESS_KEY_ID="abc"
$ export AMAZON_ACCESS_KEY_SECRET="123"

Installation

$ npm install seed-sqs --save

Usage

var queue = new Queue({ 
  name: 'test-queue',
  key: process.env.AMAZON_ACCESS_KEY_ID,
  secret: process.env.AMAZON_ACCESS_KEY_SECRET,
  timeout: 30
});

// push messages to the queue
queue.push({ hello: 'world' }, function(error) {
  
  // pull messages from the queue (long poll for 20s, auto-retry)
  queue.pull(function(error, message) {
    console.log(message.Body); // { hello: 'world' }
    
    // remove messages from the queue (avoid duplication)
    queue.release(message, function(error) {
      // message removed from queue
      
      // delete queue
      queue.reset(function(error) {
        // queue deleted
      });
    });
  });
});

Development

$ git clone git@github.com:seedalpha/sqs.git
$ cd sqs
$ npm install
$ npm test

Author

Vladimir Popov vlad@seedalpha.net

License

©2014 Seedalpha