don't add "<not-provided>" correlation-id to published logs, fixed al…

…so for debug log Signed-off-by: Thomas Jaeckle <thomas.jaeckle@bosch.io>
eclipse-ditto · Nov 10, 2021 · ef5ab31 · ef5ab31
1 parent 7b124e9
commit ef5ab31
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/...itto/connectivity/service/messaging/monitoring/logs/FluentPublishingConnectionLogger.java b/...itto/connectivity/service/messaging/monitoring/logs/FluentPublishingConnectionLogger.java
@@ -156,9 +156,9 @@ private void emitLogEntry(final ConnectionMonitor.InfoProvider infoProvider, fin
     }
 
     private void emitLogEntry(final LogEntry logEntry) {
+        final String correlationId = InfoProviderFactory.FALLBACK_CORRELATION_ID
+                .equals(logEntry.getCorrelationId()) ? null : logEntry.getCorrelationId();
         if (logLevels.contains(logEntry.getLogLevel())) {
-            final String correlationId = InfoProviderFactory.FALLBACK_CORRELATION_ID
-                    .equals(logEntry.getCorrelationId()) ? null : logEntry.getCorrelationId();
             try {
                 final Instant timestamp = logEntry.getTimestamp();
                 final EventTime eventTime = EventTime.fromEpoch(timestamp.getEpochSecond(), timestamp.getNano());
@@ -193,7 +193,7 @@ private void emitLogEntry(final LogEntry logEntry) {
                                 e.getClass().getSimpleName(), e.getMessage());
             }
         } else {
-            LOGGER.withCorrelationId(logEntry.getCorrelationId())
+            LOGGER.withCorrelationId(correlationId)
                     .debug("Not emitting log entry with logLevel <{}> as the configured logLevels contained: <{}>",
                             logEntry.getLogLevel(), logLevels);
         }