Worker get a clean arguments.

athoune · Jan 15, 2012 · 94abc50 · 94abc50
1 parent 3fc2d9f
commit 94abc50
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 5 deletions.
diff --git a/examples/triangle/front.js b/examples/triangle/front.js
@@ -13,9 +13,9 @@ var web = http.createServer(function (req, res) {
       cluster.self(), function(err, resp) {
     //console.log('async job sent', resp);
   });
-  cluster.on('id:something long:' + job_id, function() {
-      //console.log('call back', arguments);
-      res.end('Hello World\n');
+  cluster.on('id:something long:' + job_id, function(arg) {
+      res.write(arg[0]);
+      res.end('\n');
   });
 });
 

diff --git a/examples/triangle/worker.js b/examples/triangle/worker.js
@@ -7,7 +7,7 @@ cluster.queues.push('working');
 
 cluster.worker.on('something long', function(args, respond_to, job_id) {
     //console.log('worker got some args', args);
-    cluster.answer(respond_to, 'something long', job_id, ['done'], function(err, resp) {
+    cluster.answer(respond_to, 'something long', job_id, ['Hello world!'], function(err, resp) {
     });
 });
 

diff --git a/lib/cluster.js b/lib/cluster.js
@@ -18,7 +18,10 @@ var Cluster = function(_port, _address) {
         if (command[0] == 'info') {
             this.encode('redis_version:2.4.5');
         } else {
-            that.emit('id:' + command[0] + ':' + command[1], command);
+            var cmd = command[0];
+            var pid = command[1];
+            var values = command[2];
+            that.emit('id:' + cmd + ':' + pid, JSON.parse(values));
             this.singleline('OK');
         }
     });