added missing file changes

Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch-si.com>
eclipse-ditto · May 8, 2018 · 1b3aaf9 · 1b3aaf9
1 parent f3ed1bc
commit 1b3aaf9
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/.../java/org/eclipse/ditto/services/concierge/util/config/AbstractConciergeConfigReader.java b/.../java/org/eclipse/ditto/services/concierge/util/config/AbstractConciergeConfigReader.java
@@ -11,6 +11,8 @@
  */
 package org.eclipse.ditto.services.concierge.util.config;
 
+import java.time.Duration;
+
 import org.eclipse.ditto.services.base.config.AbstractServiceConfigReader;
 
 import com.typesafe.config.Config;
@@ -23,6 +25,9 @@ public abstract class AbstractConciergeConfigReader extends AbstractServiceConfi
     private static final String PATH_CACHES = "caches";
     private static final String PATH_ENFORCEMENT = "enforcement";
 
+    private static final String PATH_THINGS_AGGREGATOR_SINGLE_RETRIEVE_THING_TIMEOUT =
+            "things-aggregator.single-retrieve-thing-timeout";
+
     protected AbstractConciergeConfigReader(final Config config, final String serviceName) {
         super(config, serviceName);
     }
@@ -45,4 +50,12 @@ public EnforcementConfigReader enforcement() {
         return new EnforcementConfigReader(getChild(PATH_ENFORCEMENT));
     }
 
+    /**
+     * Retrieve timeout how long the {@code ThingsAggregatorActor} should wait for a single retrieve thing.
+     *
+     * @return timeout how long to wait for a single retrieve thing.
+     */
+    public Duration thingsAggregatorSingleRetrieveThingTimeout() {
+        return config.getDuration(PATH_THINGS_AGGREGATOR_SINGLE_RETRIEVE_THING_TIMEOUT);
+    }
 }