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) {