buff from

lib/amqp/event-pub.js

@@ -40,7 +40,7 @@ EventPub.prototype.send = function(topic,msg)
 {
   var self=this;
   this.open(function(err){
-    self.ch.publish(self.name, topic, new Buffer(JSON.stringify(msg)));
+    self.ch.publish(self.name, topic, Buffer.from(JSON.stringify(msg)));
   });
 }
 

lib/amqp/queuecaller.js

@@ -41,7 +41,7 @@ QueueCaller.prototype.send = function(msg)
     if(err){
       console.log(err);
     }
-    self.ch.sendToQueue(self.name, new Buffer(JSON.stringify(msg)), {persistent: true});
+    self.ch.sendToQueue(self.name, Buffer.from(JSON.stringify(msg)), {persistent: true});
   });
 }
 

lib/amqp/rpccaller.js

@@ -51,7 +51,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,persistent: false })
+    self.ch.sendToQueue(self.name, Buffer.from(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,persistent: false});
+          ch.sendToQueue(msg.properties.replyTo,Buffer.from(JSON.stringify(resp)),{correlationId: msg.properties.correlationId,persistent: false});
 
         });
         //ch.ack(msg);