rpc persist

lib/amqp/rpccaller.js

@@ -50,7 +50,7 @@ RPCCaller.prototype.call = function(req,cb){
     self.ch.responseEmitter.once(corr, (resp)=>{
       cb(null,resp);
     });
-    self.ch.sendToQueue(self.name, new Buffer(JSON.stringify(req)), { correlationId: corr, replyTo: REPLY_QUEUE })
+    self.ch.sendToQueue(self.name, new Buffer(JSON.stringify(req)), { correlationId: corr, replyTo: REPLY_QUEUE,persistent: false })
   });
 
   function generateUuid() {

lib/amqp/rpcserver.js

@@ -30,7 +30,7 @@ RPCServer.prototype.start = function(cb)
         var req = JSON.parse(msg.content.toString());
 
         self.remote_function(req,function(err,resp){
-          ch.sendToQueue(msg.properties.replyTo,new Buffer(JSON.stringify(resp)),{correlationId: msg.properties.correlationId});
+          ch.sendToQueue(msg.properties.replyTo,new Buffer(JSON.stringify(resp)),{correlationId: msg.properties.correlationId,persistent: false});
 
         });
         ch.ack(msg);