From 205419a972385b3a017c29f5e82f1f6d28dd4837 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=ED=98=84=EC=84=B1=ED=95=84?= Date: Tue, 21 Jan 2025 13:20:35 +0900 Subject: [PATCH] =?UTF-8?q?=EC=A3=BC=EC=84=9D=20=EC=A0=9C=EA=B1=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../testmaster/queue/service/DynamicQueueManager.java | 11 ----------- 1 file changed, 11 deletions(-) diff --git a/src/main/java/com/eactive/testmaster/queue/service/DynamicQueueManager.java b/src/main/java/com/eactive/testmaster/queue/service/DynamicQueueManager.java index ff29696..c53850d 100644 --- a/src/main/java/com/eactive/testmaster/queue/service/DynamicQueueManager.java +++ b/src/main/java/com/eactive/testmaster/queue/service/DynamicQueueManager.java @@ -29,17 +29,6 @@ public class DynamicQueueManager { /** * Start a listener for the specified queue */ -// public void startQueueListener(QueueHandler queueHandler) { -// if (!queueListeners.containsKey(queueHandler.getQueueName())) { -// QueueListenerService listener = new QueueListenerService(hazelcastInstance, hazelcastJSBridge); -// listener.setQueueHandler(queueHandler); -// queueListeners.put(queueHandler.getQueueName(), listener); -// listener.startListening(); -// logger.info("Started listener for queue: {}", queueHandler.getQueueName()); -// } else { -// logger.warn("Listener already exists for queue: {}", queueHandler.getQueueName()); -// } -// } public void startQueueListener(QueueHandler queueHandler) { QueueListenerService existingListener = queueListeners.get(queueHandler.getQueueName()); if (existingListener != null) {