@gasbuddy/configured-sqs-client

configured-sqs-client

A small wrapper around the AWS SQS sdk and sqs-consumer to allow configuration from confit. Unlike configured-rabbitmq-client, most queue configuration for SQS is done OUTSIDE of the infrastructure here (assumedly will be terraform or similar). So this module focuses on publishing and consuming messages, but with as similar an configuration specification as possible.

Usage

See the test directory for sample usage. To send a message, you must configure a logical queue, something like:

{
  region: 'us-east-1',
  queues: {
    basic: 'basic_queue'
  }
}

Now, you can publish to this queue using:

  configuredSqsClient.publish(req, 'basic', { some: 'message' });

To receive this message, you would subscribe:

  sqs.subscribe(context, 'basic', async (req, message, envelope) => {
    // Do stuff, await stuff, throw errors, whatever
  });

If your handler throws an error, the redrive policy of the queue takes over. However, if your handler marks that error with a property "deadLetter" that is either true or the name of another queue, the failed attempt will be published on the target queue (either the deadLetter property of the queue that was configured in your configured-sqs-client config, or the queue specified in the deadLetter error property).

Compression

Max message size allowed through SQS is 256kb. You can compress/deflate your message if you think it could go over that limit.

  configuredSqsClient.publish(req, 'basic', { some: 'message' }, { compression: true });

The deflated message will automatically be inflated before delivering to a consumer

Testing this package

docker run -p 9324:9324 gasbuddy/sqs-mock:latest
npm run test