Просмотр исходного кода

全景图单张下载不打zip包

dengsixing 3 лет назад
Родитель
Сommit
f52b04e14d

+ 8 - 8
4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/BuildScenePreMQListener.java

@@ -36,14 +36,14 @@ import org.springframework.stereotype.Component;
  * @date 2022/2/23
  **/
 @Slf4j
-//@Component
-//@RocketMQMessageListener(
-//        consumerGroup = "${rocketmq.consumer.build-scene-pre-group}",
-//        topic = "${rocketmq.build-scene.topicName.topic-modeling-a-pre}",
-//        messageModel = MessageModel.CLUSTERING,//负载均衡模式
-//        consumeThreadMax = 10,
-//        consumeTimeout = 172801000L
-//)
+@Component
+@RocketMQMessageListener(
+        consumerGroup = "${rocketmq.consumer.build-scene-pre-group}",
+        topic = "${rocketmq.build-scene.topicName.topic-modeling-a-pre}",
+        messageModel = MessageModel.CLUSTERING,//负载均衡模式
+        consumeThreadMax = 10,
+        consumeTimeout = 172801000L
+)
 public class BuildScenePreMQListener implements RocketMQListener<String> {
 
 

+ 6 - 6
4dkankan-center-scene/src/main/java/com/fdkankan/scene/listener/BuildSceneResultMQListener.java

@@ -65,12 +65,12 @@ import org.springframework.transaction.annotation.Transactional;
  * @date 2022/2/23
  **/
 @Slf4j
-//@Component
-//@RocketMQMessageListener(
-//        consumerGroup = "${rocketmq.consumer.build-scene-result-group}",
-//        topic = "${rocketmq.build-scene-result.topicName.topic-modeling-a}",
-//        messageModel = MessageModel.CLUSTERING//负载均衡模式
-//)
+@Component
+@RocketMQMessageListener(
+        consumerGroup = "${rocketmq.consumer.build-scene-result-group}",
+        topic = "${rocketmq.build-scene-result.topicName.topic-modeling-a}",
+        messageModel = MessageModel.CLUSTERING//负载均衡模式
+)
 public class BuildSceneResultMQListener implements RocketMQListener<String> {
 
     @Value("${rocketmq.consumer.build-scene-result-group}")