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

Restore embedded MongoDb tests

Browse Source
This commit is contained in:
Artem Bilan
2022-01-24 11:30:33 -05:00
parent f8d8f1d6df
commit e5222501c8
3 changed files with 6 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
functions/consumer/mongodb-consumer/src/test/java/org/springframework/cloud/fn/consumer/mongo/MongoDbConsumerApplicationTests.java
View File

@@ -23,7 +23,6 @@ import java.util.Map;
import java.util.function.Consumer;
import org.bson.Document;
import org.junit.jupiter.api.Disabled;
import org.junit.jupiter.api.Test;
import reactor.core.publisher.Flux;
import reactor.test.StepVerifier;
@@ -43,8 +42,8 @@ import static org.awaitility.Awaitility.await;
*/
@SpringBootTest(properties = {
"spring.data.mongodb.port=0",
"mongodb.consumer.collection=testing" })
@Disabled
"mongodb.consumer.collection=testing",
"spring.mongodb.embedded.version=latest" })
class MongoDbConsumerApplicationTests {
@Autowired
@@ -57,7 +56,6 @@ class MongoDbConsumerApplicationTests {
private ReactiveMongoTemplate mongoTemplate;
@Test
@Disabled
void testMongodbConsumer() {
Map<String, String> data1 = new HashMap<>();
data1.put("foo", "bar");

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

@@ -19,7 +19,6 @@ 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;
@@ -41,9 +40,9 @@ 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" })
"aggregator.message-store-entity=aggregatorTest",
"spring.mongodb.embedded.version=latest" })
@AutoConfigureDataMongo
@Disabled
public class CustomPropsAndMongoMessageStoreAggregatorTests extends AbstractAggregatorFunctionTests {
@Test

4
functions/supplier/mongodb-supplier/src/test/java/org/springframework/cloud/fn/supplier/mongo/MongodbSupplierApplicationTests.java
View File

@@ -43,9 +43,9 @@ import static org.assertj.core.api.Assertions.entry;
"spring.data.mongodb.port=0",
"mongodb.supplier.collection=testing",
"mongodb.supplier.query={ name: { $exists: true }}",
"mongodb.supplier.update-expression='{ $unset: { name: 0 } }'"
"mongodb.supplier.update-expression='{ $unset: { name: 0 } }'",
"spring.mongodb.embedded.version=latest"
})
@Disabled
class MongodbSupplierApplicationTests {
private ObjectMapper objectMapper = new ObjectMapper();