Fix _storeProcessing staying true after outStore got emptied

mqttjs · Jun 8, 2022 · 463c023 · 463c023
1 parent 5c04ab4
commit 463c023
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/client.js b/lib/client.js
@@ -1806,7 +1806,6 @@ MqttClient.prototype._onConnect = function (packet) {
       if (!outStore) {
         return
       }
-      that._storeProcessing = true
 
       const packet = outStore.read(1)
 
@@ -1818,6 +1817,8 @@ MqttClient.prototype._onConnect = function (packet) {
         return
       }
 
+      that._storeProcessing = true
+
       // Skip already processed store packets
       if (that._packetIdsDuringStoreProcessing[packet.messageId]) {
         storeDeliver()