sqs-consumer - Build SQS-based Node applications without the boilerplate

  •        55

Build SQS-based applications without the boilerplate. Just define a function that receives an SQS message and call a callback when the message has been processed.Creates a new SQS consumer.

https://github.com/BBC/sqs-consumer

Dependencies:

async : ^2.0.1
auto-bind : ^1.1.0
aws-sdk : ^2.100.0
debug : ^2.1.0

Tags
Implementation
License
Platform

   




Related Projects

goaws - AWS (SQS/SNS) Clone for Development testing

  •    Go

Written in Go this is a clone of the AWS SQS/SNS systems. This system is designed to emulate SQS and SNS in a local environment so developers can test their interfaces without having to connect to the AWS Cloud and possibly incurring the expense, or even worse actually write to production topics/queues by mistake. If you see any problems or would like to see a new feature, please open an issue here in github. As well, I will logon to Gitter so we can discuss your deployment issues or the weather. Usign the postman collection, use this link to import it. As well the Environment variable for the collection should be set as follows: URL = http://localhost:4100/.

JCTools - Java Concurrency Tools for the JVM

  •    Java

Java Concurrency Tools for the JVM. This project aims to offer some concurrent data structures currently missing from the JDK.

lambda-complex - Build and deploy Node.js applications constructed from AWS Lambda functions.

  •    Javascript

Lambda Complex is a Node.js framework for applications that run entirely within Lambda, SQS, and other high abstraction layer AWS services. It is well suited to non-realtime content generation and other types of application driven by message queues and which require enforced concurrency limits. Examples include high volume generation of static content from data or other types of workflow initiated in response to messages placed into SQS queues. A Lambda Complex application can be deployed from a developer machine, or from an Amazon Linux EC2 instance if binary NPM modules are required. No server infrastructure beyond that is needed.

aws-lib - Extensible Node.js library for the Amazon Web Services API

  •    Javascript

A simple Node.js library to communicate with the Amazon Web Services API. Richard Rodger maintains a user-friendly SimpleDB library which is based on aws-lib.


cqs - CouchDB Queue Service: API-compatible Amazon SQS implementation with NodeJS, CouchDB

  •    Javascript

CouchDB Queue Service: API-compatible Amazon SQS implementation with NodeJS, CouchDB

AWS for .NET Sample (Amazon EC2, S3, SQS, DynamoDB)

  •    

Amazon Web Services (AWS) Sample for .NET (C#) with Asp.NET MVC and Web API. Including S3, DynamoDB, Elastic Beanstalk and SQS

cmb - A highly available, horizontally scalable queuing and notification service compatible with AWS SQS and SNS

  •    Java

A highly available, horizontally scalable queuing and notification service compatible with AWS SQS and SNS

propono - Easy-to-use pub/sub built on AWS. Ruby.

  •    Ruby

Propono is a pub/sub gem built on top of Amazon Web Services (AWS). It uses Simple Notification Service (SNS) and Simple Queue Service (SQS) to seamlessly pass messages throughout your infrastructure. The first thing to do is setup some configuration keys for Propono. It's best to do this in an initializer, or at the start of your application.

kq - Kafka-based Job Queue for Python

  •    Python

KQ (Kafka Queue) is a lightweight Python library which lets you queue and execute jobs asynchronously using Apache Kafka. It uses kafka-python under the hood. You may need to use sudo depending on your environment.

Stratosphere

  •    

Mono compatible .NET/C# library with set of primitives to work with table, queue and block containers with corresponding implementations for Amazon SimpleDB, SQS and S3. Additionally includes local machine (file system and SQLite) implementations to enable debugging and testing.

concurrentqueue - A fast multi-producer, multi-consumer lock-free concurrent queue for C++11

  •    C++

An industrial-strength lock-free queue for C++. Note: If all you need is a single-producer, single-consumer queue, I have one of those too.

Luxun - A high-throughput, persistent, distributed, publish-subscribe messaging system based on memo

  •    Java

A high-throughput, persistent, distributed, publish-subscribe messaging system based on memory mapped file and Thrift RPC.

aws - Easy command line access to Amazon EC2, S3, SQS, ELB, and SDB (new!)

  •    Perl

Easy command line access to Amazon EC2, S3, SQS, ELB, and SDB (new!)

aws - Easy command line access to Amazon EC2, S3, SQS, ELB, and SDB (new!)

  •    Perl

Easy command line access to Amazon EC2, S3, SQS, ELB, and SDB (new!)

thumbd - Node.js/AWS/ImageMagick-based image thumbnailing service.

  •    Javascript

Thumbd is an image thumbnailing server built on top of Node.js, SQS, S3, and ImageMagick.You can easily run Thumbd on Heroku. Simply set the appropriate environment variables with config:set and deploy using the Procfile provided.

fake_sqs - Provides a fake SQS server that you can run locally to test against

  •    Ruby

Fake SQS is a lightweight server that mocks the Amazon SQS API. It is extremely useful for testing SQS applications in a sandbox environment without actually making calls to Amazon, which not only requires a network connection, but also costs money.

uq - Another simple persistent message queue.

  •    Go

Messages in uq is very safe. It exists until a consumer confirms clearly. Consumer lines of a topic are independent. So one independent workflow can use a line to consume the messages in topic. A group of uq can make up a cluster. Cluster information is stored in etcd. Clients can get the information from etcd and then connect to one or some uq servers in the cluster. Or you can use libuq to communicate with uq cluster.Messages popped from a line should be confirmed after disposing. If a consumer pops a message but fails to dispose it, this message will be pushed back into the line after a recycle time which is set when creating the line.

Celery - Distributed Task Queue

  •    Python

Celery is an asynchronous task queue/job queue based on distributed message passing. It is focused on real-time operation, but supports scheduling as well. The execution units, called tasks, are executed concurrently on a single or more worker servers using multiprocessing, Eventlet, or gevent. Tasks can execute asynchronously (in the background) or synchronously (wait until ready).

rsmq - Redis Simple Message Queue

  •    CoffeeScript

A lightweight message queue for Node.js that requires no dedicated queue server. Just a Redis server. tl;dr: If you run a Redis server and currently use Amazon SQS or a similar message queue you might as well use this fast little replacement. Using a shared Redis server multiple Node.js processes can send / receive messages.