diff --git a/spring-statemachine-core/src/test/java/org/springframework/statemachine/EventDeferTests.java b/spring-statemachine-core/src/test/java/org/springframework/statemachine/EventDeferTests.java index 396a9054..94e25a7c 100644 --- a/spring-statemachine-core/src/test/java/org/springframework/statemachine/EventDeferTests.java +++ b/spring-statemachine-core/src/test/java/org/springframework/statemachine/EventDeferTests.java @@ -121,7 +121,7 @@ public class EventDeferTests extends AbstractStateMachineTests { @Test public void testDeferWithSubsThreadExecutor() throws Exception { - context.register(Config1.class, ExecutorConfig.class); + context.register(Config1.class, ExecutorConfig2.class); context.refresh(); @SuppressWarnings("unchecked") StateMachine machine = context.getBean(StateMachineSystemConstants.DEFAULT_ID_STATEMACHINE, StateMachine.class); @@ -555,6 +555,19 @@ public class EventDeferTests extends AbstractStateMachineTests { } + @Configuration + static class ExecutorConfig2 { + + @Bean(name=StateMachineSystemConstants.TASK_EXECUTOR_BEAN_NAME) + public TaskExecutor taskExecutor() { + ThreadPoolTaskExecutor taskExecutor = new ThreadPoolTaskExecutor(); + taskExecutor.setCorePoolSize(1); + taskExecutor.setMaxPoolSize(4); + return taskExecutor; + } + + } + static class TestListener extends StateMachineListenerAdapter { volatile CountDownLatch stateChangedLatch = new CountDownLatch(1);