inc prefetch size

lib/amqp/rpccaller.js

@@ -26,6 +26,7 @@ function RPCCaller(config)
         
         ch.responseEmitter = new EventEmitter();
         ch.responseEmitter.setMaxListeners(0);
+        ch.prefetch(4);
         ch.consume(REPLY_QUEUE ,
           (msg) => { ch.responseEmitter.emit(msg.properties.correlationId, JSON.parse(msg.content.toString()))},
           {noAck: true});

lib/amqp/rpcserver.js

@@ -23,7 +23,7 @@ RPCServer.prototype.start = function(cb)
       var q = self.name;
 
       ch.assertQueue(q, {durable: false});
-      ch.prefetch(1);
+      ch.prefetch(4);
       //console.log(' [x] Awaiting RPC requests');
 
       ch.consume(q, function reply(msg) {