Skip to content

Commit

Permalink
fix: _storeProcessing staying true after outStore got emptied (#1492)
Browse files Browse the repository at this point in the history
Co-authored-by: Jan Willem Penterman <[email protected]>
Co-authored-by: Daniel Lando <[email protected]>
  • Loading branch information
3 people authored Jun 28, 2023
1 parent 8d68c8c commit f3f7be7
Showing 1 changed file with 2 additions and 1 deletion.
3 changes: 2 additions & 1 deletion lib/client.js
Original file line number Diff line number Diff line change
Expand Up @@ -1817,7 +1817,6 @@ MqttClient.prototype._onConnect = function (packet) {
if (!outStore) {
return
}
that._storeProcessing = true

const packet = outStore.read(1)

Expand All @@ -1829,6 +1828,8 @@ MqttClient.prototype._onConnect = function (packet) {
return
}

that._storeProcessing = true

// Skip already processed store packets
if (that._packetIdsDuringStoreProcessing[packet.messageId]) {
storeDeliver()
Expand Down

0 comments on commit f3f7be7

Please sign in to comment.