get service and subservice from event using enableNamemapping flag

telefonicaid · Jun 11, 2024 · e13fc7b · e13fc7b
1 parent 5907e65
commit e13fc7b
Showing 1 changed file with 3 additions and 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
@@ -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/");