MiniDay/hamster-ball
1
0
Fork 0
Code Issues Pull Requests Actions Releases 9 Activity

fix: 兼容 1.12.2 服务端

Browse Source
This commit is contained in:
叁只仓鼠
2022-10-31 12:27:19 +08:00
parent 2d381d2025
commit c21d63de5f
1 changed files with 9 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
hamster-ball-common/src/main/java/cn/hamster3/mc/plugin/ball/common/connector/BallKeepAliveHandler.java
View File

@@ -2,19 +2,23 @@ package cn.hamster3.mc.plugin.ball.common.connector;
import io.netty.channel.ChannelHandler; import io.netty.channel.ChannelHandler;
import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.SimpleUserEventChannelHandler; import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.handler.timeout.IdleStateEvent; import io.netty.handler.timeout.IdleStateEvent;
@ChannelHandler.Sharable @ChannelHandler.Sharable
public class BallKeepAliveHandler extends SimpleUserEventChannelHandler<IdleStateEvent> { public class BallKeepAliveHandler extends ChannelInboundHandlerAdapter {
public static final BallKeepAliveHandler INSTANCE = new BallKeepAliveHandler(); public static final BallKeepAliveHandler INSTANCE = new BallKeepAliveHandler();
private BallKeepAliveHandler() { private BallKeepAliveHandler() {
super(true); super();
} }
@Override @Override
protected void eventReceived(ChannelHandlerContext context, IdleStateEvent event) { public void userEventTriggered(ChannelHandlerContext context, Object event) throws Exception {
context.channel().writeAndFlush("ping"); if (event instanceof IdleStateEvent) {
context.channel().writeAndFlush("ping");
return;
}
super.userEventTriggered(context, event);
} }
} }