svcs
v0.2.1
Published
AMQP driven micro services for node.
Downloads
16
Readme
svcs
This library aims to simplify building queue based services in nodejs using AMQP. It simplifies getting started and provides some out of the box monitoring / admin for these services.
Status
Don't use it in production, early adopters and hackers are welcome, the API is still in a state of flux as we work on evolving some of the core features.
API
To build a new service we just create the service and pass in our handler(s).
var svcs = require('svcs');
var container = svcs();
// override the default amqpUrl
var amqpUrl = process.env.AMQP_URL || config.amqp.url;
container.set('amqpUrl', amqpUrl);
function onErr(err) {
console.warn('error processing message', err);
}
// add a route which will process messages for the given routing key
// the attribute :gatewayId will be replaced with * when passed to bindQueue
container.route('$gw.:gatewayId.events', {queue: 'gw_events', errorHandler: onErr}, function handler(msg){
var gatewayId = msg.params.gatewayId;
});
Middleware
There are a couple of modules which can be added to the container.
JSON
This is a simple JSON decoder which will convert the payload of the incoming AMQP messages to JSON when the messages
contentType
is set to application/json
.
container.use(svcs.json());
Routing Statistics
This will send per routingKey
statistics to a statsd server using the increment
function.
container.use(svcs.stats());
TODO
- Add locals to enable connection pools to be tied in and available to the msg, this probably should be done by a middleware module later.
- Need to rework configuration and decide where the defaults should live.
- Need to review jobs as the api is pretty average at the moment.
- More testing..
License
Copyright (c) 2013 Mark Wolfe released under the MIT license.