alter the logs to have orgId

SolaceProducts · Jan 27, 2025 · b615c4e · b615c4e
1 parent caef0e8
commit b615c4e
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/...ation/src/main/java/com/solace/maas/ep/event/management/agent/command/CommandManager.java b/...ation/src/main/java/com/solace/maas/ep/event/management/agent/command/CommandManager.java
@@ -231,7 +231,6 @@ private void finalizeAndSendResponse(CommandRequest requestBO) {
     }
 
     private Path executeTerraformCommand(CommandRequest request, Command command, Map<String, String> envVars) {
-        Path executionLog = null;
         try {
             Validate.isTrue(command.getCommandType().equals(terraform), "Command type must be terraform");
             return terraformManager.execute(request, command, envVars);
@@ -240,7 +239,7 @@ private Path executeTerraformCommand(CommandRequest request, Command command, Ma
             setCommandError(command, e);
 
         }
-        return executionLog;
+        return null;
     }
 
     private void executeSempCommand(Command command, SolaceHttpSemp solaceClient) {

diff --git a/.../maas/ep/event/management/agent/subscriber/messageProcessors/CommandMessageProcessor.java b/.../maas/ep/event/management/agent/subscriber/messageProcessors/CommandMessageProcessor.java
@@ -38,7 +38,8 @@ public CommandMessageProcessor(CommandManager commandManager,
 
     @Override
     public void processMessage(CommandMessage message) {
-        log.info("Config push command processor started. context={} actorId={} ", message.getContext(), message.getActorId());
+        log.info("Config push command processor started. context={} orgId={} actorId={} ",
+                message.getContext(), message.getOrgId(), message.getActorId());
         logConfigPushMetric(message);
         if (CollectionUtils.isNotEmpty(message.getResources())) {
             dynamicResourceConfigurationHelper.loadSolaceBrokerResourceConfigurations(message.getResources());