Feature/mongo pool config

CHANGELOG.md

@@ -26,6 +26,7 @@
 * Logging improvement and extension options for DaemonMessageListener
 * Add TLS server parameters for JAX-RS
 * Improved Errormessage in case of non parseable JSON strings in the space of InterconnectObjects and Messsaging.
+* Add connection pool settings and idle timeout to MongoDB client configuration
 
 
 # 1.37

mongodb/README.md

@@ -20,6 +20,9 @@ For connections to real MongoDB databases, these extra properties can be set:
 * `mongodb.uri` - instead of host and port you can specify the complete connection string
 * `mongodb.sockettimeout` - the socket timeout of the connection (default: 10 seconds)
 * `mongodb.connecttimeout` - the connection timeout of the connection attempt (default: 10 seconds)
+* `mongodb.maxConnectionIdleTime` - the maximum idle time for pooled connections in milliseconds (default: 600000 / 10 minutes)
+* `mongodb.minPoolSize` - the minimum number of connections in the connection pool (default: 10)
+* `mongodb.maxPoolSize` - the maximum number of connections in the connection pool (default: 100)
 
 ### Access to database
 

mongodb/src/main/java/de/taimos/dvalin/mongo/config/RealClientConfig.java

@@ -25,6 +25,7 @@
 import com.mongodb.MongoClientSettings.Builder;
 import com.mongodb.client.MongoClient;
 import com.mongodb.client.MongoClients;
+import de.taimos.daemon.DaemonStarter;
 import de.taimos.daemon.spring.conditional.OnSystemProperty;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.context.annotation.Bean;
@@ -51,17 +52,33 @@ public class RealClientConfig {
     @Value("${mongodb.connecttimeout:${mongodb.connectTimeout:10000}}")
     private int connectTimeout;
 
+    @Value("${mongodb.maxConnectionIdleTime:600000}")
+    private int maxConnectionIdleTime = 600000;
+
+    @Value("${mongodb.minPoolSize:10}")
+    private int minPoolSize = 10;
+
+    @Value("${mongodb.maxPoolSize:100}")
+    private int maxPoolSize = 100;
+
     /**
      * @return the configured mongo client
      */
     @Bean
     public MongoClient mongoClient() {
         Builder settingsBuilder = MongoClientSettings.builder();
         settingsBuilder.applyConnectionString(new ConnectionString(this.mongoURI));
+        settingsBuilder.applicationName(DaemonStarter.getDaemonName());
         settingsBuilder.applyToSocketSettings(builder -> {
             builder.connectTimeout(RealClientConfig.this.connectTimeout, TimeUnit.MILLISECONDS);
             builder.readTimeout(RealClientConfig.this.socketTimeout, TimeUnit.MILLISECONDS);
         });
+
+        settingsBuilder.applyToConnectionPoolSettings(builder -> {
+            builder.minSize(this.minPoolSize);
+            builder.maxSize(this.maxPoolSize);
+            builder.maxConnectionIdleTime(RealClientConfig.this.maxConnectionIdleTime, TimeUnit.MILLISECONDS);
+        });
         return MongoClients.create(settingsBuilder.build());
     }