bootstrap.setOption("receiveBufferSizePredictorFactory", new FixedReceiveBufferSizePredictorFactory(8192));
bootstrap.setOption("child.receiveBufferSize", getRecvBufferSize());
return bootstrap;
}
@Override
<BUG>protected List<Pair<String, ? extends ChannelHandler>> getBaseChannelHandlers(MessageInput input) {

final List<Pair<String, ? extends ChannelHandler>> baseChannelHandlers = super.getBaseChannelHandlers(input);
baseChannelHandlers.add(Pair.of("connection-counter", connectionCounter));
</BUG>
return baseChannelHandlers;

bootstrap.setOption("receiveBufferSizePredictorFactory", new FixedReceiveBufferSizePredictorFactory(8192));
bootstrap.setOption("child.receiveBufferSize", getRecvBufferSize());
return bootstrap;
}
@Override
protected LinkedHashMap<String, Callable<? extends ChannelHandler>> getBaseChannelHandlers(
MessageInput input) {
final LinkedHashMap<String, Callable<? extends ChannelHandler>> baseChannelHandlers =
super.getBaseChannelHandlers(input);
baseChannelHandlers.put("connection-counter", Callables.returning(connectionCounter));
