From: danielhanrahan <daniel.hanrahan@est.tech>
Date: Sat, 27 Sep 2025 10:07:21 +0000 (+0100)
Subject: Add logging to ThreadHandler when cancelling threads
X-Git-Tag: 8.2.1~3
X-Git-Url: https://gerrit.onap.org/r/gitweb?a=commitdiff_plain;h=refs%2Fchanges%2F31%2F142131%2F2;p=policy%2Fclamp.git

Add logging to ThreadHandler when cancelling threads

Issue-ID: POLICY-5458
Change-Id: I24e38efc8220db0094111a2ed196b0e1bc47c171
Signed-off-by: danielhanrahan <daniel.hanrahan@est.tech>
---

diff --git a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/ThreadHandler.java b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/ThreadHandler.java
index 45b2488cc..29377a923 100644
--- a/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/ThreadHandler.java
+++ b/participant/participant-intermediary/src/main/java/org/onap/policy/clamp/acm/participant/intermediary/handler/ThreadHandler.java
@@ -72,6 +72,8 @@ public class ThreadHandler implements Closeable {
         this.cacheProvider = cacheProvider;
         executor = Context.taskWrapping(Executors.newFixedThreadPool(
                 parameters.getIntermediaryParameters().getThreadPoolSize()));
+        LOGGER.info("ThreadHandler started with thread pool size {}",
+                parameters.getIntermediaryParameters().getThreadPoolSize());
     }
 
     /**
@@ -244,6 +246,8 @@ public class ThreadHandler implements Closeable {
         var process = executionMap.get(execIdentificationId);
         if (process != null) {
             if (!process.isDone()) {
+                LOGGER.warn("ThreadHandler cancelling previous thread for execIdentificationId={} messageId={}",
+                        execIdentificationId, messageId);
                 process.cancel(true);
             }
             executionMap.remove(execIdentificationId);