Commit dbefa935 by 徐康

修改queue和key

parent 22348f60
...@@ -1065,7 +1065,7 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService { ...@@ -1065,7 +1065,7 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService {
} }
Header header = new Header(MQAction.UPDATE.getAction(), "order-application-service-api", Header header = new Header(MQAction.UPDATE.getAction(), "order-application-service-api",
"inviter-activity-queue-routing-key", "inviter-activity-queue"); "send_score_key", "send_score_queue");
OrderInfoRequest body = new OrderInfoRequest(); OrderInfoRequest body = new OrderInfoRequest();
body.setBizType(orderBean.getBizType()); body.setBizType(orderBean.getBizType());
body.setExtInfo(JSON.toJSONString(orderBean.getExtInfo())); body.setExtInfo(JSON.toJSONString(orderBean.getExtInfo()));
...@@ -1083,7 +1083,7 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService { ...@@ -1083,7 +1083,7 @@ public class MCCafeOrderServiceImpl implements MCCafeOrderService {
body.setSettlementAmount(settlementAmount); body.setSettlementAmount(settlementAmount);
MQMessage<OrderInfoRequest> mqMessage = new MQMessage<>(header, body); MQMessage<OrderInfoRequest> mqMessage = new MQMessage<>(header, body);
ApiLog.info("邀请有礼发消息:"+JSON.toJSONString(mqMessage)); ApiLog.info("邀请有礼发消息:"+JSON.toJSONString(mqMessage));
mqService.convertAndSend("topic-Exchange", "inviter-activity-queue", mqMessage); mqService.convertAndSend("topic-Exchange", "send_score_queue", mqMessage);
//支付回掉成功标记 //支付回掉成功标记
redisCache.save(RedisKeyConstant.KGD_PAYMENT_CALLBACK_FMID + message.getOut_trade_no(), message.getOut_trade_no(), 10L, TimeUnit.MINUTES); redisCache.save(RedisKeyConstant.KGD_PAYMENT_CALLBACK_FMID + message.getOut_trade_no(), message.getOut_trade_no(), 10L, TimeUnit.MINUTES);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment