Fixed - additional check for blocking command added to PingConnectionHandler. #3107

pull/3118/head
Nikita Koksharov 4 years ago
parent 3adf683c48
commit d3d8c7830a

@ -75,6 +75,13 @@ public class PingConnectionHandler extends ChannelInboundHandlerAdapter {
if (connection.isClosed()) {
return;
}
CommandData<?, ?> commandData = connection.getCurrentCommand();
if (commandData != null && commandData.isBlockingCommand()) {
sendPing(ctx);
return;
}
if (future != null
&& (future.cancel(false) || !future.isSuccess())) {
ctx.channel().close();

Loading…
Cancel
Save