zy123/hmall
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

6.4 将mq抽取为公共方法写在common中

Browse Source
This commit is contained in:
zhangsan 2025-06-04 16:34:39 +08:00
parent 9b61eb1018
commit 487d847bf2
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
hm-common/src/main/java/com/hmall/common/constants/MQConstants.java
View File

@ -8,4 +8,5 @@ public interface MQConstants {
//支付成功消息的交换器和路由键 //支付成功消息的交换器和路由键
String PAY_EXCHANGE_NAME = "pay.direct"; String PAY_EXCHANGE_NAME = "pay.direct";
String PAY_SUCCESS_ROUTING_KEY = "pay.success"; String PAY_SUCCESS_ROUTING_KEY = "pay.success";
String PAY_SUCCESS_QUEUE_NAME = "trade.pay.success.queue";
} }

7
trade-service/src/main/java/com/hmall/trade/listener/PayStatusListener.java
View File

@ -1,5 +1,6 @@
package com.hmall.trade.listener; package com.hmall.trade.listener;
import com.hmall.common.constants.MQConstants;
import com.hmall.trade.service.IOrderService; import com.hmall.trade.service.IOrderService;
import lombok.RequiredArgsConstructor; import lombok.RequiredArgsConstructor;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
@ -17,9 +18,9 @@ public class PayStatusListener {
private final IOrderService orderService; private final IOrderService orderService;
@RabbitListener(bindings = @QueueBinding( @RabbitListener(bindings = @QueueBinding(
value = @Queue(name = "trade.pay.success.queue", durable = "true"), value = @Queue(name = MQConstants.PAY_SUCCESS_QUEUE_NAME, durable = "true"),
exchange = @Exchange(name = "pay.direct"), exchange = @Exchange(name = MQConstants.PAY_EXCHANGE_NAME),
key = "pay.success" key = MQConstants.PAY_SUCCESS_ROUTING_KEY
)) ))
public void listenPaySuccess(Long orderId){ public void listenPaySuccess(Long orderId){
orderService.markOrderPaySuccess(orderId); orderService.markOrderPaySuccess(orderId);