From 86c0808cfd2c13f54d2e3d1b2c72c04850b3f32f Mon Sep 17 00:00:00 2001
From: switschel <stefan.witschel@cumulocity.com>
Date: Mon, 6 Jan 2025 16:03:42 +0100
Subject: [PATCH] Merging latest develop to virtualThreads

---
 .../mapping/processor/inbound/BaseProcessorInbound.java     | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/dynamic-mapping-service/src/main/java/dynamic/mapping/processor/inbound/BaseProcessorInbound.java b/dynamic-mapping-service/src/main/java/dynamic/mapping/processor/inbound/BaseProcessorInbound.java
index 60554da4..0559a7c6 100644
--- a/dynamic-mapping-service/src/main/java/dynamic/mapping/processor/inbound/BaseProcessorInbound.java
+++ b/dynamic-mapping-service/src/main/java/dynamic/mapping/processor/inbound/BaseProcessorInbound.java
@@ -63,14 +63,14 @@ public abstract class BaseProcessorInbound<T> {
     public BaseProcessorInbound(ConfigurationRegistry configurationRegistry) {
         this.objectMapper = configurationRegistry.getObjectMapper();
         this.c8yAgent = configurationRegistry.getC8yAgent();
-        this.processingCachePool = configurationRegistry.getProcessingCachePool();
+        this.virtThreadPool = configurationRegistry.getVirtThreadPool();
     }
 
     protected C8YAgent c8yAgent;
 
     protected ObjectMapper objectMapper;
 
-    protected ExecutorService processingCachePool;
+    protected ExecutorService virtThreadPool;
 
     public abstract T deserializePayload(Mapping mapping, ConnectorMessage message)
             throws IOException;
@@ -149,7 +149,7 @@ public void substituteInTargetAndSend(ProcessingContext<T> context) {
             for (int i = 0; i < deviceEntries.size(); i++) {
                 // for (MappingSubstitution.SubstituteValue device : deviceEntries) {
                 int finalI = i;
-                contextFutureList.add(processingCachePool.submit(() -> {
+                contextFutureList.add(virtThreadPool.submit(() -> {
                     return getBuildProcessingContext(context, deviceEntries.get(finalI),
                             finalI, deviceEntries.size());
                 }));