Support message buffering not only when reconnected but also before first connect (#354)

Signed-off-by: Masakazu Matsushita <matsukaz@gmail.com>

Author: matsukaz

org.eclipse.paho.client.mqttv3/src/main/java-templates/org/eclipse/paho/client/mqttv3/internal/ClientComms.java

@@ -186,8 +186,8 @@ public void sendNoWait(MqttWireMessage message, MqttToken token) throws MqttExce
 			} else {
 				this.internalSend(message, token);
 			}
-		} else if(disconnectedMessageBuffer != null && isResting()){
-			//@TRACE 508=Client Resting, Offline Buffer available. Adding message to buffer. message={0}
+		} else if(disconnectedMessageBuffer != null) {
+			//@TRACE 508=Offline Buffer available. Adding message to buffer. message={0}
 			log.fine(CLASS_NAME, methodName, "508", new Object[] {message.getKey()});
 			if(disconnectedMessageBuffer.isPersistBuffer()){
 				this.clientState.persistBufferedMessage(message);
@@ -832,13 +832,13 @@ public void deleteBufferedMessage(int bufferIndex){
 
 
 	/**
-	 * When the client automatically reconnects, we want to send all messages from the
+	 * When the client connects, we want to send all messages from the
 	 * buffer first before allowing the user to send any messages
 	 */
-	public void notifyReconnect() {
-		final String methodName = "notifyReconnect";
+	public void notifyConnect() {
+		final String methodName = "notifyConnect";
 		if(disconnectedMessageBuffer != null){
-			//@TRACE 509=Client Reconnected, Offline Buffer Available. Sending Buffered Messages.
+			//@TRACE 509=Client Connected, Offline Buffer Available. Sending Buffered Messages.
 			log.fine(CLASS_NAME, methodName, "509");
 
 			disconnectedMessageBuffer.setPublishCallback(new ReconnectDisconnectedBufferCallback(methodName));

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

@@ -92,9 +92,7 @@ public void onSuccess(IMqttToken token) {
     userToken.internalTok.notifyComplete();
     userToken.internalTok.setClient(this.client); // fix bug 469527 - maybe should be set elsewhere?
 
-    if(reconnect){
-		comms.notifyReconnect();
-    }
+	comms.notifyConnect();
 
     if (userCallback != null) {
       userToken.setUserContext(userContext);