corr

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 to ' + msg.properties.correlationId); ch.responseEmitter.emit(msg.properties.correlationId, JSON.parse(msg.content.toString()))},
+          (msg) => { console.log(msg); ch.responseEmitter.emit(msg.properties.correlationId, JSON.parse(msg.content.toString()))},
           {noAck: true});
 
         self.opened = true;
@@ -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)), { corr, replyTo: REPLY_QUEUE })
+    self.ch.sendToQueue(self.name, new Buffer(JSON.stringify(req)), { correlationId: corr, replyTo: REPLY_QUEUE })
   });
 
   function generateUuid() {