From 53b66312d378e2e64fcf1bb8db8d3c9ff9cab87a Mon Sep 17 00:00:00 2001 From: Dulanjali Dilmi Date: Fri, 22 Mar 2024 14:18:47 +0530 Subject: [PATCH] Create ELK metadata for fault events Fix wso2/micro-integrator#3278 --- .../publisher/services/MessageFlowReporterThread.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/components/mediation/data-publishers/org.wso2.micro.integrator.analytics.messageflow.data.publisher/src/main/java/org/wso2/micro/integrator/analytics/messageflow/data/publisher/services/MessageFlowReporterThread.java b/components/mediation/data-publishers/org.wso2.micro.integrator.analytics.messageflow.data.publisher/src/main/java/org/wso2/micro/integrator/analytics/messageflow/data/publisher/services/MessageFlowReporterThread.java index 4e93b447dd..cfe1008934 100644 --- a/components/mediation/data-publishers/org.wso2.micro.integrator.analytics.messageflow.data.publisher/src/main/java/org/wso2/micro/integrator/analytics/messageflow/data/publisher/services/MessageFlowReporterThread.java +++ b/components/mediation/data-publishers/org.wso2.micro.integrator.analytics.messageflow.data.publisher/src/main/java/org/wso2/micro/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 messageFlowLogs, i } } - void addFaultsToParents(List messageFlowLogs, int index) { + void addFaultsToParents(List 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()); + } } }