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

socket 修改实现

Browse Source
This commit is contained in:
lianglihui
2021-07-22 21:23:13 +08:00
parent 92c9a4bc0b
commit b9b8a863cc
2 changed files with 13 additions and 30 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
foudations/mogo-socket/src/main/java/com/mogo/cloud/socket/third/ThirdSocketManager.java
View File

@@ -20,7 +20,7 @@ import static com.mogo.cloud.socket.SocketServicesConstants.SOCKET_CHANNEL_ID;
import static com.mogo.cloud.socket.SocketServicesConstants.TAG;
import static com.mogo.cloud.socket.SocketServicesConstants.getEnvironment;
public class ThirdSocketManager extends ConnectionLifecycleListener implements Callback {
public class ThirdSocketManager implements Callback {
private static volatile ThirdSocketManager mInstance;
private final MoGoAiCloudClientConfig cloudClientConfig;
@@ -53,7 +53,7 @@ public class ThirdSocketManager extends ConnectionLifecycleListener implements C
.setAuthPubKey(cloudClientConfig.getAuthPubKey())
.setDebug(cloudClientConfig.isShowDebugLog());
SocketClient.getInstance().registerSocketCallback(this);
SocketClient.getInstance().registerSocketConnCallback(this);
// SocketClient.getInstance().registerSocketConnCallback(this);
SocketClient.getInstance().start(context);
}
@@ -89,24 +89,7 @@ public class ThirdSocketManager extends ConnectionLifecycleListener implements C
}
public void unregisterSocketConnCallback(ConnectionLifecycleListener listener){
SocketClient.getInstance().registerSocketConnCallback(listener);
SocketClient.getInstance().unregisterSocketConnCallback(listener);
}
@Override
public void onConnectLost(boolean reconnect) {
Logger.d(TAG,"ThirdSocketManager onConnectLost");
super.onConnectLost(reconnect);
}
@Override
public void onConnectFailure() {
Logger.d(TAG,"ThirdSocketManager onConnectFailure");
super.onConnectFailure();
}
@Override
public void onConnectSuccess() {
Logger.d(TAG,"ThirdSocketManager onConnectSuccess");
super.onConnectSuccess();
}
}