Commit ff9cdce9 by Future

注释回调

parent 6e657714
...@@ -164,14 +164,14 @@ public class NettyApiRequest { ...@@ -164,14 +164,14 @@ public class NettyApiRequest {
appUserChannelsService.online(client.getId(), jwtToken.getPlatform(), (NioSocketChannel) ctx.channel()); appUserChannelsService.online(client.getId(), jwtToken.getPlatform(), (NioSocketChannel) ctx.channel());
// 发布客户端在线状态变化事件 // 发布客户端在线状态变化事件
Long appId = app.getId(); // Long appId = app.getId();
String clientId = client.getClientId(); // String clientId = client.getClientId();
Integer platform = jwtToken.getPlatform(); // Integer platform = jwtToken.getPlatform();
long time = System.currentTimeMillis(); // long time = System.currentTimeMillis();
String clientIp = ctx.channel().remoteAddress().toString(); // String clientIp = ctx.channel().remoteAddress().toString();
ClientOnlineStatusChangeEvent clientOnlineStatusChangeEvent = new ClientOnlineStatusChangeEvent(appId, // ClientOnlineStatusChangeEvent clientOnlineStatusChangeEvent = new ClientOnlineStatusChangeEvent(appId,
clientId, 1, platform, time, clientIp); // clientId, 1, platform, time, clientIp);
eventPublisher.publishEvent(clientOnlineStatusChangeEvent); // eventPublisher.publishEvent(clientOnlineStatusChangeEvent);
//移除当前api处理handler, 不再参与长连接处理 //移除当前api处理handler, 不再参与长连接处理
ctx.pipeline().remove("SingleHttpRequestHandler"); ctx.pipeline().remove("SingleHttpRequestHandler");
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment