From 67c021b8fe1eee235d779a29ec8c93b0ebe56e2c Mon Sep 17 00:00:00 2001 From: wangli <274027703@qq.com> Date: Thu, 21 Nov 2024 11:47:33 +0800 Subject: [PATCH] =?UTF-8?q?feat(REQ-3004)=20-=20=E7=A7=BB=E9=99=A4?= =?UTF-8?q?=E6=B5=8B=E8=AF=95=E6=97=B6=E7=9A=84=E7=BA=BF=E7=A8=8B=E9=99=90?= =?UTF-8?q?=E5=88=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../mq/inside/consumer/ElasticSearchBatchSyncListener.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java index 7cfc678b1..ed5e51cdf 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/mq/inside/consumer/ElasticSearchBatchSyncListener.java @@ -84,7 +84,7 @@ public class ElasticSearchBatchSyncListener { } return ConsumeConcurrentlyStatus.CONSUME_SUCCESS; }); - consumer.start(); +// consumer.start(); } private Boolean support(Event event) {