simplebus

Simple Service Bus for Node.js, Work in Progress

SimpleBus

Simple Service Bus implementation, for Node.js.

Via npm on Node:

npm install simplebus

Reference in your program:

var simplebus = require('simplebus');

Create a local message bus:

var bus = simplebus.createBus();

Create a local message bus with a fixed size message queue (recommended):

var bus = simplebus.createBus(1000);

Send a message to local bus:

bus.post("foo");
bus.post({ operation: 'sale', price: 100, quantity: 10 });

Subscribe to a message

// to all message 
bus.subscribe(null, function (msg) { ... });
// to messages with property operation === 'sale' 
bus.subscribe({ operation: 'sale' }, function(msg) { ... });
// to messages that satisfy a predicate 
bus.subscribe(function (msg) { return msg.price < 100; }, function(msg) { ... });

Expose a bus as a server:

var server = simplebus.createServer(bus, port, [host]);
server.start();
/// 
server.stop();

Consume as a client:

var client = simplebus.createClient(port, [host]);
client.start(function () { // callback when connection is OK 
    client.post("foo");
    client.subscribe(function (msg) { return msg.price > 100 }, function (msg) { .... });
});
/// 
client.stop();
git clone git://github.com/ajlopez/SimpleBus.git
cd SimpleBus
npm install
npm test
  • Market A distributed sample. Operator send buy or sale messages, subscriber listen to selected messages.
  • 0.0.1: Published
  • 0.0.2: Published, bus with maximum message queue size
  • 0.0.3: Published, using SimpleRemote 0.0.5, updated engine range
  • 0.0.4: Published, with improved error handling, via remster and sidrees

Feel free to file issues and submit pull requests � contributions are welcome.

If you submit a pull request, please be sure to add or update corresponding test cases, and ensure that npm test continues to pass.

(Thanks to JSON5 by aseemk. This file is based on that project README.md).