From 7607bab6e868a51609164ce111c9d5e1046cd11f Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Wed, 01 Sep 2021 14:44:00 +0800
Subject: [PATCH] 走航车实时websocket，小时表分表
---
screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java | 7 ++++---
1 files changed, 4 insertions(+), 3 deletions(-)
diff --git a/screen-manage/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java b/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java
similarity index 97%
rename from screen-manage/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java
rename to screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java
index 211b9f5..bc9db3d 100644
--- a/screen-manage/src/main/java/com/moral/api/kafka/consumer/KafkaConsumer.java
+++ b/screen-manage/src/main/java/com/moral/api/kafka/consumer/DeviceConsumer.java
@@ -22,10 +22,11 @@
import com.moral.constant.RedisConstants;
/*
- * ������������������
+ * ���������������������
* */
+@Component
@Slf4j
-public class KafkaConsumer {
+public class DeviceConsumer {
@Autowired
private HistoryMinutelyService historyMinutelyService;
@@ -148,7 +149,7 @@
}
//���������������������
- @KafkaListener(topics = KafkaConstants.UAV_TOPIC_SECOND, groupId = KafkaConstants.GROUP_INSERT, containerFactory = "kafkaListenerContainerFactory")
+ @KafkaListener(topics = KafkaConstants.UAV_TOPIC_SECOND, groupId = KafkaConstants.GROUP_INSERT, containerFactory = "insertListenerContainerFactory")
public void listenSecondSpecial(ConsumerRecord<String, String> record, Acknowledgment ack) {
String msg = record.value();
try {
--
Gitblit v1.8.0