From daebf0f7865b2a8ec715edf57783da942acdec67 Mon Sep 17 00:00:00 2001 From: Artem Bilan Date: Wed, 7 Apr 2021 12:02:02 -0400 Subject: [PATCH] Limit aggregator tests for 10 seconds to wait --- .../CustomPropsAndMongoMessageStoreAggregatorTests.java | 3 ++- .../cloud/fn/aggregator/DefaultAggregatorTests.java | 3 ++- .../GroupTimeOutAndGemfireMessageStoreAggregatorTests.java | 3 ++- .../cloud/fn/aggregator/JdbcMessageStoreAggregatorTests.java | 3 ++- .../cloud/fn/aggregator/RedisMessageStoreAggregatorTests.java | 3 ++- 5 files changed, 10 insertions(+), 5 deletions(-) diff --git a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/CustomPropsAndMongoMessageStoreAggregatorTests.java b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/CustomPropsAndMongoMessageStoreAggregatorTests.java index da961520..52921cfb 100644 --- a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/CustomPropsAndMongoMessageStoreAggregatorTests.java +++ b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/CustomPropsAndMongoMessageStoreAggregatorTests.java @@ -16,6 +16,7 @@ package org.springframework.cloud.fn.aggregator; +import java.time.Duration; import java.util.List; import org.junit.jupiter.api.Test; @@ -60,7 +61,7 @@ public class CustomPropsAndMongoMessageStoreAggregatorTests extends AbstractAggr .hasSize(1) .element(0).isEqualTo("foo")) .thenCancel() - .verify(); + .verify(Duration.ofSeconds(10)); assertThat(this.messageGroupStore).isInstanceOf(ConfigurableMongoDbMessageStore.class); assertThat(TestUtils.getPropertyValue(this.messageGroupStore, "collectionName")).isEqualTo("aggregatorTest"); diff --git a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java index 62cd1f7f..600bea57 100644 --- a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java +++ b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java @@ -16,6 +16,7 @@ package org.springframework.cloud.fn.aggregator; +import java.time.Duration; import java.util.List; import org.junit.jupiter.api.Test; @@ -59,7 +60,7 @@ public class DefaultAggregatorTests extends AbstractAggregatorFunctionTests { .hasSize(2) .contains("1", "2")) .thenCancel() - .verify(); + .verify(Duration.ofSeconds(10)); assertThat(this.messageGroupStore).isNull(); assertThat(this.aggregatingMessageHandler.getMessageStore()).isInstanceOf(SimpleMessageStore.class); diff --git a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/GroupTimeOutAndGemfireMessageStoreAggregatorTests.java b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/GroupTimeOutAndGemfireMessageStoreAggregatorTests.java index abdbfd61..87784b54 100644 --- a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/GroupTimeOutAndGemfireMessageStoreAggregatorTests.java +++ b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/GroupTimeOutAndGemfireMessageStoreAggregatorTests.java @@ -16,6 +16,7 @@ package org.springframework.cloud.fn.aggregator; +import java.time.Duration; import java.util.List; import org.junit.jupiter.api.Test; @@ -56,7 +57,7 @@ public class GroupTimeOutAndGemfireMessageStoreAggregatorTests extends AbstractA .hasSize(1) .contains("1")) .thenCancel() - .verify(); + .verify(Duration.ofSeconds(10)); assertThat(this.messageGroupStore).isInstanceOf(GemfireMessageStore.class); assertThat(this.aggregatingMessageHandler.getMessageStore()).isSameAs(this.messageGroupStore); diff --git a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/JdbcMessageStoreAggregatorTests.java b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/JdbcMessageStoreAggregatorTests.java index 6357489c..0b8e4d92 100644 --- a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/JdbcMessageStoreAggregatorTests.java +++ b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/JdbcMessageStoreAggregatorTests.java @@ -16,6 +16,7 @@ package org.springframework.cloud.fn.aggregator; +import java.time.Duration; import java.util.List; import org.junit.jupiter.api.Test; @@ -61,7 +62,7 @@ public class JdbcMessageStoreAggregatorTests extends AbstractAggregatorFunctionT .hasSize(2) .contains("1", "2")) .thenCancel() - .verify(); + .verify(Duration.ofSeconds(10)); assertThat(this.messageGroupStore).isInstanceOf(JdbcMessageStore.class); diff --git a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/RedisMessageStoreAggregatorTests.java b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/RedisMessageStoreAggregatorTests.java index e99a9fa6..c53f671a 100644 --- a/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/RedisMessageStoreAggregatorTests.java +++ b/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/RedisMessageStoreAggregatorTests.java @@ -16,6 +16,7 @@ package org.springframework.cloud.fn.aggregator; +import java.time.Duration; import java.util.List; import org.junit.jupiter.api.Disabled; @@ -63,7 +64,7 @@ public class RedisMessageStoreAggregatorTests extends AbstractAggregatorFunction .hasSize(2) .contains("1", "2")) .thenCancel() - .verify(); + .verify(Duration.ofSeconds(10)); assertThat(this.messageGroupStore).isInstanceOf(RedisMessageStore.class);