Skip to content

Commit 479521a

Browse files
authored
Fix IntegrationFlowTests for missed customTaskScheduler
Signed-off-by: Artem Bilan <[email protected]>
1 parent cb85fe0 commit 479521a

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

spring-integration-core/src/test/java/org/springframework/integration/dsl/flows/IntegrationFlowTests.java

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -192,6 +192,9 @@ public class IntegrationFlowTests {
192192
@Autowired
193193
AbstractEndpoint stringSupplierEndpoint;
194194

195+
@Autowired
196+
TaskScheduler customTaskScheduler;
197+
195198
@Test
196199
public void testWithSupplierMessageSourceImpliedPoller() {
197200
assertThat(this.stringSupplierEndpoint.isAutoStartup()).isFalse();
@@ -596,6 +599,11 @@ public TaskScheduler taskScheduler() {
596599
return threadPoolTaskScheduler;
597600
}
598601

602+
@Bean
603+
public TaskScheduler customScheduler() {
604+
return new SimpleAsyncTaskScheduler();
605+
}
606+
599607
@Bean
600608
public QueueChannelSpec suppliedChannel() {
601609
return MessageChannels.queue(10);

0 commit comments

Comments
 (0)