Make sure DefaultAsyncTaskExecutor is started

flowable · Jun 11, 2024 · 03d8680 · 03d8680
1 parent 473fc25
commit 03d8680
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git a/...g-boot-autoconfigure/src/main/java/org/flowable/spring/boot/FlowableJobConfiguration.java b/...g-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;
     }
 
-}
+}
diff --git a/...c/test/java/org/flowable/test/spring/boot/process/ProcessEngineAutoConfigurationTest.java b/...c/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();
                             });
                 });
     }