|
|
@ -36,12 +36,10 @@ public final class RelayHandler extends ChannelInboundHandlerAdapter {
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public void channelInactive(ChannelHandlerContext ctx) {
|
|
|
|
public void channelInactive(ChannelHandlerContext ctx) {
|
|
|
|
if (relayChannel.isActive()) {
|
|
|
|
|
|
|
|
if (relayChannel.isActive()) {
|
|
|
|
if (relayChannel.isActive()) {
|
|
|
|
relayChannel.writeAndFlush(Unpooled.EMPTY_BUFFER).addListener(ChannelFutureListener.CLOSE);
|
|
|
|
relayChannel.writeAndFlush(Unpooled.EMPTY_BUFFER).addListener(ChannelFutureListener.CLOSE);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Override
|
|
|
|
@Override
|
|
|
|
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
|
|
|
|
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
|
|
|
|