wangli/workflow-engine
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(REQ-3004) - 移除测试时的线程限制

Browse Source
This commit is contained in:
wangli 2024-11-21 11:45:58 +08:00
parent de8da186a9
commit 88799743d9
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java
View File

@ -60,8 +60,8 @@ public class ElasticSearchBatchSyncListener {
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET); consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
consumer.subscribe(topic, "*"); consumer.subscribe(topic, "*");
consumer.setConsumeMessageBatchMaxSize(refreshProperties.getEsSyncBatchSize()); consumer.setConsumeMessageBatchMaxSize(refreshProperties.getEsSyncBatchSize());
consumer.setConsumeThreadMax(1); // consumer.setConsumeThreadMax(1);
consumer.setConsumeThreadMin(1); // consumer.setConsumeThreadMin(1);
consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> { consumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
log.warn("batch get msg size: {}", msgs.size()); log.warn("batch get msg size: {}", msgs.size());
if(CollectionUtils.isEmpty(msgs)) { if(CollectionUtils.isEmpty(msgs)) {