From bdb5ea4433f77c531912e7b4c2093bbff34abac5 Mon Sep 17 00:00:00 2001
From: puzhibing <393733352@qq.com>
Date: 星期六, 07 三月 2026 21:01:36 +0800
Subject: [PATCH] 添加模拟XPU推送消息接口
---
xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java | 15 ---------------
1 files changed, 0 insertions(+), 15 deletions(-)
diff --git a/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java b/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
index 7f2f951..279020b 100644
--- a/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
+++ b/xp-robotaxi-automatic-pilot-boot/src/main/java/com/xiaopeng/automaticPilot/controller/KafkaTestController.java
@@ -42,19 +42,4 @@
log.info("收到XPU上报低优先级主题消息: {}", message);
kafkaConsumerService.topicProdRobotaxiXpuNormal(message);
}
-
-
- /**
- * 模拟推送XPU消息
- * @param message
- * @return
- */
- @PostMapping("/base/v1/pushXPUMessage")
- public R pushXPUMessage(String message) {
- log.info("收到XPU推送消息: {}", message);
- kafkaConsumerService.topicProdRobotaxiXpuHigh(message);
- return R.ok();
- }
-
-
}
--
Gitblit v1.7.1