From 51a7c15f8dcef39005122c45ae32dac46a5fb9b5 Mon Sep 17 00:00:00 2001 From: Derran Date: Mon, 28 Apr 2025 14:35:08 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E6=94=BF=E7=AD=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../handler/revenuereward/RevenueRewardEventHandler.java | 4 ++-- .../com/qniao/dam/infrastructure/constant/MqExchange.java | 2 ++ .../java/com/qniao/dam/infrastructure/constant/MqQueue.java | 2 ++ 3 files changed, 6 insertions(+), 2 deletions(-) diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/revenuereward/RevenueRewardEventHandler.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/revenuereward/RevenueRewardEventHandler.java index 0dfaf30..9265595 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/revenuereward/RevenueRewardEventHandler.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/application/handler/revenuereward/RevenueRewardEventHandler.java @@ -257,8 +257,8 @@ public class RevenueRewardEventHandler extends BaseApplicationService { * * @param mq */ - @RabbitListener(bindings = @QueueBinding(value = @Queue(MqQueue.OPERATION_CENTER_CREATED), - exchange = @Exchange(value = MqExchange.OPERATION_CENTER_CREATED, + @RabbitListener(bindings = @QueueBinding(value = @Queue(MqQueue.MATCHMAKER_NOVICE_TASK_PROGRESS_FINISHED), + exchange = @Exchange(value = MqExchange.MATCHMAKER_NOVICE_TASK_PROGRESS_FINISHED, type = ExchangeTypes.FANOUT))) public void handle(MatchmakerNoviceTaskProgressFinishedMQ mq) { try { diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java index 3f90105..fde3735 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqExchange.java @@ -31,4 +31,6 @@ public interface MqExchange { String OPERATION_CENTER_CREATED = "fanout.operationCenterCreated"; String MATCHMAKER_INVITED = "fanout.MatchmakerInvited"; + + String MATCHMAKER_NOVICE_TASK_PROGRESS_FINISHED = "fanout.matchmakerNoviceTaskProgressFinished"; } diff --git a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqQueue.java b/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqQueue.java index fb5c7ee..1752357 100644 --- a/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqQueue.java +++ b/dating-agency-mall-server/src/main/java/com/qniao/dam/infrastructure/constant/MqQueue.java @@ -23,4 +23,6 @@ public interface MqQueue { String STORE_CREATED = MqExchange.STORE_CREATED + serviceName; String OPERATION_CENTER_CREATED = MqExchange.OPERATION_CENTER_CREATED + serviceName; + + String MATCHMAKER_NOVICE_TASK_PROGRESS_FINISHED = MqExchange.MATCHMAKER_NOVICE_TASK_PROGRESS_FINISHED + serviceName; }