From 03d8680cab866a55fb144d9d2d2b4b0f08c2a21e Mon Sep 17 00:00:00 2001 From: "sven.rienstra" Date: Thu, 30 May 2024 08:36:49 +0200 Subject: [PATCH] Make sure DefaultAsyncTaskExecutor is started --- .../org/flowable/spring/boot/FlowableJobConfiguration.java | 6 ++++-- .../boot/process/ProcessEngineAutoConfigurationTest.java | 1 + 2 files changed, 5 insertions(+), 2 deletions(-) diff --git a/modules/flowable-spring-boot/flowable-spring-boot-starters/flowable-spring-boot-autoconfigure/src/main/java/org/flowable/spring/boot/FlowableJobConfiguration.java b/modules/flowable-spring-boot/flowable-spring-boot-starters/flowable-spring-boot-autoconfigure/src/main/java/org/flowable/spring/boot/FlowableJobConfiguration.java index 0f9489ef973..ea5de73002c 100644 --- a/modules/flowable-spring-boot/flowable-spring-boot-starters/flowable-spring-boot-autoconfigure/src/main/java/org/flowable/spring/boot/FlowableJobConfiguration.java +++ b/modules/flowable-spring-boot/flowable-spring-boot-starters/flowable-spring-boot-autoconfigure/src/main/java/org/flowable/spring/boot/FlowableJobConfiguration.java @@ -60,7 +60,9 @@ public AsyncTaskExecutorConfiguration flowableAsyncTaskInvokerTaskExecutorConfig public AsyncTaskExecutor flowableAsyncTaskInvokerTaskExecutor( @Qualifier("flowableAsyncTaskInvokerTaskExecutorConfiguration") AsyncTaskExecutorConfiguration executorConfiguration ) { - return new DefaultAsyncTaskExecutor(executorConfiguration); + DefaultAsyncTaskExecutor defaultAsyncTaskExecutor = new DefaultAsyncTaskExecutor(executorConfiguration); + defaultAsyncTaskExecutor.start(); + return defaultAsyncTaskExecutor; } -} \ No newline at end of file +} diff --git a/modules/flowable-spring-boot/flowable-spring-boot-starters/flowable-spring-boot-autoconfigure/src/test/java/org/flowable/test/spring/boot/process/ProcessEngineAutoConfigurationTest.java b/modules/flowable-spring-boot/flowable-spring-boot-starters/flowable-spring-boot-autoconfigure/src/test/java/org/flowable/test/spring/boot/process/ProcessEngineAutoConfigurationTest.java index 08b1c1536d8..98920de6ea4 100644 --- a/modules/flowable-spring-boot/flowable-spring-boot-starters/flowable-spring-boot-autoconfigure/src/test/java/org/flowable/test/spring/boot/process/ProcessEngineAutoConfigurationTest.java +++ b/modules/flowable-spring-boot/flowable-spring-boot-starters/flowable-spring-boot-autoconfigure/src/test/java/org/flowable/test/spring/boot/process/ProcessEngineAutoConfigurationTest.java @@ -608,6 +608,7 @@ void processEngineShouldUseSpringTaskExecutor() { assertThat(taskExecutor.getMaxPoolSize()).isEqualTo(8); assertThat(taskExecutor.getQueueSize()).isEqualTo(100); assertThat(taskExecutor.getThreadPoolNamingPattern()).isEqualTo("flowable-async-task-invoker-%d"); + assertThat(taskExecutor.submit(() -> true).join()).isTrue(); }); }); }