We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents 240f82f + 96de362 commit 6d36f4bCopy full SHA for 6d36f4b
1 file changed
org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/ClientState.java
@@ -1366,8 +1366,12 @@ public void quiesce(long timeout) {
1366
// Quiesce time up or inflight messages delivered. Ensure pending delivery
1367
// vectors are cleared ready for disconnect to be sent as the final flow.
1368
synchronized (queueLock) {
1369
- pendingMessages.clear();
1370
- pendingFlows.clear();
+ if (pendingMessages != null) {
+ pendingMessages.clear();
1371
+ }
1372
+ if (pendingFlows != null) {
1373
+ pendingFlows.clear();
1374
1375
quiescing = false;
1376
actualInFlight = 0;
1377
}
0 commit comments