buffer alloc

jobworker/lib/memstore.js

@@ -25,7 +25,7 @@ memstore.prototype.getItem = function(k,cb)
     if(!err && v){
       if(typeof v == 'object' && v.type == 'Buffer')
       {
-        value = new Buffer.from(v.data);
+        value = Buffer.from(v.data);
       }else{
         value = JSON.parse(v);
       }

storage-service/lib/dataevent.js

@@ -29,7 +29,7 @@ module.exports.newdata = function(prm,cb){
                 var msg = JSON.stringify(objMsg);
 
                 ch.assertExchange(ex, 'topic', {durable: false});
-                ch.publish(ex, key, new Buffer(msg));
+                ch.publish(ex, key, Buffer.from(msg));
                 //console.log("[AMQP] Sent %s:'%s'", key, msg);
             }
         });