fix: _storeProcessing staying true after outStore got emptied (#1492)

Co-authored-by: Jan Willem Penterman <janwillem@gingeros.ai> Co-authored-by: Daniel Lando <daniel.sorridi@gmail.com>
mqttjs · Jun 28, 2023 · f3f7be7 · f3f7be7
1 parent 8d68c8c
commit f3f7be7
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/lib/client.js b/lib/client.js
@@ -1817,7 +1817,6 @@ MqttClient.prototype._onConnect = function (packet) {
       if (!outStore) {
         return
       }
-      that._storeProcessing = true
 
       const packet = outStore.read(1)
 
@@ -1829,6 +1828,8 @@ MqttClient.prototype._onConnect = function (packet) {
         return
       }
 
+      that._storeProcessing = true
+
       // Skip already processed store packets
       if (that._packetIdsDuringStoreProcessing[packet.messageId]) {
         storeDeliver()