refactoring

pull/2776/head
Nikita Koksharov 5 years ago
parent becacb350a
commit 4c11f13e9b

@ -28,9 +28,9 @@ import java.util.regex.Pattern;
* @author Nikita Koksharov
*
*/
public class LoggingHandler extends ChannelDuplexHandler {
public class ErrorsLoggingHandler extends ChannelDuplexHandler {
private static final Logger log = LoggerFactory.getLogger(LoggingHandler.class);
private static final Logger log = LoggerFactory.getLogger(ErrorsLoggingHandler.class);
private static final Pattern IGNORABLE_ERROR_MESSAGE = Pattern.compile(
"^.*(?:connection.*(?:reset|closed|abort|broken)|broken.*pipe).*$", Pattern.CASE_INSENSITIVE);

@ -100,7 +100,7 @@ public class RedisChannelInitializer extends ChannelInitializer<Channel> {
ch.pipeline().addLast(new CommandPubSubDecoder(config.getExecutor(), config.isKeepPubSubOrder(), config.isDecodeInExecutor()));
}
ch.pipeline().addLast(new LoggingHandler());
ch.pipeline().addLast(new ErrorsLoggingHandler());
config.getNettyHook().afterChannelInitialization(ch);
}

Loading…
Cancel
Save