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

Limit aggregator tests for 10 seconds to wait

Browse Source
This commit is contained in:
Artem Bilan
2021-04-07 12:02:02 -04:00
parent b2540806ab
commit bbf04eff2e
5 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
functions/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/CustomPropsAndMongoMessageStoreAggregatorTests.java
View File

@@ -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");

3
functions/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/DefaultAggregatorTests.java
View File

@@ -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);

3
functions/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/GroupTimeOutAndGemfireMessageStoreAggregatorTests.java
View File

@@ -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);

3
functions/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/JdbcMessageStoreAggregatorTests.java
View File

@@ -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);

3
functions/function/aggregator-function/src/test/java/org/springframework/cloud/fn/aggregator/RedisMessageStoreAggregatorTests.java
View File

@@ -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);