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
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).