djb-eapim/elink-test-master
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

주석 제거

Browse Source
This commit is contained in:
현성필
2025-01-21 13:20:35 +09:00
parent fab924d136
commit 205419a972
1 changed files with 0 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/eactive/testmaster/queue/service/DynamicQueueManager.java
-11
View File
@@ -29,17 +29,6 @@ public class DynamicQueueManager {
/** /**
* Start a listener for the specified queue * 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) { public void startQueueListener(QueueHandler queueHandler) {
QueueListenerService existingListener = queueListeners.get(queueHandler.getQueueName()); QueueListenerService existingListener = queueListeners.get(queueHandler.getQueueName());
if (existingListener != null) { if (existingListener != null) {