db

lib/amqp/rpccaller.js

@@ -27,7 +27,7 @@ function RPCCaller(config)
         ch.responseEmitter = new EventEmitter();
         ch.responseEmitter.setMaxListeners(0);
         ch.consume(REPLY_QUEUE ,
-          (msg) => { console.log('reply consumee'); ch.responseEmitter.emit(msg.properties.correlationId, JSON.parse(msg.content.toString()))},
+          (msg) => { console.log('reply consumee to ' + msg.properties.correlationId); ch.responseEmitter.emit(msg.properties.correlationId, JSON.parse(msg.content.toString()))},
           {noAck: true});
 
         self.opened = true;