Skip to content

Commit d30154a

Browse files
authored
Merge pull request #107 from rhuan080/master
Created a constant to mongo server prefix.
2 parents 300d689 + 60fd492 commit d30154a

File tree

1 file changed

+15
-2
lines changed

1 file changed

+15
-2
lines changed

mongodb-driver/src/main/java/org/jnosql/diana/mongodb/document/MongoDBDocumentConfiguration.java

Lines changed: 15 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -44,8 +44,11 @@ public class MongoDBDocumentConfiguration implements DocumentConfiguration<Mongo
4444

4545
private static final String FILE_CONFIGURATION = "diana-mongodb.properties";
4646

47+
private static final String PREFIX_SERVER_HOST = "mongodb-server-host-";
48+
4749
static final int DEFAULT_PORT = 27017;
4850

51+
4952
/**
5053
* Creates a {@link MongoDBDocumentCollectionManagerFactory} from map configurations
5154
*
@@ -55,7 +58,7 @@ public class MongoDBDocumentConfiguration implements DocumentConfiguration<Mongo
5558
*/
5659
public MongoDBDocumentCollectionManagerFactory get(Map<String, String> configurations) throws NullPointerException {
5760
requireNonNull(configurations, "configurations is required");
58-
List<ServerAddress> servers = configurations.keySet().stream().filter(s -> s.startsWith("mongodb-server-host-"))
61+
List<ServerAddress> servers = configurations.keySet().stream().filter(s -> s.startsWith(PREFIX_SERVER_HOST))
5962
.map(configurations::get).map(HostPortConfiguration::new)
6063
.map(HostPortConfiguration::toServerAddress).collect(Collectors.toList());
6164
if (servers.isEmpty()) {
@@ -100,6 +103,16 @@ public MongoDBDocumentCollectionManagerFactory get(Settings settings) throws Nul
100103
return get(configurations);
101104
}
102105

106+
@Override
107+
public MongoDBDocumentCollectionManagerFactory get(String pathFileConfig) throws NullPointerException {
108+
requireNonNull(pathFileConfig, "settings is required");
109+
110+
Map<String, String> configuration = ConfigurationReader.from(pathFileConfig);
111+
return get(configurations);
112+
}
113+
114+
115+
103116
@Override
104117
public MongoDBDocumentCollectionManagerAsyncFactory getAsync() {
105118
Map<String, String> configurations = ConfigurationReader.from(FILE_CONFIGURATION);
@@ -131,7 +144,7 @@ public MongoDBDocumentCollectionManagerAsyncFactory getAsync(com.mongodb.async.c
131144

132145

133146
private MongoDBDocumentCollectionManagerAsyncFactory getAsync(Map<String, String> configurations) {
134-
List<ServerAddress> servers = configurations.keySet().stream().filter(s -> s.startsWith("mongodb-server-host-"))
147+
List<ServerAddress> servers = configurations.keySet().stream().filter(s -> s.startsWith(PREFIX_SERVER_HOST))
135148
.map(configurations::get).map(HostPortConfiguration::new)
136149
.map(HostPortConfiguration::toServerAddress).collect(Collectors.toList());
137150
if (servers.isEmpty()) {

0 commit comments

Comments
 (0)