update - 添加流程执行树日志输出配置

This commit is contained in:
yangqicheng 2024-05-15 16:59:20 +08:00
parent cfc935de7e
commit cdc58d8ba4

View File

@ -17,6 +17,7 @@ import org.flowable.job.service.JobProcessor;
import org.flowable.spring.SpringProcessEngineConfiguration; import org.flowable.spring.SpringProcessEngineConfiguration;
import org.flowable.spring.boot.EngineConfigurationConfigurer; import org.flowable.spring.boot.EngineConfigurationConfigurer;
import org.springframework.beans.factory.ObjectProvider; import org.springframework.beans.factory.ObjectProvider;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration; import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate;
@ -34,6 +35,9 @@ import static org.flowable.common.engine.impl.AbstractEngineConfiguration.DB_SCH
@Configuration @Configuration
public class FlowableConfiguration { public class FlowableConfiguration {
@Value("${workflow.enableVerboseExecutionTreeLogging:false}")
private Boolean enableVerboseExecutionTreeLogging;
@Bean @Bean
public EngineConfigurationConfigurer<SpringProcessEngineConfiguration> processEngineConfigurer( public EngineConfigurationConfigurer<SpringProcessEngineConfiguration> processEngineConfigurer(
ObjectProvider<FlowableEventListener> listeners, ObjectProvider<FlowableEventListener> listeners,
@ -62,6 +66,7 @@ public class FlowableConfiguration {
configuration.setDefaultFailedJobWaitTime(30); configuration.setDefaultFailedJobWaitTime(30);
configuration.setAsyncFailedJobWaitTime(30); configuration.setAsyncFailedJobWaitTime(30);
configuration.setAddDefaultExceptionHandler(false); configuration.setAddDefaultExceptionHandler(false);
configuration.setEnableVerboseExecutionTreeLogging(enableVerboseExecutionTreeLogging);
configuration.setCustomAsyncRunnableExecutionExceptionHandlers(Lists.newArrayList( configuration.setCustomAsyncRunnableExecutionExceptionHandlers(Lists.newArrayList(
new CustomAsyncJobLogClearTraceExceptionHandler(), new CustomAsyncJobLogClearTraceExceptionHandler(),
new CustomAsyncRunnableExceptionExceptionHandler())); new CustomAsyncRunnableExceptionExceptionHandler()));