Removing assert from WebSocketFrame and changing the order of handleActionComplete to improve in-flight message handling

Signed-off-by: James Sutton <james.sutton@uk.ibm.com>

Author: jpwsutton

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

@@ -208,6 +208,12 @@ private void handleActionComplete(MqttToken token)
 		synchronized (token) {
 			// @TRACE 705=callback and notify for key={0}
 			log.fine(CLASS_NAME, methodName, "705",	new Object[] { token.internalTok.getKey() });
+			if (token.isComplete()) {
+				// Finish by doing any post processing such as delete 
+				// from persistent store but only do so if the action
+				// is complete
+				clientState.notifyComplete(token);
+			}
 
 			// Unblock any waiters and if pending complete now set completed
 			token.internalTok.notifyComplete();
@@ -232,12 +238,7 @@ private void handleActionComplete(MqttToken token)
  			}
 
 
-			if (token.isComplete()) {
-				// Finish by doing any post processing such as delete 
-				// from persistent store but only do so if the action
-				// is complete
-				clientState.notifyComplete(token);
-			}
+			
 		}
 	}
 

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/internal/websocket/WebSocketFrame.java

@@ -204,7 +204,6 @@ public byte[] encodeFrame(){
 	 */
 	public static void appendLengthAndMask(ByteBuffer buffer, int length, byte mask[]){
 		if(mask != null){
-			assert (mask.length ==4);
 			appendLength(buffer, length, true);
 			buffer.put(mask);
 		} else {