Missed part of #330 fix

Author: Ian Craggs

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/CommsSender.java

@@ -67,7 +67,11 @@ public void start(String threadName, ExecutorService executorService) {
 		synchronized (lifecycle) {
 			if (!running) {
 				running = true;
-				senderFuture = executorService.submit(this);
+				if (executorService == null) {
+					new Thread(this).start();
+				} else {
+					senderFuture = executorService.submit(this);
+				}
 			}
 		}
 	}
@@ -85,7 +89,6 @@ public void stop() {
 			//@TRACE 800=stopping sender
 			log.fine(CLASS_NAME,methodName,"800");
 			if (running) {
-				running = false;
 				if (!Thread.currentThread().equals(sendThread)) {
 					try {
 						while (running) {
@@ -99,6 +102,7 @@ public void stop() {
 						runningSemaphore.release();
 					}
 				}
+				running = false;
 			}
 			sendThread=null;
 			//@TRACE 801=stopped
@@ -187,4 +191,8 @@ private void handleRunException(MqttWireMessage message, Exception ex) {
 		running = false;
 		clientComms.shutdownConnection(null, mex);
 	}
+
+	public boolean isRunning() {
+		return running;
+	}
 }