Fix Bug 475639 - Added null checks

Signed-off-by: Dustin Thomson <dthomson@51systems.com>
eclipse · Aug 23, 2015 · 2e29c6f · 2e29c6f
1 parent 1191172
commit 2e29c6f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...org.eclipse.paho.android.service/src/org/eclipse/paho/android/service/MqttConnection.java b/...org.eclipse.paho.android.service/src/org/eclipse/paho/android/service/MqttConnection.java
@@ -414,7 +414,7 @@ void disconnect(long quiesceTimeout, String invocationContext,
 			service.callbackToActivity(clientHandle, Status.ERROR, resultBundle);
 		}
 
-		if (connectOptions.isCleanSession()) {
+		if (connectOptions != null && connectOptions.isCleanSession()) {
 			// assume we'll clear the stored messages at this point
 			service.messageStore.clearArrivedMessages(clientHandle);
 		}
@@ -457,7 +457,7 @@ void disconnect(String invocationContext, String activityToken) {
 			service.callbackToActivity(clientHandle, Status.ERROR, resultBundle);
 		}
 
-		if (connectOptions.isCleanSession()) {
+		if (connectOptions != null && connectOptions.isCleanSession()) {
 			// assume we'll clear the stored messages at this point
 			service.messageStore.clearArrivedMessages(clientHandle);
 		}