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) => channel.responseEmitter.emit(msg.properties.correlationId, JSON.parse(msg.content.toString())),
+          (msg) => { console.log('reply consumee'); ch.responseEmitter.emit(msg.properties.correlationId, JSON.parse(msg.content.toString()))},
           {noAck: true});
 
         self.opened = true;
@@ -43,15 +43,14 @@ function RPCCaller(config)
 RPCCaller.prototype.call = function(req,cb){
   var self = this;
   var corr = generateUuid();
-console.log('callllll')
-  this.open(function(err){
+  self.open(function(err){
     if(err){
       console.log(err);
     }
     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)), { corr, replyTo: REPLY_QUEUE })
   });
 
   function generateUuid() {