Spring/spring-data-examples
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

#254 - Use MongoProperties.getPort() to configure reactive MongoClient.

Browse Source 
Embedded MongoDB auto-configuration randomizes its port. Configuration happens during the creation of embeddedMongoServer so our MongoClient creation must be delayed until then.
This commit is contained in:
Mark Paluch
2017-01-27 13:57:57 +01:00
parent 605b90dc56
commit 4bae471837
1 changed files with 10 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
mongodb/reactive/src/main/java/example/springdata/mongodb/people/ApplicationConfiguration.java
View File

@@ -1,5 +1,5 @@
/*
* Copyright 2016 the original author or authors.
* Copyright 2016-2017 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -15,12 +15,16 @@
*/
package example.springdata.mongodb.people;
import lombok.RequiredArgsConstructor;
import org.springframework.boot.autoconfigure.AutoConfigureAfter;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.data.mongo.MongoDataAutoConfiguration;
import org.springframework.boot.autoconfigure.mongo.MongoAutoConfiguration;
import org.springframework.boot.autoconfigure.mongo.MongoProperties;
import org.springframework.boot.autoconfigure.mongo.embedded.EmbeddedMongoAutoConfiguration;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.DependsOn;
import org.springframework.data.mongodb.config.AbstractReactiveMongoConfiguration;
import org.springframework.data.mongodb.core.mapping.event.LoggingEventListener;
import org.springframework.data.mongodb.repository.config.EnableReactiveMongoRepositories;
@@ -37,8 +41,11 @@ import com.mongodb.reactivestreams.client.MongoClients;
@SpringBootApplication(exclude = { MongoAutoConfiguration.class, MongoDataAutoConfiguration.class })
@EnableReactiveMongoRepositories
@AutoConfigureAfter(EmbeddedMongoAutoConfiguration.class)
@RequiredArgsConstructor
class ApplicationConfiguration extends AbstractReactiveMongoConfiguration {
private final MongoProperties mongoProperties;
@Bean
public LoggingEventListener mongoEventListener() {
return new LoggingEventListener();
@@ -46,8 +53,9 @@ class ApplicationConfiguration extends AbstractReactiveMongoConfiguration {
@Override
@Bean
@DependsOn("embeddedMongoServer")
public MongoClient mongoClient() {
return MongoClients.create();
return MongoClients.create(String.format("mongodb://localhost:%d", mongoProperties.getPort()));
}
@Override