[AMQ-7361] Active MQTT not closing the client connection

• Type: Bug
• Status: Open
• Priority: Major
• Resolution: Unresolved
• Affects Version/s: 5.15.9
• Component/s: AMQP
• Assignee: Unassigned
• Reporter: Nevadita
• Created: 09/Dec/19 09:38
• Updated: 09/Dec/19 09:38

Description

Hi ,

    I am trying to subscribe to a connect to a broker on remote server. The TCP hanshake passes but the client side ssl handshake fails. The exception is thrown but the tcp connection is not disconnected in this case. 

 

SSLNetworkModule extends TCPNetworkModule   this start function that is called internally

 

 public void start() throws IOException, MqttException { public void start() throws IOException, MqttException {

super.start(); setEnabledCiphers(enabledCiphers);

int soTimeout = socket.getSoTimeout(); // RTC 765: Set a timeout to avoid the SSL handshake being blocked indefinitely

socket.setSoTimeout(this.handshakeTimeoutSecs*1000);

((SSLSocket)socket).startHandshake();

if (hostnameVerifier != null) {     SSLSession session = ((SSLSocket)socket).getSession();     hostnameVerifier.verify(host, session); } // reset timeout to default value socket.setSoTimeout(soTimeout);    } 

 

 

Here the exception is thrown but the TCP connection is not closed.

 

This makes the Broker having a lot of connection in CLOSE_WAIT state.

 

Regards,

Nevadita