fix: java: Fix direct alert queue name

ish-hcc · ish-hcc · commit 041f79aa11b5 · 2025-11-03T17:10:00.000+09:00
diff --git a/java/mc-o11y-manager/src/main/java/com/mcmp/o11ymanager/trigger/infrastructure/external/message/alert/AlertEventConsumer.java b/java/mc-o11y-manager/src/main/java/com/mcmp/o11ymanager/trigger/infrastructure/external/message/alert/AlertEventConsumer.java
@@ -98,14 +98,14 @@ public void consumeAlert(
         }
     }
 
-    @RabbitListener(queues = "direct.queue", errorHandler = "jsonParseErrorHandler")
+    @RabbitListener(queues = "alert-manual.queue", errorHandler = "jsonParseErrorHandler")
     public void consumeDirectAlert(
             @Payload DirectAlert directAlert,
             @Header(AmqpHeaders.DELIVERY_TAG) long tag,
             Channel channel)
             throws IOException {
 
-        log.info("Consume Direct alert message from direct.queue");
+        log.info("Consume Direct alert message from alert-manual.queue");
         log.debug("Raw message: {}", objectMapper.writeValueAsString(directAlert));
 
         try {

Original file line number	Diff line number	Diff line change
`@@ -98,14 +98,14 @@ public void consumeAlert(`
`98`	`98`	`}`
`99`	`99`	`}`
`100`	`100`
`101`		`- @RabbitListener(queues = "direct.queue", errorHandler = "jsonParseErrorHandler")`
	`101`	`+ @RabbitListener(queues = "alert-manual.queue", errorHandler = "jsonParseErrorHandler")`
`102`	`102`	`public void consumeDirectAlert(`
`103`	`103`	`@Payload DirectAlert directAlert,`
`104`	`104`	`@Header(AmqpHeaders.DELIVERY_TAG) long tag,`
`105`	`105`	`Channel channel)`
`106`	`106`	`throws IOException {`
`107`	`107`
`108`		`- log.info("Consume Direct alert message from direct.queue");`
	`108`	`+ log.info("Consume Direct alert message from alert-manual.queue");`
`109`	`109`	`log.debug("Raw message: {}", objectMapper.writeValueAsString(directAlert));`
`110`	`110`
`111`	`111`	`try {`