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

feat(REQ-3004) - 优化 ES 同步的逻辑

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

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

@ -75,9 +75,9 @@ public class ElasticSearchBatchSyncListener {
if (support(event)) { if (support(event)) {
String processInstanceId = event.normalizedData(String.class); String processInstanceId = event.normalizedData(String.class);
idSet.add(processInstanceId); idSet.add(processInstanceId);
log.info("batch sync es processIds: {}", processInstanceId);
} }
} }
log.warn("deduplication ids size: {}", idSet.size());
idSet.forEach(this::sync); idSet.forEach(this::sync);
} catch (Exception e) { } catch (Exception e) {
return ConsumeConcurrentlyStatus.RECONSUME_LATER; return ConsumeConcurrentlyStatus.RECONSUME_LATER;