Create ELK metadata for fault events

Fix #3278
wso2 · Mar 22, 2024 · 53b6631 · 53b6631
1 parent 4845814
commit 53b6631
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/...o/integrator/analytics/messageflow/data/publisher/services/MessageFlowReporterThread.java b/...o/integrator/analytics/messageflow/data/publisher/services/MessageFlowReporterThread.java
@@ -178,7 +178,7 @@ private void processAndPublishEventList(StatisticsReportingEventHolder statistic
                 break;
             case FAULT_EVENT:
                 BasicStatisticDataUnit basicDataUnit = event.getDataUnit();
-                addFaultsToParents(messageFlowLogs, basicDataUnit.getCurrentIndex());
+                addFaultsToParents(messageFlowLogs, basicDataUnit, basicDataUnit.getCurrentIndex());
                 break;
             case PARENT_REOPEN_EVENT:
                 BasicStatisticDataUnit parentReopenDataUnit = event.getDataUnit();
@@ -262,11 +262,15 @@ private void openFlowContinuableMediators(List<StatisticsLog> messageFlowLogs, i
         }
     }
 
-    void addFaultsToParents(List<StatisticsLog> messageFlowLogs, int index) {
+    void addFaultsToParents(List<StatisticsLog> messageFlowLogs, BasicStatisticDataUnit dataUnit, int index) {
         while (index > -1) {
             StatisticsLog updatingLog = messageFlowLogs.get(index);
             updatingLog.incrementNoOfFaults();
             index = updatingLog.getParentIndex();
+
+            if (dataUnit.getElasticMetadata() != null) {
+                updatingLog.setElasticMetadata(dataUnit.getElasticMetadata());
+            }
         }
 
     }