SpringCloud/spring-cloud-stream
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix test

Browse Source
This commit is contained in:
Oleg Zhurakousky
2021-07-16 09:59:29 +02:00
parent dbe0d61e0f
commit e07c7e1b49
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java
View File

@@ -587,15 +587,15 @@ public class ImplicitFunctionBindingTests {
try (ConfigurableApplicationContext context = new SpringApplicationBuilder( try (ConfigurableApplicationContext context = new SpringApplicationBuilder(
TestChannelBinderConfiguration.getCompleteConfiguration(SupplierWithExplicitPollerConfiguration.class)) TestChannelBinderConfiguration.getCompleteConfiguration(SupplierWithExplicitPollerConfiguration.class))
.web(WebApplicationType.NONE).run("--spring.jmx.enabled=false", .web(WebApplicationType.NONE).run("--spring.jmx.enabled=false",
"--spring.cloud.stream.poller.fixed-delay=2000", "--spring.cloud.stream.poller.fixed-delay=1200",
"--spring.cloud.function.bindings.supplier-out-0=output")) { "--spring.cloud.function.bindings.supplier-out-0=output")) {
OutputDestination outputDestination = context.getBean(OutputDestination.class); OutputDestination outputDestination = context.getBean(OutputDestination.class);
PollerMetadata pollerMetadata = context.getBean(PollerMetadata.class); PollerMetadata pollerMetadata = context.getBean(PollerMetadata.class);
assertThat(((PeriodicTrigger) pollerMetadata.getTrigger()).getPeriod()).isEqualTo(2000); assertThat(((PeriodicTrigger) pollerMetadata.getTrigger()).getPeriod()).isEqualTo(1200);
Message<byte[]> outputMessage = outputDestination.receive(6000); Message<byte[]> outputMessage = outputDestination.receive(10000);
assertThat(outputMessage.getPayload()).isEqualTo("hello".getBytes()); assertThat(outputMessage.getPayload()).isEqualTo("hello".getBytes());
} }
} }