Version 0.0.4

README.md

@@ -121,7 +121,7 @@ server and many topologies running in worker processes.
 - 0.0.3: Published. Major internal/external refactor. Spout.start, Bold.process.
 Topology.listen. Topology Server. Task message exchange between running worker processes (in different
 nodes). Workers sample.
-- 0.0.4: Under develoopment, in master. To implement local and distributed ack.
+- 0.0.4: Published. Using SimpleMessages 0.0.6
 
 ## To Do
 

lib/simplestorm.js

@@ -252,10 +252,11 @@ exports.createTopologyServer = function () {
     }
 
     return simplemessages.createServer(function (client) {
+        console.log('new client');
         addClient(client);
 
-        client.on('error', function() { removeClient(client); });
-        client.on('close', function() { removeClient(client); });
+        client.on('error', function() { console.log('client error'); removeClient(client); });
+        client.on('close', function() { console.log('client close'); removeClient(client); });
         client.on('data', function(msg) {
             if (isHostMessage(msg))
                 broadcast(msg, client);

package.json

@@ -10,7 +10,7 @@
     "test": "nodeunit test"
   }
 , "dependencies": {
-	"simplemessages": "0.0.5"
+	"simplemessages": "0.0.6"
   }
 , "devDependencies": {
     "nodeunit": ">= 0.7.4"

samples/DistributedWebCrawler/package.json

@@ -3,6 +3,6 @@
   "version": "0.0.1",
   "private": true,
   "dependencies": {
-    "simplequeue": "0.0.3"
+    "simplequeue": "0.0.4"
   }
 }

samples/Workers/README.md

@@ -23,7 +23,7 @@ Server exposes a queue server using port 3000. It listens to topology workers at
 
 Launch one or more clients
 ```
-node stormnode.js port  
+node stormapp.js [port]
 ```
 The node starts to listen other nodes at `port`. It communicates its address to the topology server
 listening at port 3001.

samples/Workers/package.json

@@ -1,8 +1,8 @@
 {
-  "name": "distributed-webcrawler-example",
+  "name": "workers-example",
   "version": "0.0.1",
   "private": true,
   "dependencies": {
-    "simplequeue": "0.0.2"
+    "simplequeue": "0.0.4"
   }
 }