DATAMONGO-1631 - Polishing
Update Javadoc and test classes. Original Pull Request: #490
This commit is contained in:
@@ -18,10 +18,8 @@ package org.springframework.data.mongodb.config;
|
|||||||
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Bean;
|
||||||
import org.springframework.context.annotation.Configuration;
|
import org.springframework.context.annotation.Configuration;
|
||||||
import org.springframework.data.mongodb.ReactiveMongoDatabaseFactory;
|
import org.springframework.data.mongodb.ReactiveMongoDatabaseFactory;
|
||||||
import org.springframework.data.mongodb.core.MongoTemplate;
|
|
||||||
import org.springframework.data.mongodb.core.ReactiveMongoOperations;
|
import org.springframework.data.mongodb.core.ReactiveMongoOperations;
|
||||||
import org.springframework.data.mongodb.core.ReactiveMongoTemplate;
|
import org.springframework.data.mongodb.core.ReactiveMongoTemplate;
|
||||||
import org.springframework.data.mongodb.core.SimpleMongoDbFactory;
|
|
||||||
import org.springframework.data.mongodb.core.SimpleReactiveMongoDatabaseFactory;
|
import org.springframework.data.mongodb.core.SimpleReactiveMongoDatabaseFactory;
|
||||||
import org.springframework.data.mongodb.core.convert.MappingMongoConverter;
|
import org.springframework.data.mongodb.core.convert.MappingMongoConverter;
|
||||||
|
|
||||||
@@ -31,6 +29,7 @@ import com.mongodb.reactivestreams.client.MongoClient;
|
|||||||
* Base class for reactive Spring Data MongoDB configuration using JavaConfig.
|
* Base class for reactive Spring Data MongoDB configuration using JavaConfig.
|
||||||
*
|
*
|
||||||
* @author Mark Paluch
|
* @author Mark Paluch
|
||||||
|
* @author Christoph Strobl
|
||||||
* @since 2.0
|
* @since 2.0
|
||||||
* @see MongoConfigurationSupport
|
* @see MongoConfigurationSupport
|
||||||
*/
|
*/
|
||||||
@@ -38,17 +37,17 @@ import com.mongodb.reactivestreams.client.MongoClient;
|
|||||||
public abstract class AbstractReactiveMongoConfiguration extends MongoConfigurationSupport {
|
public abstract class AbstractReactiveMongoConfiguration extends MongoConfigurationSupport {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Return the Reactive Streams {@link MongoClient} instance to connect to. Annotate with {@link Bean} in case you want to expose a
|
* Return the Reactive Streams {@link MongoClient} instance to connect to. Annotate with {@link Bean} in case you want
|
||||||
* {@link MongoClient} instance to the {@link org.springframework.context.ApplicationContext}.
|
* to expose a {@link MongoClient} instance to the {@link org.springframework.context.ApplicationContext}.
|
||||||
*
|
*
|
||||||
* @return
|
* @return never {@literal null}.
|
||||||
*/
|
*/
|
||||||
public abstract MongoClient reactiveMongoClient();
|
public abstract MongoClient reactiveMongoClient();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a {@link ReactiveMongoTemplate}.
|
* Creates {@link ReactiveMongoOperations}.
|
||||||
*
|
*
|
||||||
* @return
|
* @return never {@literal null}.
|
||||||
*/
|
*/
|
||||||
@Bean
|
@Bean
|
||||||
public ReactiveMongoOperations reactiveMongoTemplate() throws Exception {
|
public ReactiveMongoOperations reactiveMongoTemplate() throws Exception {
|
||||||
@@ -56,12 +55,12 @@ public abstract class AbstractReactiveMongoConfiguration extends MongoConfigurat
|
|||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Creates a {@link SimpleMongoDbFactory} to be used by the {@link MongoTemplate}. Will use the {@link Mongo} instance
|
* Creates a {@link ReactiveMongoDatabaseFactory} to be used by the {@link ReactiveMongoOperations}. Will use the
|
||||||
* configured in {@link #reactiveMongoClient()}.
|
* {@link MongoClient} instance configured in {@link #reactiveMongoClient()}.
|
||||||
*
|
*
|
||||||
* @see #reactiveMongoClient()
|
* @see #reactiveMongoClient()
|
||||||
* @see #reactiveMongoTemplate()
|
* @see #reactiveMongoTemplate()
|
||||||
* @return
|
* @return never {@literal null}.
|
||||||
*/
|
*/
|
||||||
@Bean
|
@Bean
|
||||||
public ReactiveMongoDatabaseFactory reactiveMongoDbFactory() {
|
public ReactiveMongoDatabaseFactory reactiveMongoDbFactory() {
|
||||||
@@ -75,7 +74,7 @@ public abstract class AbstractReactiveMongoConfiguration extends MongoConfigurat
|
|||||||
* @see #customConversions()
|
* @see #customConversions()
|
||||||
* @see #mongoMappingContext()
|
* @see #mongoMappingContext()
|
||||||
* @see #reactiveMongoDbFactory()
|
* @see #reactiveMongoDbFactory()
|
||||||
* @return
|
* @return never {@literal null}.
|
||||||
* @throws Exception
|
* @throws Exception
|
||||||
*/
|
*/
|
||||||
@Bean
|
@Bean
|
||||||
|
|||||||
@@ -35,9 +35,10 @@ import com.mongodb.reactivestreams.client.MongoClients;
|
|||||||
* Integration tests for {@link AbstractReactiveMongoConfiguration}.
|
* Integration tests for {@link AbstractReactiveMongoConfiguration}.
|
||||||
*
|
*
|
||||||
* @author Mark Paluch
|
* @author Mark Paluch
|
||||||
|
* @author Christoph Strobl
|
||||||
*/
|
*/
|
||||||
@RunWith(SpringRunner.class)
|
@RunWith(SpringRunner.class)
|
||||||
@ContextConfiguration(classes = AbstractReactiveMongoConfigurationIntegrationTests.ReactiveConfiguration.class)
|
@ContextConfiguration
|
||||||
public class AbstractReactiveMongoConfigurationIntegrationTests {
|
public class AbstractReactiveMongoConfigurationIntegrationTests {
|
||||||
|
|
||||||
@Autowired ApplicationContext context;
|
@Autowired ApplicationContext context;
|
||||||
|
|||||||
@@ -34,14 +34,18 @@ import org.springframework.data.mongodb.config.AbstractReactiveMongoConfiguratio
|
|||||||
import org.springframework.data.mongodb.core.query.Collation;
|
import org.springframework.data.mongodb.core.query.Collation;
|
||||||
import org.springframework.data.mongodb.test.util.MongoVersionRule;
|
import org.springframework.data.mongodb.test.util.MongoVersionRule;
|
||||||
import org.springframework.data.util.Version;
|
import org.springframework.data.util.Version;
|
||||||
|
import org.springframework.test.context.ContextConfiguration;
|
||||||
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
|
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
|
||||||
|
|
||||||
|
import com.mongodb.reactivestreams.client.MongoClient;
|
||||||
import com.mongodb.reactivestreams.client.MongoClients;
|
import com.mongodb.reactivestreams.client.MongoClients;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @author Mark Paluch
|
* @author Mark Paluch
|
||||||
|
* @author Christoph Strobl
|
||||||
*/
|
*/
|
||||||
@RunWith(SpringJUnit4ClassRunner.class)
|
@RunWith(SpringJUnit4ClassRunner.class)
|
||||||
|
@ContextConfiguration
|
||||||
public class ReactiveMongoTemplateCollationTests {
|
public class ReactiveMongoTemplateCollationTests {
|
||||||
|
|
||||||
public static @ClassRule MongoVersionRule REQUIRES_AT_LEAST_3_4_0 = MongoVersionRule.atLeast(Version.parse("3.4.0"));
|
public static @ClassRule MongoVersionRule REQUIRES_AT_LEAST_3_4_0 = MongoVersionRule.atLeast(Version.parse("3.4.0"));
|
||||||
@@ -51,7 +55,7 @@ public class ReactiveMongoTemplateCollationTests {
|
|||||||
static class Config extends AbstractReactiveMongoConfiguration {
|
static class Config extends AbstractReactiveMongoConfiguration {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public com.mongodb.reactivestreams.client.MongoClient reactiveMongoClient() {
|
public MongoClient reactiveMongoClient() {
|
||||||
return MongoClients.create();
|
return MongoClients.create();
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user