From 487d847bf28035c7dd6f45bf765b2bcbbfc23004 Mon Sep 17 00:00:00 2001
From: zhangsan <646228430@qq.com>
Date: Wed, 4 Jun 2025 16:34:39 +0800
Subject: [PATCH] =?UTF-8?q?6.4=20=E5=B0=86mq=E6=8A=BD=E5=8F=96=E4=B8=BA?=
 =?UTF-8?q?=E5=85=AC=E5=85=B1=E6=96=B9=E6=B3=95=E5=86=99=E5=9C=A8common?=
 =?UTF-8?q?=E4=B8=AD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../main/java/com/hmall/common/constants/MQConstants.java  | 1 +
 .../java/com/hmall/trade/listener/PayStatusListener.java   | 7 ++++---
 2 files changed, 5 insertions(+), 3 deletions(-)

diff --git a/hm-common/src/main/java/com/hmall/common/constants/MQConstants.java b/hm-common/src/main/java/com/hmall/common/constants/MQConstants.java
index 2c2e4b3..f4d3e21 100644
--- a/hm-common/src/main/java/com/hmall/common/constants/MQConstants.java
+++ b/hm-common/src/main/java/com/hmall/common/constants/MQConstants.java
@@ -8,4 +8,5 @@ public interface MQConstants {
     //支付成功消息的交换器和路由键
     String PAY_EXCHANGE_NAME = "pay.direct";
     String PAY_SUCCESS_ROUTING_KEY = "pay.success";
+    String PAY_SUCCESS_QUEUE_NAME = "trade.pay.success.queue";
 }
\ No newline at end of file
diff --git a/trade-service/src/main/java/com/hmall/trade/listener/PayStatusListener.java b/trade-service/src/main/java/com/hmall/trade/listener/PayStatusListener.java
index b713e94..5607295 100644
--- a/trade-service/src/main/java/com/hmall/trade/listener/PayStatusListener.java
+++ b/trade-service/src/main/java/com/hmall/trade/listener/PayStatusListener.java
@@ -1,5 +1,6 @@
 package com.hmall.trade.listener;
 
+import com.hmall.common.constants.MQConstants;
 import com.hmall.trade.service.IOrderService;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
@@ -17,9 +18,9 @@ public class PayStatusListener {
     private final IOrderService orderService;
 
     @RabbitListener(bindings = @QueueBinding(
-            value = @Queue(name = "trade.pay.success.queue", durable = "true"),
-            exchange = @Exchange(name = "pay.direct"),
-            key = "pay.success"
+            value = @Queue(name = MQConstants.PAY_SUCCESS_QUEUE_NAME, durable = "true"),
+            exchange = @Exchange(name = MQConstants.PAY_EXCHANGE_NAME),
+            key = MQConstants.PAY_SUCCESS_ROUTING_KEY
     ))
     public void listenPaySuccess(Long orderId){
         orderService.markOrderPaySuccess(orderId);