From 388794937d371fbe434c587c6793f16f0da6cccb Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=ED=98=84=EC=84=B1=ED=95=84?= <hyunsp@gmail.com>
Date: Mon, 30 Dec 2024 21:13:06 +0900
Subject: [PATCH] =?UTF-8?q?=EB=B9=84=EB=8F=99=EA=B8=B0=20=ED=95=B8?=
 =?UTF-8?q?=EB=93=A4=EB=9F=AC=20=EC=88=98=EC=A0=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../queue/service/QueueListenerService.java   | 41 +------------------
 1 file changed, 1 insertion(+), 40 deletions(-)

diff --git a/src/main/java/com/eactive/testmaster/queue/service/QueueListenerService.java b/src/main/java/com/eactive/testmaster/queue/service/QueueListenerService.java
index 634bc02..626786b 100644
--- a/src/main/java/com/eactive/testmaster/queue/service/QueueListenerService.java
+++ b/src/main/java/com/eactive/testmaster/queue/service/QueueListenerService.java
@@ -52,29 +52,6 @@ public class QueueListenerService {
         this.console = new Console();
     }
 
-//    @PostConstruct
-//    public void startListening() {
-//        if (queueHandler != null) {
-//            taskQueue = hazelcastInstance.getQueue(queueHandler.getQueueName());
-//            executorService.submit(this::processQueueItems);
-//            logger.info("Queue listener started");
-//            this.running.set(true);
-//        }
-//    }
-
-    //    private void processQueueItems() {
-//        while (running.get()) {
-//            try {
-//                Object item = taskQueue.poll();
-//                if (item != null) {
-//                    processItem(item);
-//                }
-//            } catch (Exception e) {
-//                logger.error("Error processing queue item", e);
-//            }
-//        }
-//    }
-
     @PostConstruct
     public void startListening() {
         if (queueHandler != null) {
@@ -126,22 +103,6 @@ public class QueueListenerService {
         return running.get();
     }
 
-//    @PreDestroy
-//    public void stopListening() {
-//        logger.info("Stopping queue listener...");
-//        running.set(false);
-//        executorService.shutdown();
-//        try {
-//            if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
-//                executorService.shutdownNow();
-//            }
-//        } catch (InterruptedException e) {
-//            Thread.currentThread().interrupt();
-//            executorService.shutdownNow();
-//        }
-//        logger.info("Queue listener stopped");
-//
-//    }
 
     @PreDestroy
     public void stopListening() {
@@ -150,7 +111,7 @@ public class QueueListenerService {
         // Interrupt the blocking take() call
         executorService.shutdownNow();
         try {
-            if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
+            if (!executorService.awaitTermination(15, TimeUnit.SECONDS)) {
                 logger.warn("Queue listener did not terminate in time");
             }
         } catch (InterruptedException e) {