its-op-server/src/main/java/com/its/api/xnettcp/client/handler/NettyTcpClientOutboundHandler.java

package com.its.api.xnettcp.client.handler;

import io.netty.channel.*;

public class NettyTcpClientOutboundHandler extends ChannelOutboundHandlerAdapter {

    @Override
    public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) {
        promise.addListener(new ChannelFutureListener() {
            @Override
            public void operationComplete(ChannelFuture f) {
                if (!f.isSuccess()) {
                    f.cause().printStackTrace();
                    f.channel().close();
                }
            }
        });
    }

}