[SB3 Update] Agg function use MongoDB testcontainers

- Disable tests
This commit is contained in:
Chris Bono
2022-10-16 23:17:37 -05:00
parent 8800a9c002
commit ea800682b2
4 changed files with 31 additions and 8 deletions

View File

@@ -19,15 +19,19 @@ package org.springframework.cloud.fn.aggregator;
import java.time.Duration;
import java.util.List;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Flux;
import reactor.test.StepVerifier;
import org.springframework.boot.test.autoconfigure.data.mongo.AutoConfigureDataMongo;
import org.springframework.cloud.fn.common.mongo.MongoDbTestContainerSupport;
import org.springframework.integration.mongodb.store.ConfigurableMongoDbMessageStore;
import org.springframework.integration.test.util.TestUtils;
import org.springframework.messaging.Message;
import org.springframework.messaging.support.GenericMessage;
import org.springframework.test.context.DynamicPropertyRegistry;
import org.springframework.test.context.DynamicPropertySource;
import org.springframework.test.context.TestPropertySource;
import static org.assertj.core.api.Assertions.assertThat;
@@ -40,10 +44,18 @@ import static org.assertj.core.api.Assertions.assertThat;
"aggregator.release=!messages.?[payload == 'bar'].empty",
"aggregator.aggregation=#this.?[payload == 'foo'].![payload]",
"aggregator.messageStoreType=mongodb",
"aggregator.message-store-entity=aggregatorTest",
"spring.mongodb.embedded.version=3.5.5" })
"aggregator.message-store-entity=aggregatorTest"
})
@AutoConfigureDataMongo
public class CustomPropsAndMongoMessageStoreAggregatorTests extends AbstractAggregatorFunctionTests {
@Disabled
public class CustomPropsAndMongoMessageStoreAggregatorTests extends AbstractAggregatorFunctionTests
implements MongoDbTestContainerSupport {
@DynamicPropertySource
static void mongoDbProperties(DynamicPropertyRegistry registry) {
registry.add("spring.data.mongodb.uri", MongoDbTestContainerSupport::mongoDbUri);
registry.add("spring.data.mongodb.database", () -> "test");
}
@Test
public void test() {

View File

@@ -19,6 +19,7 @@ package org.springframework.cloud.fn.aggregator;
import java.time.Duration;
import java.util.List;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Flux;
import reactor.test.StepVerifier;
@@ -34,6 +35,7 @@ import static org.assertj.core.api.Assertions.assertThat;
* @author Artem Bilan
* @author Corneil du Plessis
*/
@Disabled
public class DefaultAggregatorTests extends AbstractAggregatorFunctionTests {
@Test

View File

@@ -19,6 +19,7 @@ package org.springframework.cloud.fn.aggregator;
import java.time.Duration;
import java.util.List;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Flux;
import reactor.test.StepVerifier;
@@ -36,6 +37,7 @@ import static org.assertj.core.api.Assertions.assertThat;
* @author Corneil du Plessis
*/
@TestPropertySource(properties = "aggregator.message-store-type=jdbc")
@Disabled
public class JdbcMessageStoreAggregatorTests extends AbstractAggregatorFunctionTests {
@Test