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

feat(REQ-3004) - 批量 ES 同步的逻辑中，精细化 tag

Browse Source
This commit is contained in:
wangli 2024-11-27 11:09:23 +08:00
parent 4e1bc80359
commit 753eb10c4c
2 changed files with 4 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/controller/web/bpmn/BpmnProcessActivityController.java
View File

@ -49,7 +49,8 @@ public class BpmnProcessActivityController extends BasicPopulateAvatarController
private BpmnProcessActivityService bpmnProcessActivityService; private BpmnProcessActivityService bpmnProcessActivityService;
/** /**
* 业务节点唤醒 旧版本使用的接口 * 业务节点唤醒
* 旧版本使用的接口, 建议使用 {@link BpmnProcessActivityController#trigger(BpmnActivityTriggerDTO)}
* *
* @param triggerId * @param triggerId
* @return * @return
@ -58,6 +59,7 @@ public class BpmnProcessActivityController extends BasicPopulateAvatarController
@GetMapping("/trigger") @GetMapping("/trigger")
@Override @Override
@RepeatSubmit @RepeatSubmit
@Deprecated
public CommonResponse<Boolean> trigger(@NotBlank(message = "触发 ID 不能为空") @RequestParam String triggerId) { public CommonResponse<Boolean> trigger(@NotBlank(message = "触发 ID 不能为空") @RequestParam String triggerId) {
log.info("业务节点唤醒 trigger2 ===>>>参数：{}", triggerId); log.info("业务节点唤醒 trigger2 ===>>>参数：{}", triggerId);
return trigger(new BpmnActivityTriggerDTO(triggerId, true)); return trigger(new BpmnActivityTriggerDTO(triggerId, true));

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

@ -58,7 +58,7 @@ public class ElasticSearchBatchSyncListener {
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(consumerGroup); DefaultMQPushConsumer consumer = new DefaultMQPushConsumer(consumerGroup);
consumer.setNamesrvAddr(rocketMQProperties.getNameServer()); consumer.setNamesrvAddr(rocketMQProperties.getNameServer());
consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET); consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);
consumer.subscribe(topic, "*"); consumer.subscribe(topic, ELASTIC_SEARCH_SYNC.getTag());
consumer.setConsumeMessageBatchMaxSize(refreshProperties.getEsSyncBatchSize()); consumer.setConsumeMessageBatchMaxSize(refreshProperties.getEsSyncBatchSize());
// consumer.setConsumeThreadMax(1); // consumer.setConsumeThreadMax(1);
// consumer.setConsumeThreadMin(1); // consumer.setConsumeThreadMin(1);