admin/vlv-ai-analytic-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修改消费线程数

Browse Source
This commit is contained in:
zren25
2025-04-27 15:30:55 +08:00
parent 04780a5a91
commit bafbfefeed
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/mq/AnalysisDifyMqConsumer.java
View File

@@ -38,7 +38,7 @@ import java.util.concurrent.CompletableFuture;
@RestController @RestController
@RocketMQMessageListener(topic = "${rocketmq.consumer.analysisDify.topic}",consumerGroup = "${rocketmq.consumer.analysisDify.group}", @RocketMQMessageListener(topic = "${rocketmq.consumer.analysisDify.topic}",consumerGroup = "${rocketmq.consumer.analysisDify.group}",
instanceName = "analysisDifyMqConsumer", instanceName = "analysisDifyMqConsumer",
consumeThreadNumber = 1, consumeThreadNumber = 20,
enableMsgTrace = true) enableMsgTrace = true)
public class AnalysisDifyMqConsumer implements RocketMQListener<MessageExt> { public class AnalysisDifyMqConsumer implements RocketMQListener<MessageExt> {