发消息

order-application-service/src/main/java/cn/freemud/service/impl/MCCafeOrderServiceImpl.java

@@ -1065,7 +1065,7 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService {
         }
 
         Header header = new Header(MQAction.INSERT.getAction(), "order-application-service-api",
-                "send_score_key", "send_score_queue");
+                "inviter-activity-queue-routing-key", "inviter-activity-queue");
         OrderInfoRequest body = new OrderInfoRequest();
         body.setBizType(orderBean.getBizType());
         body.setExtInfo(JSON.toJSONString(orderBean.getExtInfo()));
@@ -1083,7 +1083,7 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService {
         body.setSettlementAmount(settlementAmount);
         MQMessage<OrderInfoRequest> mqMessage = new MQMessage<>(header, body);
         ApiLog.info("邀请有礼发消息："+JSON.toJSONString(mqMessage));
-        mqService.convertAndSend("topic-Exchange", "send_score_key", mqMessage);
+        mqService.convertAndSend("topic-Exchange", "inviter-activity-queue-routing-key", mqMessage);
 
         //支付回掉成功标记
         redisCache.save(RedisKeyConstant.KGD_PAYMENT_CALLBACK_FMID + message.getOut_trade_no(), message.getOut_trade_no(), 10L, TimeUnit.MINUTES);