Change Event and Aggreagations threads to use only one threadpool (#475)

* Change threads to use only one threadpool

* indentation fix

* Fix ttl duplication bug in EI infromation

* More ttl fix

* Remove ttl fix, since it seems to fail tests indirect

* Increased threadpool size

* Changed back threadpool size for travis test failures

* change threadpool parameter

* Changed back thread queue capacity

* removed a ttl config value that might cause test failures

* thread pools config tweak

* Fix the minor duplication AggregationTTl values in information restapi

* fix default MongoDb connection configuration in case of MongoDB connection is lost and comes back

* Fixed MongoDb Client object to not get closed state when connection goes down and comes up

* Remove some mongodb parameters that is not needed

* Removed unused private function

* Removed some default mongodb connection flags that is not needed

Author: tobiasake

src/main/java/com/ericsson/ei/handlers/ObjectHandler.java

@@ -21,6 +21,7 @@
 import java.util.List;
 
 import com.ericsson.ei.mongo.*;
+import com.fasterxml.jackson.annotation.JsonIgnore;
 import org.apache.commons.lang3.StringUtils;
 import org.bson.Document;
 import org.slf4j.Logger;
@@ -274,6 +275,7 @@ public String lockDocument(String id) {
      *
      * @return ttl Integer value representing time to live for documents
      */
+    @JsonIgnore
     public int getTtl() {
         int ttl = 0;
         if (StringUtils.isNotEmpty(aggregationsTtl)) {

src/main/java/com/ericsson/ei/mongo/MongoDBHandler.java

@@ -392,8 +392,7 @@ private List<String> getCollectionList(String databaseName) throws MongoClientEx
         } catch (MongoInterruptedException | MongoSocketReadException | MongoSocketWriteException
                 | MongoCommandException | IllegalStateException e) {
             String message = String.format("Failed to get Mongo collection list, Reason: %s",
-                    e.getMessage());
-            closeMongoDbConnection();
+                    e.getMessage()); 
             throw new MongoClientException(message, e);
         }
     }
@@ -435,11 +434,4 @@ private void checkIfCollectionExistError(String databaseName, String collectionN
             throw new MongoClientException(message, e);
         }
     }
-
-    private void closeMongoDbConnection() {
-        if (mongoClient != null) {
-            mongoClient.close();
-        }
-        mongoClient = null;
-    }
 }

src/main/java/com/ericsson/ei/subscription/SubscriptionHandler.java

@@ -74,15 +74,11 @@ public class SubscriptionHandler {
      */
     public void checkSubscriptionForObject(final String aggregatedObject,
                                            final String id) {
-        Thread subscriptionThread = new Thread(() -> {
-            List<String> subscriptions = mongoDBHandler.getAllDocuments(
-                    database, subscriptionCollectionName);
-            subscriptions.forEach(
+        List<String> subscriptions = mongoDBHandler.getAllDocuments(
+                database, subscriptionCollectionName);
+        subscriptions.forEach(
                 subscription -> extractConditions(aggregatedObject,
-                    subscription, id));
-        });
-        subscriptionThread.setName("SubscriptionHandler");
-        subscriptionThread.start();
+                        subscription, id));
     }
 
     /**

src/main/resources/application.properties

@@ -75,7 +75,7 @@ spring.mongodb.embedded.version: 3.4.1
 # starts and activate it manually in tests where we need the Spring's own embedded mongo DB
 spring.autoconfigure.exclude: org.springframework.boot.autoconfigure.mongo.embedded.EmbeddedMongoAutoConfiguration
 
-threads.core.pool.size: 100
-threads.queue.capacity: 5000
-threads.max.pool.size: 150
-scheduled.threadpool.size: 100
+threads.core.pool.size: 200
+threads.queue.capacity: 7000
+threads.max.pool.size: 250
+scheduled.threadpool.size: 200