Hi,
I am writing a code in which i have used Active MQTT client with ssl.
The case in which my TCP connection is made and my Ssl handshake fails. The
serverside broker is left with many CLOSE_WAIT state connections. Do I need
to disconnect and close my client if exception this case occures.
Below is a sample snippet of my code:
private MqttClient client;
boolean connectSubscriber() throws Exception {
MqttSmpClient.logger.info("MqttSmpClient.connectSubscriber :
Connect
subscriber");
if (client != null && !client.isConnected()) {
try {
client.connect(mqttOptions);
MqttSmpClient.logger.info("MqttSmpClient.connectSubscriber : Subscriber
connected for clientId {}",
clientId);
mqttServiceListener.onConnectivityChange(MqttServiceListener.CONNECTED);
} catch (final Exception exc) {
MqttSmpClient.logger.error("MqttSmpClient.connectSubscriber : Mqtt
connection failed. Retrying : {}",
exc.getMessage());
MqttSmpClient.logger.debug("MqttSmpClient.connectSubscriber : Mqtt
connection failed. Retrying : ",
exc);
*
client.disconnect();
client.close();
*
throw exc;
}
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html