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) {