Updated default flow start log message with messageAttributeText

avioconsulting · Dec 18, 2024 · c26f06b · c26f06b
1 parent d9abf51
commit c26f06b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/...ioconsulting/mule/logger/internal/listeners/CustomLoggerAbstractNotificationListener.java b/...ioconsulting/mule/logger/internal/listeners/CustomLoggerAbstractNotificationListener.java
@@ -50,7 +50,7 @@ protected void logMessage(ComponentLocation location, Event event, String logMes
 
   protected Map<String, String> getFlowLogAttributes(EnrichedServerNotification notification) {
     Map<String, String> value = emptyAttributes;
-    FlowLogConfig flowLogConfig = config.getFlowLogConfigMap().get(notification.getResourceIdentifier());
+    FlowLogConfig flowLogConfig;
     /**
      * Flow name can contain wildcard (*)
      * We only look for wildcard either starting of the string or ending of the

diff --git a/...ioconsulting/mule/logger/internal/listeners/CustomLoggerPipelineNotificationListener.java b/...ioconsulting/mule/logger/internal/listeners/CustomLoggerPipelineNotificationListener.java
@@ -56,7 +56,8 @@ public void onNotification(PipelineMessageNotification notification) {
         String message = "Event not processed yet, this should never be shown";
         switch (Integer.parseInt(notification.getAction().getIdentifier())) {
           case PipelineMessageNotification.PROCESS_START:
-            message = "Flow [" + notification.getResourceIdentifier() + "]" + " start " + msgToAppend;
+            message = "Flow [" + notification.getResourceIdentifier() + "]" + " start "
+                + (msgToAppend != null ? msgToAppend : "");
             break;
           case PipelineMessageNotification.PROCESS_COMPLETE:
             message = "Flow [" + notification.getResourceIdentifier() + "]" + " end";