diff --git a/modules/mogo-module-extensions/src/main/java/com/mogo/module/extensions/utils/CameraLiveNoticeHelper.java b/modules/mogo-module-extensions/src/main/java/com/mogo/module/extensions/utils/CameraLiveNoticeHelper.java
index fbec2bd1a7..2449ff7ebf 100644
--- a/modules/mogo-module-extensions/src/main/java/com/mogo/module/extensions/utils/CameraLiveNoticeHelper.java
+++ b/modules/mogo-module-extensions/src/main/java/com/mogo/module/extensions/utils/CameraLiveNoticeHelper.java
@@ -3,8 +3,11 @@ package com.mogo.module.extensions.utils;
 import android.content.Context;
 import android.graphics.Bitmap;
 import android.graphics.BitmapFactory;
+import android.text.TextUtils;
+import android.util.Log;
 
 import com.mogo.commons.AbsMogoApplication;
+import com.mogo.commons.network.Utils;
 import com.mogo.map.marker.IMogoMarker;
 import com.mogo.map.marker.IMogoMarkerClickListener;
 import com.mogo.map.marker.MogoMarkerOptions;
@@ -18,6 +21,7 @@ import com.mogo.module.extensions.live.ExtensionServiceManager;
 import com.mogo.module.extensions.live.PushDataType;
 import com.mogo.service.connection.IMogoOnWebSocketMessageListener;
 import com.mogo.service.connection.WebSocketMsgType;
+import com.mogo.utils.UiThreadHandler;
 import com.mogo.utils.logger.Logger;
 
 
@@ -80,7 +84,7 @@ public class CameraLiveNoticeHelper implements IMogoOnWebSocketMessageListener<M
                         .getApis()
                         .getMapServiceApi()
                         .getMarkerManager(AbsMogoApplication.getApp())
-                        .addMarker(DataTypes.TYPE_MARKER_PUSH_DATA, options);
+                        .addMarker(PushDataType.TYPE_PUSH_CAMERA_DATA, options);
 
         ExtensionServiceManager.getMapService().getMarkerManager(mContext).addMarker(PushDataType.TYPE_PUSH_CAMERA_DATA, options);
     }
@@ -102,19 +106,28 @@ public class CameraLiveNoticeHelper implements IMogoOnWebSocketMessageListener<M
         return MogoSnapshotSetData.class;
     }
 
+    /**
+     *
+     * @param obj
+     */
     @Override
     public void onMsgReceived(MogoSnapshotSetData obj) {
-        Logger.d(TAG, "onMsgReceived cameralive : " + obj);
-        mCloudRoadData = obj.getTrafficLight();
-        if (mCloudRoadData != null) {
-            Logger.d(TAG, "onMsgReceived cameralive : ");
-            //添加marker TODO
-            addCameraMarker(mCloudRoadData);
+        Logger.d(TAG, "onMsgReceived  cameralive : " + obj);
+        if (obj != null) {
+            mCloudRoadData = obj.getCamera();
+            if (mCloudRoadData != null) {
+                Logger.d(TAG, "onMsgReceived getRtmpUrl = " + mCloudRoadData.getRtmpUrl());
+                //添加marker TODO
+                addCameraMarker(mCloudRoadData);
+            } else {
+                //删除marker TODO
+                UiThreadHandler.postDelayed( () -> {
+                    removeCameraMarker();
+                }, 2_000 );
 
+            }
         } else {
-            //删除marker TODO
-            removeCameraMarker();
-
+            Log.e(TAG, "onMsgReceived  obj == null ");
         }
     }
 
diff --git a/modules/mogo-module-v2x/src/main/java/com/mogo/module/v2x/scenario/scene/obu/OptimalSpeedMarker.java b/modules/mogo-module-v2x/src/main/java/com/mogo/module/v2x/scenario/scene/obu/OptimalSpeedMarker.java
index f0b34492f8..71213daba0 100644
--- a/modules/mogo-module-v2x/src/main/java/com/mogo/module/v2x/scenario/scene/obu/OptimalSpeedMarker.java
+++ b/modules/mogo-module-v2x/src/main/java/com/mogo/module/v2x/scenario/scene/obu/OptimalSpeedMarker.java
@@ -26,7 +26,9 @@ class OptimalSpeedMarker implements IV2XMarker<MogoLatLng> {
                 .latitude(entity.getLat())
                 .longitude(entity.getLon()).anchor(0.5f,0.9f).icon(ViewUtils.fromView(new OptimalSpeedMarkerView(V2XServiceManager.getContext())));
         optimalMarker = V2XServiceManager.getMarkerManager().addMarker(V2X_OPTIMAL_SPEED_MARKER, optionsRipple);
-        optimalMarker.setClickable(false);
+        if (optimalMarker != null) {
+            optimalMarker.setClickable(false);
+        }
     }
 
     @Override