test

lib/amqp/rpcserver.js

@@ -33,8 +33,8 @@ RPCServer.prototype.start = function(cb)
           ch.sendToQueue(msg.properties.replyTo,new Buffer(JSON.stringify(resp)),{correlationId: msg.properties.correlationId,persistent: false});
 
         });
-        ch.ack(msg);
-      }, {noAck: false});
+        //ch.ack(msg);
+      }, {noAck: true});
       cb(null);
 
     });

test/test_rpccli.js

@@ -28,11 +28,13 @@ var req = {
 
   var idx = 0;
   async.whilst(
-      function() { return idx < 10000; },
+      function() { return idx < 2000; },
       function(callback) {
         req.id = idx;
         caller.call(req,function(err,resp){
-          //console.log(resp)
+          if(idx%100==0){
+            console.log(resp)
+          }
           idx++;
           callback(null);
         });