diff --git a/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java b/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java index 442c8ddb..343a7ed9 100644 --- a/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java +++ b/zc-business/src/main/java/com/zc/business/message/device/handler/DeviceMessageHandler.java @@ -533,10 +533,10 @@ public class DeviceMessageHandler { * @param msg 设备消息 */ private void oneStopDeviceMessageHandle(JSONObject msg) { - //kafka消息推送 - kafkaTopicProducer.KafkaTopicProducer(msg.toJSONString(), KafkEnum.surveyStation.value()); dcTrafficSectionDataService.processRealtimeOneStopMessage(msg); + //kafka消息推送 + kafkaTopicProducer.KafkaTopicProducer(msg.toJSONString(), KafkEnum.surveyStation.value()); }