yangyakun921/MoGoEagleEye
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix bug

Browse Source
This commit is contained in:
unknown
2020-10-27 10:11:09 +08:00
parent 0fe86044ea
commit 19c4859a71
2 changed files with 8 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
foudations/mogo-base-websocket-sdk/src/main/java/com/mogo/base/websocket/WebSocketManager.java
View File

@@ -72,11 +72,11 @@ public class WebSocketManager implements IMogoWebSocketManager, ISocketMsgSettin
@Override
public void registerOnWebSocketMessageListener(IMogoOnWebSocketMessageListener listener) {
if (listener.getType() == null) {
if (listener.getDownLinkType() == null) {
Logger.w(TAG, "websocket registerListener msgType is not exist");
return;
}
int msgType = listener.getType().getMsgType();
int msgType = listener.getDownLinkType().getMsgType();
if (mListeners.containsKey(msgType)) {
Logger.w(TAG, "websocket msgType %d is exist.", msgType);
}
@@ -92,11 +92,11 @@ public class WebSocketManager implements IMogoWebSocketManager, ISocketMsgSettin
if (listener == null) {
return;
}
if (listener.getType() == null) {
if (listener.getDownLinkType() == null) {
Logger.w(TAG, "websocket unregisterListener msgType is not exist");
return;
}
int msgType = listener.getType().getMsgType();
int msgType = listener.getDownLinkType().getMsgType();
if (!mListeners.containsKey(msgType)) {
return;
}
@@ -113,7 +113,7 @@ public class WebSocketManager implements IMogoWebSocketManager, ISocketMsgSettin
if (handlerThread != null) {
WebSocketData webSocketData = new WebSocketData();
webSocketData.setSeq(System.currentTimeMillis());
webSocketData.setMsgType(listener.getType().getMsgType());
webSocketData.setMsgType(listener.getUpLinkType().getMsgType());
webSocketData.setT(body);
handlerThread.sendMsg(new Gson().toJson(webSocketData));
}

4
services/mogo-service-api/src/main/java/com/mogo/service/connection/IMogoOnWebSocketMessageListener.java
View File

@@ -5,7 +5,9 @@ package com.mogo.service.connection;
*/
public interface IMogoOnWebSocketMessageListener< T > {
WebSocketMsgType getType();
WebSocketMsgType getDownLinkType();
WebSocketMsgType getUpLinkType();
default void onMsgReceived(T obj){