Skip to content

Commit 768fa00

Browse files
authored
Merge pull request #15 from hannesa2/FixNPE
Fixed NPE
2 parents fe771c0 + 455a5b1 commit 768fa00

File tree

1 file changed

+4
-5
lines changed
  • org.eclipse.paho.android.service/src/main/java/org/eclipse/paho/android/service

1 file changed

+4
-5
lines changed

org.eclipse.paho.android.service/src/main/java/org/eclipse/paho/android/service/MqttConnection.java

+4-5
Original file line numberDiff line numberDiff line change
@@ -176,11 +176,10 @@ public void connect(MqttConnectOptions options, String invocationContext, String
176176

177177
if (options != null) {
178178
cleanSession = options.isCleanSession();
179-
}
180-
181-
if (connectOptions.isCleanSession()) { // if it's a clean session,
182-
// discard old data
183-
service.messageStore.clearArrivedMessages(clientHandle);
179+
if (options.isCleanSession()) { // if it's a clean session,
180+
// discard old data
181+
service.messageStore.clearArrivedMessages(clientHandle);
182+
}
184183
}
185184

186185
service.traceDebug(TAG, "Connecting {" + serverURI + "} as {" + clientId + "}");

0 commit comments

Comments
 (0)