Simple Service Bus for Node.js, Work in Progress

npm install simplebus
9 downloads in the last week
31 downloads in the last month


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:"foo");{ 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]);

Consume as a client:

var client = simplebus.createClient(port, [host]);
client.start(function () { // callback when connection is OK"foo");
    client.subscribe(function (msg) { return msg.price > 100 }, function (msg) { .... });


git clone 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


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

npm loves you