seneca-sqs-queue

KO | EN

gitlite — search

#golang #android #machine-learning #deep-learning #linux #docker #macos #nodejs #java #awesome #cli #vue #pytorch #open-source

seneca-sqs-queue

(★ 8)

Seneca plugin to send/receive message over Amazon SQS

seneca-sqs-queue Latest Version Download

Download Latest Version (.zip)

// repository documentation

Was this content helpful?

★ 0 (0 ratings)

# seneca-queue

A SQS job queue plugin for Seneca

It support send/receive messages to/from a given Amazon SQS queue.

In order to receive a message you should add a Seneca patter that will match the message you are sending i.e:

```js
  seneca.add({type: 'task'}, function (args, next) {
    console.log(args);
    next();  // This is needed to receive the next message
  })
  ```
and then start the receiver with:

```js
  seneca.act({role: 'queue', cmd: 'start'});
  ```

this will receive all the messages containing a `type` key with the `task` value, to send a message like this use:

```js
  seneca.act({role: 'queue', cmd: 'enqueue', msg: {type: 'task', number '42'}});
  ```

you can stop the queue with:

```js
  seneca.act({role: 'queue', cmd: 'stop'});
  ```

## Events

As you may suspect, when we stop the receiver it doesn't stop right away.
If we want to execute and action when the receiver is stopped we can subscribe to the 'stopped' event

```js
  seneca.add({
      role: 'queue',
      evnt: 'stopped'
    }, function () {
      console.log("RECEIVER STOPPED");
  });
  ```

You can do the same for the `empty` event, it is emitted every time the receiver time out waiting for a message.

# Test

To run the tests you need to create a `config/test_env` file using `config/example_env` as example and provide all the required information
The you can run:

```js
  npm test
  ```

# Acknowledgements

Sponsored by [nearForm](http://www.nearform.com/)

##
## License

MIT

seneca-sqs-queue

seneca-sqs-queue Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

seneca-sqs-queue

seneca-sqs-queue Latest Version Download

Today's picks

Was this content helpful?

Recent Feedback

Download README