Check if packet is type 'publish'. Also, remove from the outgoing que…

…ue only when the client is not clean
moscajs · Apr 27, 2016 · 473a33f · 473a33f
1 parent 9d97374
commit 473a33f
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/client.js b/lib/client.js
@@ -75,11 +75,11 @@ function Client (broker, conn) {
   }
 
   this.deliverQoS = function deliverQoS (_packet, cb) {
-    var _toForward = _packet;
-    if(_packet.cmd === 'publish'){
+    var _toForward = _packet
+    if (_packet.cmd === 'publish') {
       _toForward = that.broker.authorizeForward(that, _packet)
       if (!_toForward) {
-        if(that.clean === false){
+        if (that.clean === false) {
           that.broker.persistence.outgoingClearMessageId(that, _packet, nop)
         }
         // we consider this to be an error, since the packet is undefined, so there's nothing to send