no message

modules/mogo-realtime/src/main/java/com/mogo/realtime/Imp/RealTimeDelegateManager.java

@@ -0,0 +1,37 @@
+package com.mogo.realtime.Imp;
+
+
+import com.elegant.spi.AbstractDelegateManager;
+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;
+
+    public static RealTimeDelegateManager getInstance() {
+        if (sInstance == null) {
+            synchronized (RealTimeDelegateManager.class) {
+                if (sInstance == null) {
+                    sInstance = new RealTimeDelegateManager();
+                }
+            }
+        }
+        return sInstance;
+    }
+
+    public RealTimeDelegateManager() {
+        loadDelegateClasses(MoGoAiCloudClient.getInstance().getContext(), RealTimeProvider.class, new DelegateListener<Class<? extends RealTimeProvider>>() {
+            @Override
+            public void onDelegate(String unit, Class<? extends RealTimeProvider> p) {
+                mRealTimeProvider = p;
+            }
+        });
+    }
+
+}