Ggtcf

I am new to netty and dont understand why server response is partially lost in my server. I have already read several questions posted, but i cant solve the problem.

I'm using netty 4.0.46 version.
The server must close the connection once it has sent all response data.
I'm using a SimpleChannelInboundHandler, and try to close the channel by using a ChannelFutureListener once the response is been sent.

public class AlbaranXMLServerHandler extends SimpleChannelInboundHandler<String> {
...
 @Override
 public void channelActive(ChannelHandlerContext ctx) throws Exception 
 String host = ((InetSocketAddress)ctx.channel().remoteAddress()).getAddress().getHostAddress();
 int port = ((InetSocketAddress)ctx.channel().remoteAddress()).getPort();
 logger.debug(String.format("Nueva conexión. host:%s port:%d", host, port));
 

@Override
public void channelRead0(ChannelHandlerContext ctx, String request)
 throws Exception 

 logger.info("Request received: " + request);
 .......

 logger.debug("XML Response: " + response); 

 ChannelFuture future = ctx.writeAndFlush(response);
 future.addListener(ChannelFutureListener.CLOSE);
 .......

When the response data (an XML string) are few, there is no problem, and the cliente receive the complete XML. But when it comes to a large XML file, the transmision gets interrupted, apparently when teh listener closes the channel.

The server log debug shows always the complete XML Ok.

Is there something i am missing about the way netty writes/closes the channel?

ChannelInitializer

public class AlbaranXMLServerInitializer extends ChannelInitializer<SocketChannel> 
......
 @Override
 public void initChannel(SocketChannel ch) throws Exception 
 ChannelPipeline pipeline = ch.pipeline();

 // Add the text line codec combination first,
 pipeline.addLast("framer", new FixedLengthFrameDecoder(AlbaranXMLServerHandler.TRAMA_PETICION_LONGITUD));
 // the encoder and decoder are static as these are sharable
 pipeline.addLast("decoder", DECODER);
 pipeline.addLast("encoder", ENCODER);

 // and then business logic.
 pipeline.addLast("handler", new AlbaranXMLServerHandler(rutaAlbaranes, autenticacionRFCService, albaranXMLRFCService, grupoSociedadesRFCService));
 

Server

 @Service 
public class AlbaranXMLServer extends SocketServerBase {
 logger.info("Inicializando el servicio " + this.getClass().getSimpleName() + " ...");

 bossGroup = new NioEventLoopGroup();
 workerGroup = new NioEventLoopGroup();

 try 
 ServerBootstrap b = new ServerBootstrap();
 b.group(bossGroup, workerGroup)
 .channel(NioServerSocketChannel.class)
 .childHandler(this.getChannelInitializer());

 Channel channel = b.bind(port).sync().channel();
 logger.info("Finalizada la inicialización del servicio " + this.getClass().getSimpleName());

 catch (Exception e) 
 logger.warn("Error al inicializar el servicio " + this.getClass().getSimpleName(), e);
 bossGroup.shutdownGracefully();
 workerGroup.shutdownGracefully();