diff --git a/rtsp_service_ws_kadian.py b/rtsp_service_ws_kadian.py
index a2d5631..525aca1 100644
--- a/rtsp_service_ws_kadian.py
+++ b/rtsp_service_ws_kadian.py
@@ -104,6 +104,7 @@ class RTSPCaptureWorker(threading.Thread):
                         "camera_id": self.camera_cfg.id,
                         "camera_name": self.camera_cfg.name,
                         "timestamp": time.time(),
+                        "camera_index": self.camera_cfg.index,
                         "frame": frame,
                     }
 
@@ -183,7 +184,7 @@ class RTSPService:
 
     def start(self):
         self.ws_sender.start()
-        self.processor.start()
+        self.biz_processor.start()
         for cam in self.cameras:
             w = RTSPCaptureWorker(cam, self.raw_queue, self.stop_event)
             w.start()
@@ -196,7 +197,7 @@ class RTSPService:
         self.ws_queue.join()
         for w in self.capture_workers:
             w.join(timeout=2.0)
-        self.processor.join(timeout=2.0)
+        self.biz_processor.join(timeout=2.0)
         self.ws_sender.join(timeout=2.0)
         logger.info("[INFO] Service stopped")