添加mq 冲正

55fa07f3 · zhiheng.zhang · a4f7dc76 · 55fa07f3
Commit 55fa07f3 authored May 10, 2021 by zhiheng.zhang
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 0 deletions

order-application-service/src/main/java/cn/freemud/service/impl/MallOrderServiceImpl.java
+4 -0

No files found.
--- a/order-application-service/src/main/java/cn/freemud/service/impl/MallOrderServiceImpl.java
+++ b/order-application-service/src/main/java/cn/freemud/service/impl/MallOrderServiceImpl.java
@@ -277,6 +277,10 @@ public class MallOrderServiceImpl implements MallOrderService {
            CreateOrderRequest createOrderRequest = new CreateOrderRequest();
            baseCreateOrderRequest.setTrackingNo(LogThreadLocal.getTrackingNo());
            createOrderRequest.setBaseCreateOrderRequest(baseCreateOrderRequest);
+            MqMessageRequest mqMessageRequest = new MqMessageRequest();
+            mqMessageRequest.setBackOrdersNotifyActivityExchange(backOrdersNotifyActivityExchange);
+            mqMessageRequest.setBackOrdersNotifyActivityQueue(backOrdersChangeOrderStatusConsumerQueue);
+            createOrderRequest.setMqMessageRequest(mqMessageRequest);
            createOrderRequest.setTrackingNo(LogThreadLocal.getTrackingNo());
            return orderCenterSdkService.createOrderFlow(createOrderRequest);
        });