Package Exports

sqsd-handler

This package does not declare an exports field, so the exports above have been automatically detected and optimized by JSPM instead. If any package subpath is missing, it is recommended to post an issue to the original package (sqsd-handler) to support the "exports" field. If that is not possible, create a JSPM override to customize the exports field for this package.

Readme

Introduction

sqsd-handler is Express middleware for handling SQS messages posted by the AWS ElasticBeanstalk worker-tier utility, SQSD.

Quick Start

npm install sqsd-handler --save

Then:

var express = require("express");
var app = express();
var sqsdHandler = require("sqsd-handler");

// Create message handler
var handler = sqsdHandler.create(function (msg) {
    console.log("Received worker message", msg);
});

// Mount handler to Express stack at ElasticBeanstalk worker path
app.use("/", handler);

Usage

sqsd-handler supports a number of Elastic Beanstalk worker-tier SQS messaging use cases:

Messages sent to the environment's worker queue
Scheduled task messages
Identifying SNS notification messages and parsing SNS fields

Additionally, the API provides methods for error handling and logging.

Worker Queue Messages

var sqsdHandler = require("sqsd-handler");
var express = require("express");
var app = express();

var handler = sqsdHandler.create(function (msg) {
    console.log("Received worker queue message", msg);
});

app.use("/", handler);

Scheduled Task Messages

var sqsdHandler = require("sqsd-handler");
var express = require("express");
var app = express();

var scheduledTaskHandler = sqsdHandler.create();

scheduledTaskHandler.task("blue", function (msg) {
    console.log("Scheduled task 'blue': ", msg);
});

scheduledTaskHandler.task("red", function (msg) {
    console.log("Scheduled task 'red': ", msg);
});

app.use("/scheduled", scheduledTaskHandler);

var sqsdHandler = require("sqsd-handler");
var express = require("express");
var app = express();

var snsHandler = sqsdHandler.sns(function (msg) {
    console.log("Received SNS notification", msg.sns);
});

app.use("/messages", snsHandler);

License

MIT

sqsd-handler