From 57816b1920c2cd3f2e7f28ba535b8efb302a2438 Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Fri, 16 Jul 2021 09:59:29 +0200 Subject: [PATCH] Fix test --- .../cloud/stream/function/ImplicitFunctionBindingTests.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java index f6cb11ac9..f2d77b0b9 100644 --- a/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java +++ b/spring-cloud-stream/src/test/java/org/springframework/cloud/stream/function/ImplicitFunctionBindingTests.java @@ -587,15 +587,15 @@ public class ImplicitFunctionBindingTests { try (ConfigurableApplicationContext context = new SpringApplicationBuilder( TestChannelBinderConfiguration.getCompleteConfiguration(SupplierWithExplicitPollerConfiguration.class)) .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")) { OutputDestination outputDestination = context.getBean(OutputDestination.class); PollerMetadata pollerMetadata = context.getBean(PollerMetadata.class); - assertThat(((PeriodicTrigger) pollerMetadata.getTrigger()).getPeriod()).isEqualTo(2000); + assertThat(((PeriodicTrigger) pollerMetadata.getTrigger()).getPeriod()).isEqualTo(1200); - Message outputMessage = outputDestination.receive(6000); + Message outputMessage = outputDestination.receive(10000); assertThat(outputMessage.getPayload()).isEqualTo("hello".getBytes()); } }