From 5def440949f47dd266ce3f07cd703afbc9be682a Mon Sep 17 00:00:00 2001 From: root Date: Tue, 26 Jan 2016 15:22:48 +0000 Subject: [PATCH] using newPacket instead of packet for publish --- lib/server.js | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/lib/server.js b/lib/server.js index fa4cdec..7c6db9a 100755 --- a/lib/server.js +++ b/lib/server.js @@ -344,22 +344,22 @@ Server.prototype.publish = function publish(packet, client, callback) { that.storePacket(newPacket, function() { if (that.closed) { - logger.debug({ packet: packet }, "not delivering because we are closed"); + logger.debug({ packet: newPacket }, "not delivering because we are closed"); return; } that.ascoltatore.publish( - packet.topic, - packet.payload, + newPacket.topic, + newPacket.payload, opts, function() { - that.published(packet, client, function() { - if( packet.topic.indexOf( '$SYS' ) >= 0 ) { - logger.trace({ packet: packet }, "published packet"); + that.published(newPacket, client, function() { + if( newPacket.topic.indexOf( '$SYS' ) >= 0 ) { + logger.trace({ packet: newPacket }, "published packet"); } else { - logger.debug({ packet: packet }, "published packet"); + logger.debug({ packet: newPacket }, "published packet"); } - that.emit("published", packet, client); + that.emit("published", newPacket, client); callback(); }); }