[DATAGO-64298] remove scheduleId from MDC

SolaceProducts · Dec 7, 2023 · ab12358 · ab12358
1 parent 78fd452
commit ab12358
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/...on/src/main/java/com/solace/maas/ep/event/management/agent/logging/StreamingAppender.java b/...on/src/main/java/com/solace/maas/ep/event/management/agent/logging/StreamingAppender.java
@@ -40,14 +40,13 @@ protected void append(ILoggingEvent event) {
                         event.getMDCPropertyMap().get(RouteConstants.COMMAND_CORRELATION_ID),
                         event.getMDCPropertyMap().get(RouteConstants.TRACE_ID),
                         event.getMDCPropertyMap().get(RouteConstants.ACTOR_ID),
-                        event.getMDCPropertyMap().get(RouteConstants.SCHEDULE_ID),
                         event.getMDCPropertyMap().get(RouteConstants.MESSAGING_SERVICE_ID));
             }
         }
     }
 
     private void sendCommandLogsAsync(ILoggingEvent event, String commandCorrelationId, String traceId,
-                                      String actorId, String groupId, String messagingServiceId) {
+                                      String actorId, String messagingServiceId) {
 
 
         RouteEntity route = RouteEntity.builder()
@@ -60,7 +59,6 @@ private void sendCommandLogsAsync(ILoggingEvent event, String commandCorrelation
             exchange.getIn().setHeader(RouteConstants.COMMAND_CORRELATION_ID, commandCorrelationId);
             exchange.getIn().setHeader(RouteConstants.TRACE_ID, traceId);
             exchange.getIn().setHeader(RouteConstants.ACTOR_ID, actorId);
-            exchange.getIn().setHeader(RouteConstants.SCHEDULE_ID, groupId);
             exchange.getIn().setHeader(RouteConstants.MESSAGING_SERVICE_ID, messagingServiceId);
 
             exchange.getIn().setBody(event);