Merge pull request #3118 from DedunuKarunarathne/master

Template endpoint metrics in ELK Monitoring for Micro Integrator
wso2 · Feb 16, 2024 · b7f70b0 · b7f70b0
2 parents 99cab9a + 18b94b5
commit b7f70b0
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/...nalytics/messageflow/data/publisher/publish/elasticsearch/ElasticStatisticsPublisher.java b/...nalytics/messageflow/data/publisher/publish/elasticsearch/ElasticStatisticsPublisher.java
@@ -180,15 +180,16 @@ private void publishEndpointAnalytics(PublishingEvent event) {
             return;
         }
 
-        Endpoint endpoint = event.getElasticMetadata().getEndpoint(event.getComponentName());
+        String placeholderName = "$name";
+        String componentName = event.getComponentName();
 
-        if (endpoint == null) {
+        if (SynapseConstants.ANONYMOUS_ENDPOINT.equals(componentName) || placeholderName.equals(componentName)) {
             return;
         }
 
         ElasticDataSchemaElement analyticsPayload = generateAnalyticsObject(event, Endpoint.class);
         ElasticDataSchemaElement endpointDetails = new ElasticDataSchemaElement();
-        endpointDetails.setAttribute(ElasticConstants.EnvelopDef.ENDPOINT_NAME, endpoint.getName());
+        endpointDetails.setAttribute(ElasticConstants.EnvelopDef.ENDPOINT_NAME, componentName);
         analyticsPayload.setAttribute(ElasticConstants.EnvelopDef.ENDPOINT_DETAILS, endpointDetails);
 
         publishAnalytic(analyticsPayload);