1.延迟更新订单信息

2 weeks ago · 58928eb1e4
1 changed files with 2 additions and 1 deletions
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/OrderInfoUpdateHandler.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/OrderInfoUpdateHandler.java
@ -27,7 +27,8 @@ public class OrderInfoUpdateHandler {
 		value = @Queue(name = RabbitConstant.ORDER_INFO_UPDATE_QUEUE, durable = "true"),
 		exchange = @Exchange(name = RabbitConstant.ORDER_INFO_UPDATE_EXCHANGE,
 			type = ExchangeTypes.DIRECT,
-			delayed = FactoryDataConstants.Mq.DELAYED)
+			delayed = FactoryDataConstants.Mq.DELAYED),
+		key = RabbitConstant.ORDER_INFO_UPDATE_ROUTING
 	))
 	public void updateOrderInfo(String msg, Channel channel) {
 		if(StringUtil.isNotBlank(msg)){