修改消费线程数

2025-04-28 14:52:25 +08:00
parent bafbfefeed
commit 96dec58d11
1 changed files with 1 additions and 1 deletions
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/AnalysisDifyMqConsumer.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/AnalysisDifyMqConsumer.java
@@ -38,7 +38,7 @@ import java.util.concurrent.CompletableFuture;
@RestController
@RocketMQMessageListener(topic = "${rocketmq.consumer.analysisDify.topic}",consumerGroup = "${rocketmq.consumer.analysisDify.group}",
 		instanceName = "analysisDifyMqConsumer",
-		consumeThreadNumber = 20,
+		consumeThreadNumber = 1,
 		enableMsgTrace = true)
 public class AnalysisDifyMqConsumer implements RocketMQListener<MessageExt>  {