testcase

test/test_rpccli.js

 var ctx = require('../context');
+var async = require('async');
 var amqp_cfg = ctx.config.amqp;
 
 var RPCCaller = ctx.getLib('lib/amqp/rpccaller');
 
 var caller = new RPCCaller({
   url : amqp_cfg.url,
-  name :'storage_request'
+  name :'test_request'
 });
 
 var req = {
-    'object_type' : 'storage_request',
+    'object_type' : 'test_request',
     'command' : 'write',
     'param' : {
       'storage_name' : 'gcs.file.test',
@@ -24,10 +25,26 @@ var req = {
     }
 }
 
-caller.call(req,function(err,resp){
-  console.log(resp);
-});
 
+  var idx = 0;
+  async.whilst(
+      function() { return idx < 10000; },
+      function(callback) {
+        caller.call(req,function(err,resp){
+          idx++;
+          callback(null);
+        });
+      },
+      function (err) {
+        if(!err){
+          response.success();
+        }else{
+          console.log(err);
+          response.error("storage error");
+        }
+      }
+
+  );
 
 
 

test/test_rpsserv.js

@@ -5,26 +5,14 @@ var rpcserver = ctx.getLib('lib/amqp/rpcserver');
 
 var server = new rpcserver({
               url : amqp_cfg.url,
+              name : 'test_request'
             });
 
 server.set_remote_function(function(req,callback){
-  var n = parseInt(req.t);
-  console.log('REQUEST ' + req);
-  setTimeout(function(){
   callback(null,{'time':n,'data':req.d});
-      },n);
 })
 
 server.start(function(err){
   console.log('server start');
 })
 
-var http = require('http');
-http.createServer(function (req, res) {
-    res.writeHead(200, {
-        'Content-Type': 'text/plain; charset=UTF-8'
-    });
-    console.log(req.body);
-    res.end("req");
-
-}).listen(9080, "");