Removes useless timer configuration

Signed-off-by: Klem Yannic (INST/ECS1) <Yannic.Klem@bosch-si.com>
eclipse-ditto · Jul 10, 2018 · 5850843 · 5850843
1 parent 99aa357
commit 5850843
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 4 deletions.
diff --git a/.../main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java b/.../main/java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessor.java
@@ -236,7 +236,6 @@ private StartedTimer startNewTimer() {
         return DittoMetrics
                 .expiringTimer(TIMER_NAME)
                 .tag(TracingTags.CONNECTION_ID, connectionId)
-                .maximumDuration(5, TimeUnit.MINUTES)
                 .expirationHandling(expiredTimer -> expiredTimer.tag(TracingTags.MAPPING_SUCCESS, false))
                 .build();
     }

diff --git a/.../java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java b/.../java/org/eclipse/ditto/services/connectivity/messaging/MessageMappingProcessorActor.java
@@ -255,11 +255,8 @@ private void handleSignal(final Signal<?> signal) {
 
     private void startTrace(final Signal<?> command) {
         command.getDittoHeaders().getCorrelationId().ifPresent(correlationId -> {
-            final HashMap<String, String> additionalTags = new HashMap<>();
             final StartedTimer timer = TraceUtils
                     .newAmqpRoundTripTimer(command)
-                    .maximumDuration(5, TimeUnit.MINUTES)
-                    .tags(additionalTags)
                     .expirationHandling(startedTimer -> this.timers.remove(correlationId))
                     .build();
             this.timers.put(correlationId, timer);