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