diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/Imp/RealTimeDelegateManager.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/Imp/RealTimeDelegateManager.java
index 8c4e603..7905ac6 100644
--- a/modules/mogo-realtime/src/main/java/com/mogo/realtime/Imp/RealTimeDelegateManager.java
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/Imp/RealTimeDelegateManager.java
@@ -6,13 +6,11 @@ import com.mogo.cloud.passport.MoGoAiCloudClient;
 import com.mogo.realtime.Interface.RealTimeProvider;
 
 /**
- * @author liujing
- * @description 描述
- * @since: 2021/1/25
+ *
  */
 class RealTimeDelegateManager extends AbstractDelegateManager<RealTimeProvider> {
     private static RealTimeDelegateManager sInstance = null;
-    private Class<? extends RealTimeProvider> mRealTimeProvider = null;
+    private RealTimeProvider mRealTimeProvider = null;
 
     public static RealTimeDelegateManager getInstance() {
         if (sInstance == null) {
@@ -26,12 +24,15 @@ class RealTimeDelegateManager extends AbstractDelegateManager<RealTimeProvider>
     }
 
     public RealTimeDelegateManager() {
-        loadDelegateClasses(MoGoAiCloudClient.getInstance().getContext(), RealTimeProvider.class, new DelegateListener<Class<? extends RealTimeProvider>>() {
+        loadDelegates(MoGoAiCloudClient.getInstance().getContext(), RealTimeProvider.class, new DelegateListener<RealTimeProvider>() {
             @Override
-            public void onDelegate(String unit, Class<? extends RealTimeProvider> p) {
+            public void onDelegate(String unit, RealTimeProvider p) {
                 mRealTimeProvider = p;
             }
         });
     }
 
+    public RealTimeProvider getRealTimeProvider(){
+        return mRealTimeProvider;
+    }
 }
diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/Imp/RealTimeProviderImp.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/Imp/RealTimeProviderImp.java
index 11aa066..08dd6f0 100644
--- a/modules/mogo-realtime/src/main/java/com/mogo/realtime/Imp/RealTimeProviderImp.java
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/Imp/RealTimeProviderImp.java
@@ -6,6 +6,7 @@ import com.mogo.cloud.socket.IMogoCloudSocketOnMessageListener;
 import com.mogo.realtime.Interface.RealTimeProvider;
 import com.mogo.realtime.entity.ADASRecognizedResult;
 import com.mogo.realtime.entity.CloudLocationInfo;
+import com.mogo.realtime.socket.IMogoCloudOnMsgListener;
 
 import java.util.List;
 
@@ -26,32 +27,19 @@ public class RealTimeProviderImp implements RealTimeProvider {
     }
 
     @Override
-    public float getDistanceBetweenTwoPoints() {
-        if (mDelegate != null) {
-            return mDelegate.getDistanceBetweenTwoPoints();
-        }
-        return 0;
+    public void registerOnMessageListener(IMogoCloudOnMsgListener listener) {
+
     }
 
     @Override
-    public void init(Context context, String appId) {
-        if (mDelegate != null) {
-            mDelegate.init(context, appId);
-        }
+    public void unRegisterOnMessageListener(IMogoCloudOnMsgListener listener) {
+
     }
 
     @Override
-    public void registerOnMessageListener(int msgType, IMogoCloudSocketOnMessageListener listener) {
-        if (mDelegate != null) {
-            mDelegate.registerOnMessageListener(msgType, listener);
-        }
+    public List<CloudLocationInfo> getLocationMsg(int msgId) {
+        return null;
     }
 
-    @Override
-    public void sendMsg(List list, IMogoCloudSocketOnMessageListener listener) {
-        if (mDelegate != null){
-            mDelegate.sendMsg(list,listener);
-        }
-    }
 
 }
diff --git a/modules/mogo-realtime/src/main/java/com/mogo/realtime/Interface/RealTimeProvider.java b/modules/mogo-realtime/src/main/java/com/mogo/realtime/Interface/RealTimeProvider.java
index c0aac9f..b497c1a 100644
--- a/modules/mogo-realtime/src/main/java/com/mogo/realtime/Interface/RealTimeProvider.java
+++ b/modules/mogo-realtime/src/main/java/com/mogo/realtime/Interface/RealTimeProvider.java
@@ -1,52 +1,39 @@
 package com.mogo.realtime.Interface;
 
-import android.content.Context;
-
-import com.mogo.cloud.socket.IMogoCloudSocketOnMessageListener;
 import com.mogo.realtime.entity.ADASRecognizedResult;
 import com.mogo.realtime.entity.CloudLocationInfo;
+import com.mogo.realtime.socket.IMogoCloudOnMsgListener;
 
 import java.util.List;
 
 /**
- * @author liujing
- * @description 描述
- * @since: 2021/1/21
+ *
  */
-public interface RealTimeProvider<T> {
+public interface RealTimeProvider {
+
     /**
      * 获取 adas 识别列表
-     *
-     * @return
      */
     List<ADASRecognizedResult> getLastADASRecognizedResult();
 
-    /*
-     * 两个点之间的距离
-     * */
-    float getDistanceBetweenTwoPoints();
-
-    /**
-     * 初始化
-     *
-     * @param context 上下文
-     * @param appId   一般为包名，不参与通道的建立，一般用于发消息
-     */
-    void init(Context context, String appId);
-
     /**
      * 注册消息监听
      *
-     * @param msgType  消息类型
      * @param listener 回调
      */
-    void registerOnMessageListener(int msgType, IMogoCloudSocketOnMessageListener listener);
+    void registerOnMessageListener(IMogoCloudOnMsgListener listener);
+
+    /**
+     * 取消消息监听
+     *
+     * @param listener 回调
+     */
+    void unRegisterOnMessageListener(IMogoCloudOnMsgListener listener);
 
     /**
      * 发送消息
      *
-     * @param list     消息体
-     * @param listener 回执监听
+     * @param msgId 发送消息ID
      */
-    public void sendMsg(List<CloudLocationInfo> list, IMogoCloudSocketOnMessageListener listener);
+    public List<CloudLocationInfo> getLocationMsg(int msgId);
 }