"\n         Client ID    = " + clientId);
this.mqttAsyncClient = null;
this.mqttClientOptions = new MqttConnectOptions();
this.mqttCallback = callback;
}
<BUG>public void connect(boolean autoRetry) throws MqttException {

final String METHOD = "connect";
boolean tryAgain = true;</BUG>
int connectAttempts = 0;

"\n         Client ID    = " + clientId);
this.mqttAsyncClient = null;
this.mqttClientOptions = new MqttConnectOptions();
this.mqttCallback = callback;
}
public void connect(int numberOfRetryAttempts) throws MqttException {
final String METHOD = "connect";
if(mqttAsyncClient != null && mqttAsyncClient.isConnected()) {
LoggerUtility.log(Level.WARNING, CLASS_NAME, METHOD, "Client is already connected");
return;
}
boolean tryAgain = true;
int connectAttempts = 0;
