From ae8ef482773ac518a9a2bb9d284eac3f20347345 Mon Sep 17 00:00:00 2001 From: wangli Date: Fri, 24 May 2024 00:12:11 +0800 Subject: [PATCH] =?UTF-8?q?update(REQ-2324)=20-=20=E8=A7=A3=E5=86=B3=20MQ?= =?UTF-8?q?=20=E5=8F=91=E9=80=81=E6=96=B9=E4=B8=A2=E6=B6=88=E6=81=AF?= =?UTF-8?q?=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../core/common/event/MqLogListener.java | 12 +++++++----- .../core/conf/RocketMqEventConfiguration.java | 18 +++++++----------- .../listener/EngineAsyncJobEventListener.java | 2 +- .../listener/EngineTaskEventListener.java | 2 +- ...InternalExtAxTaskInstEvent_lo_Listener.java | 2 ++ .../core/repository/entity/ExtAxMqLog.java | 8 ++++++++ .../RocketMqBpmActivityEventListener.java | 2 ++ .../ApproveErrorReporterEventListener.java | 2 ++ .../error/ErrorReporterEventListener.java | 2 ++ .../RocketMqMessagePushEventListener.java | 2 ++ .../MessagePushProcessEventListener.java | 2 ++ .../RocketMqBpmnProcessEventListener.java | 2 ++ .../task/AutoOperatorEvent_101_Listener.java | 2 ++ .../MessagePushTaskEvent_103_Listener.java | 2 ++ .../RocketMqBpmnTaskEvent_102_Listener.java | 2 ++ ...SnapshotBpmnTaskTaskEvent_100_Listener.java | 2 ++ .../src/main/resources/logback-spring.xml | 7 +++++-- 17 files changed, 51 insertions(+), 20 deletions(-) diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/common/event/MqLogListener.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/common/event/MqLogListener.java index 02839e93d..8a9b6be6c 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/common/event/MqLogListener.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/common/event/MqLogListener.java @@ -3,10 +3,10 @@ package cn.axzo.workflow.core.common.event; import cn.axzo.workflow.core.conf.SupportRefreshProperties; import cn.axzo.workflow.core.repository.entity.ExtAxMqLog; import cn.axzo.workflow.core.service.ExtAxMqLogService; +import cn.hutool.json.JSONUtil; import lombok.SneakyThrows; import lombok.extern.slf4j.Slf4j; import org.springframework.context.ApplicationListener; -import org.springframework.scheduling.annotation.Async; import org.springframework.stereotype.Component; import javax.annotation.Resource; @@ -29,7 +29,6 @@ public class MqLogListener implements ApplicationListener { @SneakyThrows @Override - @Async public void onApplicationEvent(MqLogEvent event) { log.info("receive mq log event"); if (!refreshProperties.getMqLogEnable()) { @@ -62,17 +61,20 @@ public class MqLogListener implements ApplicationListener { } private void delete(ExtAxMqLog event) { - log.info("delete mq log"); + log.info("delete mq log, event: {}", JSONUtil.toJsonStr(event)); + event.setDeleteThreadName(Thread.currentThread().getName()); mqLogService.delete(event); } private void update(ExtAxMqLog event) { - log.info("update mq log"); + log.info("update mq log, event: {}", JSONUtil.toJsonStr(event)); + event.setUpdateThreadName(Thread.currentThread().getName()); mqLogService.update(event); } private void insert(ExtAxMqLog event) { - log.info("insert mq log"); + log.info("insert mq log, event: {}", JSONUtil.toJsonStr(event)); + event.setInsertThreadName(Thread.currentThread().getName()); mqLogService.insert(event); } diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/RocketMqEventConfiguration.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/RocketMqEventConfiguration.java index 4c3bc4365..8e9b5b706 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/RocketMqEventConfiguration.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/conf/RocketMqEventConfiguration.java @@ -27,7 +27,6 @@ import java.util.function.BiConsumer; import java.util.function.Consumer; import static cn.axzo.framework.rocketmq.RocketMQEventProducer.MQ_MESSAGE_ID; -import static cn.axzo.workflow.common.constant.BpmnConstants.MQ_UNIQUE_ID; /** * RocketMQ 全局配置 @@ -83,13 +82,12 @@ public class RocketMqEventConfiguration { */ private BiConsumer> getSendBeforeCallback() { return (event, context) -> { - String uniqueId = IdUtil.fastSimpleUUID(); - context.getHeaders().put(MQ_UNIQUE_ID, uniqueId); - MqLogEvent mqLogEvent = new MqLogEvent(uniqueId, null, + event.setEventId(IdUtil.simpleUUID()); + MqLogEvent mqLogEvent = new MqLogEvent(event.getEventId(), null, event.getEventName(), event.getShardingKey(), event.toPrettyJsonString(), TraceUtils.getOrCreateTraceId(), MqLogEventType.INSERT); - log.info("mq_send_Before: {}", event.getShardingKey()); + log.info("mq_send_Before: {}, uniqueId: {}", event.getShardingKey(), event.getEventId()); applicationEventPublisher.publishEvent(mqLogEvent); }; } @@ -103,13 +101,12 @@ public class RocketMqEventConfiguration { */ private BiConsumer> getSendAfterCallback() { return (event, context) -> { - String uniqueId = context.getHeaders().get(MQ_UNIQUE_ID); String messageId = context.getHeaders().get(MQ_MESSAGE_ID); - MqLogEvent mqLogEvent = new MqLogEvent(uniqueId, messageId, + MqLogEvent mqLogEvent = new MqLogEvent(event.getEventId(), messageId, event.getEventName(), event.getShardingKey(), event.toPrettyJsonString(), TraceUtils.getOrCreateTraceId(), MqLogEventType.UPDATE); - log.info("mq_send_callback: {}", event.getShardingKey()); + log.info("mq_send_after: {}, uniqueId: {}, messageId: {}", event.getShardingKey(), event.getEventId(), messageId); applicationEventPublisher.publishEvent(mqLogEvent); }; } @@ -123,11 +120,10 @@ public class RocketMqEventConfiguration { */ private BiConsumer> getTransactionRollbackHandler() { return (event, context) -> { - String uniqueId = context.getHeaders().get(MQ_UNIQUE_ID); - MqLogEvent mqLog = new MqLogEvent(uniqueId, null, event.getEventName(), + MqLogEvent mqLog = new MqLogEvent(event.getEventId(), null, event.getEventName(), event.getShardingKey(), event.toPrettyJsonString(), TraceUtils.getOrCreateTraceId(), MqLogEventType.DELETE); - log.info("mq_transaction_rollback: {}", event.getShardingKey()); + log.info("mq_transaction_rollback: {}, uniqueId: {}", event.getShardingKey(), event.getEventId()); applicationEventPublisher.publishEvent(mqLog); }; } diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineAsyncJobEventListener.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineAsyncJobEventListener.java index bbaba72dc..9862b016a 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineAsyncJobEventListener.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineAsyncJobEventListener.java @@ -55,7 +55,7 @@ public class EngineAsyncJobEventListener extends AbstractFlowableEngineEventList }); } stopWatch.stop(); - log.info("StopWatch '" + stopWatch.getLastTaskName() + "': running time = " + stopWatch.getTotalTimeSeconds()); + log.info("StopWatch '{}': running time = {} 's", stopWatch.getLastTaskName(), stopWatch.getTotalTimeSeconds()); } private List getOrderedListeners() { diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineTaskEventListener.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineTaskEventListener.java index e2117c2ca..6bf3bdc56 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineTaskEventListener.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/engine/listener/EngineTaskEventListener.java @@ -58,7 +58,7 @@ public class EngineTaskEventListener implements TaskListener { } }); stopWatch.stop(); - log.info("StopWatch '" + stopWatch.getLastTaskName() + "': running time = " + stopWatch.getTotalTimeSeconds() + " s, processInstanceId:{}", delegateTask.getProcessInstanceId()); + log.info("StopWatch '{}': running time = {} 's, processInstanceId:{}", stopWatch.getLastTaskName(), stopWatch.getTotalTimeSeconds(), delegateTask.getProcessInstanceId()); } diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/InternalExtAxTaskInstEvent_lo_Listener.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/InternalExtAxTaskInstEvent_lo_Listener.java index 89793bf85..e34dd85fc 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/InternalExtAxTaskInstEvent_lo_Listener.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/listener/impl/InternalExtAxTaskInstEvent_lo_Listener.java @@ -14,6 +14,7 @@ import org.flowable.engine.RuntimeService; import org.flowable.engine.impl.cfg.ProcessEngineConfigurationImpl; import org.flowable.engine.impl.util.CommandContextUtil; import org.flowable.task.service.delegate.DelegateTask; +import org.springframework.context.annotation.Scope; import org.springframework.stereotype.Component; import java.util.Objects; @@ -33,6 +34,7 @@ import static cn.axzo.workflow.common.enums.BpmnProcessInstanceResultEnum.PROCES */ @Slf4j @Component +@Scope("prototype") @AllArgsConstructor public class InternalExtAxTaskInstEvent_lo_Listener extends AbstractBpmnEventListener implements BpmnTaskEventListener { private final RuntimeService runtimeService; diff --git a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/repository/entity/ExtAxMqLog.java b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/repository/entity/ExtAxMqLog.java index deccb599c..731a6cc3b 100644 --- a/workflow-engine-core/src/main/java/cn/axzo/workflow/core/repository/entity/ExtAxMqLog.java +++ b/workflow-engine-core/src/main/java/cn/axzo/workflow/core/repository/entity/ExtAxMqLog.java @@ -46,4 +46,12 @@ public class ExtAxMqLog extends BaseEntity { * 链路追踪ID */ private String traceId; + + /** + * 线程名称 + */ + private String insertThreadName; + private String updateThreadName; + private String deleteThreadName; } + diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java index e2d540004..1da62614e 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/activity/RocketMqBpmActivityEventListener.java @@ -21,6 +21,7 @@ import org.flowable.engine.delegate.DelegateExecution; import org.flowable.engine.impl.persistence.entity.ExecutionEntityImpl; import org.flowable.engine.runtime.ProcessInstance; import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Scope; import org.springframework.core.Ordered; import org.springframework.stereotype.Component; import org.springframework.util.CollectionUtils; @@ -50,6 +51,7 @@ import static cn.axzo.workflow.common.enums.ProcessActivityEventEnum.PROCESS_ACT */ @Slf4j @Component +@Scope("prototype") public class RocketMqBpmActivityEventListener extends AbstractBpmnEventListener implements BpmnActivityEventListener, Ordered { @Resource private RuntimeService runtimeService; diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ApproveErrorReporterEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ApproveErrorReporterEventListener.java index ae6fb6c83..baa6462d1 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ApproveErrorReporterEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ApproveErrorReporterEventListener.java @@ -20,6 +20,7 @@ import org.flowable.engine.impl.cfg.ProcessEngineConfigurationImpl; import org.flowable.engine.impl.util.CommandContextUtil; import org.flowable.engine.impl.util.ProcessDefinitionUtil; import org.flowable.job.api.JobInfo; +import org.springframework.context.annotation.Scope; import org.springframework.stereotype.Component; import java.util.Arrays; @@ -37,6 +38,7 @@ import static org.flowable.common.engine.api.delegate.event.FlowableEngineEventT */ @Slf4j @Component +@Scope("prototype") public class ApproveErrorReporterEventListener implements BpmnAsyncJobEventListener { private final List IGNORE_ERROR_CODES = Arrays.asList( diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ErrorReporterEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ErrorReporterEventListener.java index 508632156..2fa624d0a 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ErrorReporterEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/error/ErrorReporterEventListener.java @@ -9,6 +9,7 @@ import org.flowable.common.engine.api.delegate.event.FlowableEvent; import org.flowable.common.engine.impl.event.FlowableEntityExceptionEventImpl; import org.flowable.job.api.JobInfo; import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Scope; import org.springframework.stereotype.Component; import java.util.Objects; @@ -23,6 +24,7 @@ import static org.flowable.common.engine.api.delegate.event.FlowableEngineEventT */ @Slf4j @Component +@Scope("prototype") public class ErrorReporterEventListener implements BpmnAsyncJobEventListener { @Value("${spring.profiles.active}") private String profile; diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java index d20bcdc54..02a26656c 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/notice/RocketMqMessagePushEventListener.java @@ -25,6 +25,7 @@ import org.flowable.engine.impl.util.CommandContextUtil; import org.flowable.engine.impl.util.ProcessDefinitionUtil; import org.flowable.task.api.history.HistoricTaskInstance; import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Scope; import org.springframework.core.Ordered; import org.springframework.stereotype.Component; import org.springframework.util.CollectionUtils; @@ -87,6 +88,7 @@ import static cn.axzo.workflow.common.enums.ProcessMessagePushEventEnum.PROCESS_ */ @Slf4j @Component +@Scope("prototype") public class RocketMqMessagePushEventListener extends AbstractBpmnEventListener implements BpmnMessagePushEventListener, Ordered { @Resource private EventProducer eventProducer; diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/MessagePushProcessEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/MessagePushProcessEventListener.java index b8665cfe5..81cc92bb9 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/MessagePushProcessEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/MessagePushProcessEventListener.java @@ -19,6 +19,7 @@ import org.flowable.engine.impl.util.CommandContextUtil; import org.flowable.engine.impl.util.ProcessDefinitionUtil; import org.springframework.beans.factory.annotation.Value; import org.springframework.cloud.context.config.annotation.RefreshScope; +import org.springframework.context.annotation.Scope; import org.springframework.core.Ordered; import org.springframework.stereotype.Component; import org.springframework.util.StringUtils; @@ -34,6 +35,7 @@ import java.util.Optional; */ @Slf4j @Component +@Scope("prototype") @RefreshScope public class MessagePushProcessEventListener extends AbstractBpmnEventListener implements BpmnProcessEventListener, Ordered { @Value("${workflow.carbonCopyTemplateCode}") diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java index 4f0c7bd52..8fb08ab17 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/process/RocketMqBpmnProcessEventListener.java @@ -20,6 +20,7 @@ import org.flowable.engine.delegate.event.impl.FlowableProcessCancelledEventImpl import org.flowable.engine.impl.persistence.entity.ExecutionEntityImpl; import org.flowable.engine.repository.Deployment; import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Scope; import org.springframework.core.Ordered; import org.springframework.stereotype.Component; @@ -46,6 +47,7 @@ import static cn.axzo.workflow.common.enums.ProcessInstanceEventEnum.PROCESS_INS */ @Slf4j @Component +@Scope("prototype") public class RocketMqBpmnProcessEventListener extends AbstractBpmnEventListener implements BpmnProcessEventListener, Ordered { @Resource private RuntimeService runtimeService; diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/AutoOperatorEvent_101_Listener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/AutoOperatorEvent_101_Listener.java index 10bf64b2a..3cd6dcb90 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/AutoOperatorEvent_101_Listener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/AutoOperatorEvent_101_Listener.java @@ -31,6 +31,7 @@ import org.flowable.engine.impl.util.CommandContextUtil; import org.flowable.job.service.JobService; import org.flowable.job.service.impl.persistence.entity.JobEntity; import org.flowable.task.service.delegate.DelegateTask; +import org.springframework.context.annotation.Scope; import org.springframework.core.Ordered; import org.springframework.stereotype.Component; import org.springframework.util.StringUtils; @@ -67,6 +68,7 @@ import static cn.axzo.workflow.core.common.enums.BpmnProcessTaskResultEnum.REJEC */ @Slf4j @Component +@Scope("prototype") @AllArgsConstructor public class AutoOperatorEvent_101_Listener extends AbstractBpmnEventListener implements BpmnTaskEventListener, Ordered { @Override diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/MessagePushTaskEvent_103_Listener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/MessagePushTaskEvent_103_Listener.java index ab80d51ea..8af0e6153 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/MessagePushTaskEvent_103_Listener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/MessagePushTaskEvent_103_Listener.java @@ -24,6 +24,7 @@ import org.flowable.engine.impl.util.CommandContextUtil; import org.flowable.engine.impl.util.ProcessDefinitionUtil; import org.flowable.engine.runtime.ProcessInstance; import org.flowable.task.service.delegate.DelegateTask; +import org.springframework.context.annotation.Scope; import org.springframework.core.Ordered; import org.springframework.stereotype.Component; import org.springframework.util.CollectionUtils; @@ -50,6 +51,7 @@ import static cn.axzo.workflow.core.engine.event.BizSpecifyAssigneeEventType.ADD */ @Slf4j @Component +@Scope("prototype") @AllArgsConstructor public class MessagePushTaskEvent_103_Listener extends AbstractBpmnEventListener implements BpmnTaskEventListener, Ordered { @Override diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEvent_102_Listener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEvent_102_Listener.java index 0938886a6..355dbd01d 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEvent_102_Listener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/RocketMqBpmnTaskEvent_102_Listener.java @@ -17,6 +17,7 @@ import org.flowable.engine.repository.Deployment; import org.flowable.engine.runtime.ProcessInstance; import org.flowable.task.service.delegate.DelegateTask; import org.springframework.beans.factory.annotation.Value; +import org.springframework.context.annotation.Scope; import org.springframework.core.Ordered; import org.springframework.stereotype.Component; import org.springframework.util.StringUtils; @@ -43,6 +44,7 @@ import static cn.axzo.workflow.common.enums.ProcessTaskEventEnum.PROCESS_TASK_DE */ @Slf4j @Component +@Scope("prototype") public class RocketMqBpmnTaskEvent_102_Listener extends AbstractBpmnEventListener implements BpmnTaskEventListener, Ordered { @Override public int getOrder() { diff --git a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/SnapshotBpmnTaskTaskEvent_100_Listener.java b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/SnapshotBpmnTaskTaskEvent_100_Listener.java index ff80b7d8f..962ed5a95 100644 --- a/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/SnapshotBpmnTaskTaskEvent_100_Listener.java +++ b/workflow-engine-server/src/main/java/cn/axzo/workflow/server/controller/listener/task/SnapshotBpmnTaskTaskEvent_100_Listener.java @@ -10,6 +10,7 @@ import org.apache.commons.collections4.ListUtils; import org.flowable.engine.RuntimeService; import org.flowable.engine.TaskService; import org.flowable.task.service.delegate.DelegateTask; +import org.springframework.context.annotation.Scope; import org.springframework.core.Ordered; import org.springframework.stereotype.Component; @@ -31,6 +32,7 @@ import static cn.axzo.workflow.common.constant.BpmnConstants.INTERNAL_TASK_RELAT */ @Slf4j @Component +@Scope("prototype") @AllArgsConstructor public class SnapshotBpmnTaskTaskEvent_100_Listener extends AbstractBpmnEventListener implements BpmnTaskEventListener, Ordered { @Override diff --git a/workflow-engine-server/src/main/resources/logback-spring.xml b/workflow-engine-server/src/main/resources/logback-spring.xml index 17a324393..e56446467 100644 --- a/workflow-engine-server/src/main/resources/logback-spring.xml +++ b/workflow-engine-server/src/main/resources/logback-spring.xml @@ -1,9 +1,12 @@ + - + + + - \ No newline at end of file +