|
|
@ -78,7 +78,7 @@ public class PingConnectionHandler extends ChannelInboundHandlerAdapter {
|
|
|
|
if (future != null
|
|
|
|
if (future != null
|
|
|
|
&& (future.cancel(false) || !future.isSuccess())) {
|
|
|
|
&& (future.cancel(false) || !future.isSuccess())) {
|
|
|
|
ctx.channel().close();
|
|
|
|
ctx.channel().close();
|
|
|
|
if (future.cause() != null) {
|
|
|
|
if (future.cause() != null && !future.isCancelled()) {
|
|
|
|
log.error("Unable to send PING command over channel: " + ctx.channel(), future.cause());
|
|
|
|
log.error("Unable to send PING command over channel: " + ctx.channel(), future.cause());
|
|
|
|
}
|
|
|
|
}
|
|
|
|
log.debug("channel: {} closed due to PING response timeout set in {} ms", ctx.channel(), config.getPingConnectionInterval());
|
|
|
|
log.debug("channel: {} closed due to PING response timeout set in {} ms", ctx.channel(), config.getPingConnectionInterval());
|
|
|
|