From d8023de620b2d26cbe63e4bd97360ae253993f92 Mon Sep 17 00:00:00 2001 From: danielhanrahan Date: Sat, 27 Sep 2025 11:07:21 +0100 Subject: [PATCH] Add logging to ThreadHandler when cancelling threads Issue-ID: POLICY-5458 Change-Id: I24e38efc8220db0094111a2ed196b0e1bc47c171 Signed-off-by: danielhanrahan --- .../clamp/acm/participant/intermediary/handler/ThreadHandler.java | 4 ++++ 1 file changed, 4 insertions(+) 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); -- 2.16.6