gitee
/
roses
mirror of https://gitee.com/stylefeng/roses
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

【7.1.5】修改会话消息中心

pull/22/head
fengshuonan 2021-10-11 09:44:15 +08:00
parent 763895e29c
commit 693c6b8986
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
kernel-d-socket/socket-business-websocket/src/main/java/cn/stylefeng/roses/kernel/socket/business/websocket/message/SocketMessageCenter.java
View File

@ -1,6 +1,7 @@
package cn.stylefeng.roses.kernel.socket.business.websocket.message; package cn.stylefeng.roses.kernel.socket.business.websocket.message;
import cn.stylefeng.roses.kernel.socket.api.message.SocketMsgCallbackInterface; import cn.stylefeng.roses.kernel.socket.api.message.SocketMsgCallbackInterface;
import java.util.HashMap; import java.util.HashMap;
import java.util.Map; import java.util.Map;
@ -17,7 +18,7 @@ public class SocketMessageCenter {
/** /**
* 所有消息监听器维护 * 所有消息监听器维护
*/ */
private static Map<String, SocketMsgCallbackInterface> messageListenerMap = new HashMap<>(); private static final Map<String, SocketMsgCallbackInterface> MESSAGE_LISTENER_MAP = new HashMap<>();
/** /**
* 设置消息类型的监听器 * 设置消息类型的监听器
@ -28,7 +29,7 @@ public class SocketMessageCenter {
* @date 2021/6/1 下午2:25 * @date 2021/6/1 下午2:25
**/ **/
public static void setMessageListener(String msgType, SocketMsgCallbackInterface listener) { public static void setMessageListener(String msgType, SocketMsgCallbackInterface listener) {
messageListenerMap.put(msgType, listener); MESSAGE_LISTENER_MAP.put(msgType, listener);
} }
/** /**
@ -40,6 +41,6 @@ public class SocketMessageCenter {
* @date 2021/6/1 下午2:26 * @date 2021/6/1 下午2:26
**/ **/
public static SocketMsgCallbackInterface getSocketMsgCallbackInterface(String msgType) { public static SocketMsgCallbackInterface getSocketMsgCallbackInterface(String msgType) {
return messageListenerMap.get(msgType); return MESSAGE_LISTENER_MAP.get(msgType);
} }
} }