Fix IntegrationFlowTests for missed customTaskScheduler

Signed-off-by: Artem Bilan <artem.bilan@broadcom.com>
This commit is contained in:
Artem Bilan
2025-02-15 22:56:01 -05:00
committed by GitHub
parent cb85fe0f82
commit 479521a080

View File

@@ -192,6 +192,9 @@ public class IntegrationFlowTests {
@Autowired
AbstractEndpoint stringSupplierEndpoint;
@Autowired
TaskScheduler customTaskScheduler;
@Test
public void testWithSupplierMessageSourceImpliedPoller() {
assertThat(this.stringSupplierEndpoint.isAutoStartup()).isFalse();
@@ -596,6 +599,11 @@ public class IntegrationFlowTests {
return threadPoolTaskScheduler;
}
@Bean
public TaskScheduler customScheduler() {
return new SimpleAsyncTaskScheduler();
}
@Bean
public QueueChannelSpec suppliedChannel() {
return MessageChannels.queue(10);