X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pmproducer%2Fsrc%2Fmain%2Fjava%2Forg%2Foran%2Fpmproducer%2Ffilter%2FPmReportFilter.java;h=00f90f6c35e5b886348573b567df5c13b24a07d6;hb=db5cb9a3759fe227ce8654bd0be1c85080e83e3f;hp=26bdf58d4a41e6c52706ed70fcffe13384d4afa4;hpb=6599eca2119b68778aaacdda9639e498e2511fef;p=nonrtric%2Fplt%2Franpm.git

diff --git a/pmproducer/src/main/java/org/oran/pmproducer/filter/PmReportFilter.java b/pmproducer/src/main/java/org/oran/pmproducer/filter/PmReportFilter.java
index 26bdf58..00f90f6 100644
--- a/pmproducer/src/main/java/org/oran/pmproducer/filter/PmReportFilter.java
+++ b/pmproducer/src/main/java/org/oran/pmproducer/filter/PmReportFilter.java
@@ -193,7 +193,8 @@ public class PmReportFilter {
             if (reportFiltered == null) {
                 return FilteredData.empty();
             }
-            return new FilteredData(data.infoTypeId, data.key, gson.toJson(reportFiltered).getBytes());
+            return new FilteredData(reportFiltered.event.getCommonEventHeader().getSourceName(), data.infoTypeId,
+                    data.key, gson.toJson(reportFiltered).getBytes());
         } catch (Exception e) {
             logger.warn("Could not parse PM data. {}, reason: {}", data, e.getMessage());
             return FilteredData.empty();