Try printing thread dump info to log but with separate methods and additional logging.

Author: tecarter94

java-components/domain-proxy/client/src/main/java/com/redhat/hacbs/domainproxy/client/DomainProxyClient.java

@@ -20,15 +20,14 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
+import com.redhat.hacbs.domainproxy.common.CommonIOUtil;
 import jakarta.annotation.PostConstruct;
 import jakarta.annotation.PreDestroy;
 import jakarta.inject.Inject;
 import jakarta.inject.Singleton;
 
 import org.eclipse.microprofile.config.inject.ConfigProperty;
 
-import com.redhat.hacbs.domainproxy.common.CommonIOUtil;
-
 import io.quarkus.logging.Log;
 import io.quarkus.runtime.Quarkus;
 import io.quarkus.runtime.Startup;
@@ -81,7 +80,7 @@ private void startClient() {
                             executor.submit(channelToChannelBiDirectionalHandler(byteBufferSize, httpClientChannel,
                                     domainSocketChannel));
                             Log.info("Before thread dump");
-                            threadDump();
+                            CommonIOUtil.threadDump();
                             Log.info("After thread dump");
                         }
                     }
@@ -93,35 +92,6 @@ private void startClient() {
         Quarkus.asyncExit();
     }
 
-    private static void threadDump() throws IOException {
-        // Create a timestamp with milliseconds for the file name
-        //String timestamp = new SimpleDateFormat("yyyyMMdd_HHmmss_SSS").format(new Date());
-        //String fileName = "/app/thread_dump_" + timestamp + ".txt";
-        Log.info("Thread dump");
-        String threadDumpStr = "";
-
-        // Create a PrintWriter to write the thread dump to a file
-        //try (PrintWriter writer = new PrintWriter(new FileWriter(fileName))) {
-        // Get the ThreadMXBean instance
-        ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean();
-
-        // Get all thread IDs
-        long[] threadIds = threadMXBean.getAllThreadIds();
-        ThreadInfo[] threadInfos = threadMXBean.getThreadInfo(threadIds, Integer.MAX_VALUE);
-
-        // Write the thread information to the file
-        for (ThreadInfo threadInfo : threadInfos) {
-            threadDumpStr += "Thread ID: " + threadInfo.getThreadId() + " Name: " + threadInfo.getThreadName() + "\n";
-            threadDumpStr += "Thread State: " + threadInfo.getThreadState() + "\n";
-            StackTraceElement[] stackTrace = threadInfo.getStackTrace();
-            for (StackTraceElement stackTraceElement : stackTrace) {
-                threadDumpStr += "\t" + stackTraceElement + "\n";
-            }
-        }
-        //}
-        Log.info(threadDumpStr);
-    }
-
     @PreDestroy
     public void stop() {
         executor.shutdownNow();

java-components/domain-proxy/common/src/main/java/com/redhat/hacbs/domainproxy/common/CommonIOUtil.java

@@ -168,6 +168,7 @@ public static void threadDump() throws IOException {
         // Create a timestamp with milliseconds for the file name
         //String timestamp = new SimpleDateFormat("yyyyMMdd_HHmmss_SSS").format(new Date());
         //String fileName = "/app/thread_dump_" + timestamp + ".txt";
+        LOG.info("Thread dump");
         String threadDumpStr = "";
 
         // Create a PrintWriter to write the thread dump to a file
@@ -181,10 +182,13 @@ public static void threadDump() throws IOException {
 
         // Write the thread information to the file
         for (ThreadInfo threadInfo : threadInfos) {
+            LOG.info("Thread ID: " + threadInfo.getThreadId() + " Name: " + threadInfo.getThreadName());
+            LOG.info("Thread State: " + threadInfo.getThreadState());
             threadDumpStr += "Thread ID: " + threadInfo.getThreadId() + " Name: " + threadInfo.getThreadName() + "\n";
             threadDumpStr += "Thread State: " + threadInfo.getThreadState() + "\n";
             StackTraceElement[] stackTrace = threadInfo.getStackTrace();
             for (StackTraceElement stackTraceElement : stackTrace) {
+                LOG.info("\t" + stackTraceElement);
                 threadDumpStr += "\t" + stackTraceElement + "\n";
             }
         }

java-components/domain-proxy/server/src/main/java/com/redhat/hacbs/domainproxy/server/DomainProxyServer.java

@@ -22,15 +22,14 @@
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 
+import com.redhat.hacbs.domainproxy.common.CommonIOUtil;
 import jakarta.annotation.PostConstruct;
 import jakarta.annotation.PreDestroy;
 import jakarta.inject.Inject;
 import jakarta.inject.Singleton;
 
 import org.eclipse.microprofile.config.inject.ConfigProperty;
 
-import com.redhat.hacbs.domainproxy.common.CommonIOUtil;
-
 import io.quarkus.logging.Log;
 import io.quarkus.runtime.Quarkus;
 import io.quarkus.runtime.Startup;
@@ -81,7 +80,7 @@ private void startServer() {
                             executor.submit(channelToChannelBiDirectionalHandler(byteBufferSize, httpServerChannel,
                                     domainSocketChannel));
                             Log.info("Before thread dump");
-                            threadDump();
+                            CommonIOUtil.threadDump();
                             Log.info("After thread dump");
                         }
                     }
@@ -93,35 +92,6 @@ private void startServer() {
         Quarkus.asyncExit();
     }
 
-    private static void threadDump() throws IOException {
-        // Create a timestamp with milliseconds for the file name
-        //String timestamp = new SimpleDateFormat("yyyyMMdd_HHmmss_SSS").format(new Date());
-        //String fileName = "/app/thread_dump_" + timestamp + ".txt";
-        Log.info("Thread dump");
-        String threadDumpStr = "";
-
-        // Create a PrintWriter to write the thread dump to a file
-        //try (PrintWriter writer = new PrintWriter(new FileWriter(fileName))) {
-        // Get the ThreadMXBean instance
-        ThreadMXBean threadMXBean = ManagementFactory.getThreadMXBean();
-
-        // Get all thread IDs
-        long[] threadIds = threadMXBean.getAllThreadIds();
-        ThreadInfo[] threadInfos = threadMXBean.getThreadInfo(threadIds, Integer.MAX_VALUE);
-
-        // Write the thread information to the file
-        for (ThreadInfo threadInfo : threadInfos) {
-            threadDumpStr += "Thread ID: " + threadInfo.getThreadId() + " Name: " + threadInfo.getThreadName() + "\n";
-            threadDumpStr += "Thread State: " + threadInfo.getThreadState() + "\n";
-            StackTraceElement[] stackTrace = threadInfo.getStackTrace();
-            for (StackTraceElement stackTraceElement : stackTrace) {
-                threadDumpStr += "\t" + stackTraceElement + "\n";
-            }
-        }
-        //}
-        Log.info(threadDumpStr);
-    }
-
     @PreDestroy
     public void stop() {
         executor.shutdownNow();