fix tests

Signed-off-by: Dominik Guggemos <dominik.guggemos@bosch-si.com>
eclipse-ditto · Jan 9, 2019 · b402d03 · b402d03
1 parent 3a4d5f3
commit b402d03
Showing 1 changed file with 4 additions and 7 deletions.
diff --git a/...itto/services/connectivity/messaging/metrics/RetrieveConnectionStatusAggregatorActor.java b/...itto/services/connectivity/messaging/metrics/RetrieveConnectionStatusAggregatorActor.java
@@ -43,9 +43,12 @@ public class RetrieveConnectionStatusAggregatorActor extends AbstractActor {
     private RetrieveConnectionStatusResponse theResponse;
 
     private RetrieveConnectionStatusAggregatorActor(final Connection connection,
-            final ActorRef sender, final DittoHeaders dittoHeaders, final Duration timeout) {
+            final ActorRef sender, final DittoHeaders dittoHeaders) {
         this.connection = connection;
         this.timeout = extractTimeoutFromCommand(dittoHeaders);
+        this.sender = sender;
+        theResponse = RetrieveConnectionStatusResponse.of(connection.getId(), connection.getConnectionStatus(),
+                        Collections.emptyList(), Collections.emptyList(), Collections.emptyList(), dittoHeaders);
 
         // one RetrieveConnectionMetricsResponse per client actor
         this.expectedResponses = new HashMap<>();
@@ -59,12 +62,6 @@ private RetrieveConnectionStatusAggregatorActor(final Connection connection,
                             .map(consumers -> consumers * connection.getClientCount())
                             .sum());
         }
-
-
-        this.sender = sender;
-
-        theResponse = RetrieveConnectionStatusResponse.of(connection.getId(), connection.getConnectionStatus(),
-                        Collections.emptyList(), Collections.emptyList(), Collections.emptyList(), dittoHeaders);
     }
 
     private Duration extractTimeoutFromCommand(final DittoHeaders headers) {