Allow maximum reconnection delay to be configurable

Signed-off-by: Inderjeet Singh <inder123@gmail.com>
Signed-off-by: Inderjeet Singh <inder@peel.com>

Author: Inderjeet Singh

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/MqttAsyncClient.java

@@ -1512,7 +1512,7 @@ public void onSuccess(IMqttToken asyncActionToken) {
 		public void onFailure(IMqttToken asyncActionToken, Throwable exception) {
 			// @Trace 502=Automatic Reconnect failed, rescheduling: {0}
 			log.fine(CLASS_NAME, methodName, "502", new Object[] { asyncActionToken.getClient().getClientId() });
-			if (reconnectDelay < 128000) {
+			if (reconnectDelay < connOpts.getMaxReconnectDelay()) {
 				reconnectDelay = reconnectDelay * 2;
 			}
 			rescheduleReconnectCycle(reconnectDelay);

org.eclipse.paho.client.mqttv3/src/main/java/org/eclipse/paho/client/mqttv3/MqttConnectOptions.java

@@ -81,6 +81,7 @@ public class MqttConnectOptions {
 	private String[] serverURIs = null;
 	private int mqttVersion = MQTT_VERSION_DEFAULT;
 	private boolean automaticReconnect = false;
+	private int maxReconnectDelay = 128000;
 
 	/**
 	 * Constructs a new <code>MqttConnectOptions</code> object using the
@@ -133,6 +134,22 @@ public void setUserName(String userName) {
 		this.userName = userName;
 	}
 
+	/**
+	 * Get the maximum time (in millis) to wait between reconnects
+	 * @return Get the maximum time (in millis) to wait between reconnects
+	 */
+	public int getMaxReconnectDelay() {
+	    return maxReconnectDelay;
+	}
+
+	/**
+	 * Set the maximum time to wait between reconnects
+	 * @param maxReconnectDelay the duration (in millis)
+	 */
+	public void setMaxReconnectDelay(int maxReconnectDelay) {
+	    this.maxReconnectDelay = maxReconnectDelay;
+	}
+
 	/**
 	 * Sets the "Last Will and Testament" (LWT) for the connection.
 	 * In the event that this client unexpectedly loses its connection to the