From d3cdbf19b53e24a1417364b098f7b8f71f36a208 Mon Sep 17 00:00:00 2001
From: wzy <wzy19931122ai@163.com>
Date: Sun, 28 Feb 2021 19:47:04 +0800
Subject: [PATCH] modify
---
src/main/java/com/xcong/excoin/netty/dispatch/MsgDispatch.java | 8 +++-----
1 files changed, 3 insertions(+), 5 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/netty/dispatch/MsgDispatch.java b/src/main/java/com/xcong/excoin/netty/dispatch/MsgDispatch.java
index 5471a7f..3241e3c 100644
--- a/src/main/java/com/xcong/excoin/netty/dispatch/MsgDispatch.java
+++ b/src/main/java/com/xcong/excoin/netty/dispatch/MsgDispatch.java
@@ -1,11 +1,9 @@
package com.xcong.excoin.netty.dispatch;
import com.alibaba.fastjson.JSONObject;
-import com.xcong.excoin.netty.bean.RequestBean;
-import com.xcong.excoin.netty.bean.SubRequest;
import com.xcong.excoin.netty.bean.SubResponse;
import com.xcong.excoin.netty.bean.UnSubResponse;
-import com.xcong.excoin.netty.common.ChannelManager;
+import com.xcong.excoin.netty.common.ServerChannelManager;
import com.xcong.excoin.netty.common.NettyTools;
import com.xcong.excoin.netty.logic.MsgLogic;
import io.netty.channel.ChannelHandlerContext;
@@ -41,7 +39,7 @@
return;
}
- ChannelManager.putSymbolSubChannel(split[1], ctx.channel(), split[2]);
+ ServerChannelManager.putSymbolSubChannel(split[1], ctx.channel(), split[2]);
SubResponse subResponse = new SubResponse();
subResponse.setSubbed(sub);
subResponse.setId(jsonObject.getString("id"));
@@ -56,7 +54,7 @@
return;
}
- ChannelManager.removeSymbolUnSubChannel(split[1], ctx.channel(), split[2]);
+ ServerChannelManager.removeSymbolUnSubChannel(split[1], ctx.channel(), split[2]);
UnSubResponse resp = new UnSubResponse();
resp.setSubbed(sub);
resp.setId(jsonObject.getString("id"));
--
Gitblit v1.9.1