From e13fc7b874a843feded21b106818529d9b292a6c Mon Sep 17 00:00:00 2001
From: Alvaro Vega <alvaro.vegagarcia@telefonica.com>
Date: Tue, 11 Jun 2024 12:56:49 +0200
Subject: [PATCH] get service and subservice from event using enableNamemapping
 flag

---
 .../sinks/NGSIArcgisFeatureTableSink.java      | 18 +++---------------
 1 file changed, 3 insertions(+), 15 deletions(-)

diff --git a/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSIArcgisFeatureTableSink.java b/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSIArcgisFeatureTableSink.java
index c1b754b3a..7a6800883 100644
--- a/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSIArcgisFeatureTableSink.java
+++ b/cygnus-ngsi/src/main/java/com/telefonica/iot/cygnus/sinks/NGSIArcgisFeatureTableSink.java
@@ -482,21 +482,9 @@ public void aggregate(NGSIEvent event) throws CygnusRuntimeError {
 
                 LOGGER.debug("[NGSIArcgisAggregator] aggregate - Selected context ->" + contextElement);
 
-                // get the getRecvTimeTs headers
-                Map<String, String> headers = event.getHeaders();
-
-                for (Entry<String, String> entry : headers.entrySet()) {
-                    LOGGER.debug("Header entry key --> " + entry.getKey().toString() + ", value --> "
-                            + entry.getValue().toString());
-                    if (entry.getKey() != null
-                            && NGSIConstants.FLUME_HEADER_MAPPED_SERVICE.equals(entry.getKey().toString())) {
-                        service = entry.getValue().toString();
-                    } else if (entry.getKey() != null
-                            && NGSIConstants.FLUME_HEADER_MAPPED_SERVICE_PATH.equals(entry.getKey().toString())) {
-                        subService = entry.getValue().toString();
-                    }
-                } // for
-                
+                service = event.getServiceForNaming(enableNameMappings);
+                subService = event.getServicePathForNaming(enableNameMappings);
+
                 // Compose full url
                 featureTableUrl = argisServiceUrl + "/" + service + "/" + subService;
                 featureTableUrl = featureTableUrl.replaceAll("([^:])\\/\\/", "$1/");