tubejs
v0.0.1
Published
asynchronous Concurrent messaging
Downloads
3
Readme
Tube JS (v 0.0.1)
A prototype port of Scala actors to NodeJS. A lightweight asynchronous concurrent messaging.
Before we begin this project you shall be aware as this project is still in its prototype version and unstable. Future releases will make this library ready to be used in a production manner.
Getting Started
Example:
var tubeJs = require('tubeJs');
var channel = new tubeJs();
channel.spawn("actor1", "/absolute/path/to/actor/module");
channel.spawn("actor2", require.resolve("./relative/path/yourActor.js"));
At yourActor.js:
module.exports = function(wractor, name, path) {
console.log("CPID: "+ process.pid);
console.log("Actor name & Path: ", name, path);
wractor.on("message", function(sender, message, type) {
console.log("Actor Received: ", sender, message, type);
wractor.send(sender, message);
});
wractor.on("request", function(sender, message, type) {
console.log("Actor is requested: ", sender, message, type);
wractor.send(sender, message);
});
}
Send messages from Master to an actor:
channel.of("actor1").send("master", "Hello World", function () {
console.log("Sent!");
});
Then actor1
will receive "Hello World"
as message.
Feel free to enjoy.
Cheers!