1

src/main/java/com/fdkankan/mqcontroller/service/impl/ScenePlusServiceImpl.java

@@ -41,7 +41,7 @@ public class ScenePlusServiceImpl extends ServiceImpl<IScenePlusMapper, ScenePlu
         }
         Long cameraId = scenePlus != null ? scenePlus.getCameraId() : scenePro.getCameraId();
 
-        List<MqQueueConfig> queueConfigList = queueConfigService.list();
+        List<MqQueueConfig> queueConfigList = queueConfigService.getByType(mqSendLog.getType());
         if(queueConfigList.isEmpty()){
             return null;
         }