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

changed msgType of websocket

Browse Source
This commit is contained in:
unknown
2020-10-26 16:14:34 +08:00
parent e3f303c2ca
commit 319cadb930
3 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -21,7 +21,7 @@ import java.util.List;
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
import static com.mogo.service.connection.WebSocketMsgType.MSG_TYPE_SERVER;
import static com.mogo.service.connection.WebSocketMsgType.MSG_TYPE_DOWNLINK_CAR_DATA;
@Keep
public class WebSocketManager implements IMogoWebSocketManager, ISocketMsgSetting, ISocketMsgCallBack {
@@ -136,7 +136,7 @@ public class WebSocketManager implements IMogoWebSocketManager, ISocketMsgSettin
int msgType = webSocketData.getMsgType();
Logger.d(TAG, "websocket received msg type = %d", msgType);
//服务端下发数据返回，上传数据回执默认不返回
if (msgType == MSG_TYPE_SERVER.getMsgType()) {
if (msgType == MSG_TYPE_DOWNLINK_CAR_DATA.getMsgType()) {
List<IMogoOnWebSocketMessageListener> listeners = mListeners.get(msgType);
if (listeners != null && !listeners.isEmpty()) {
Iterator<IMogoOnWebSocketMessageListener> iterator = listeners.iterator();

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

@@ -7,7 +7,11 @@ public interface IMogoOnWebSocketMessageListener< T > {
WebSocketMsgType getType();
void onMsgReceived(T obj);
default void onMsgReceived(T obj){
void onError(String errorMsg);
}
default void onError(String errorMsg){
}
}

5
services/mogo-service-api/src/main/java/com/mogo/service/connection/WebSocketMsgType.java
View File

@@ -2,9 +2,8 @@ package com.mogo.service.connection;
public enum WebSocketMsgType {
MSG_TYPE_SELF(0,"自车数据"),
MSG_TYPE_ADAS(1,"ADAS数据"),
MSG_TYPE_SERVER(2,"服务端下发车辆信息");
MSG_TYPE_UPLINK_CAR_DATA(0,"自车与ADAS数据"),
MSG_TYPE_DOWNLINK_CAR_DATA(1,"服务端下发车辆信息");
private int msgType;
private String msg;