rcoketmq集中管理

admin

2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0

 fanli/src/main/java/com/yeshi/fanli/service/impl/shop/BanLiShopOrderServiceImpl.java

@@ -46,6 +46,7 @@
import com.yeshi.fanli.service.inter.shop.BanLiShopGoodsSetPayService;

import com.yeshi.fanli.service.inter.shop.BanLiShopGoodsSetService;

import com.yeshi.fanli.service.inter.shop.BanLiShopOrderService;

import com.yeshi.fanli.service.manger.msg.RocketMQManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.factory.RedPackDetailFactory;

import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;

@@ -74,8 +75,8 @@
   @Resource

   private RedPackBalanceService redPackBalanceService;



   @Resource(name = "producer")

   private Producer producer;

   @Resource

   private RocketMQManager rocketMQManager;



   @Resource

   private MQUnSendInfoService mqUnSendInfoService;

@@ -180,7 +181,8 @@
      msg.setKey(orderId + "");

      long delayTime = System.currentTimeMillis() + (Constant.IS_TEST ? 1000 * 30L : 1000 * 60 * 10);// 10分钟后通知

      msg.setStartDeliverTime(delayTime);

      SendResult sendResult = producer.send(msg);

		
      SendResult sendResult =   rocketMQManager.sendNormalMsg(msg,  Constant.IS_TEST ? 1000 * 30L : 1000 * 60 * 10L, orderId + "");

      if (sendResult == null) {

         MQUnSendInfo info = new MQUnSendInfo();

         info.setBody(new String(msg.getBody()));

@@ -349,7 +351,7 @@
                  BanLiShopOrderMQMsg msg = new BanLiShopOrderMQMsg(order.getId(), order.getUid());

                  Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER,

                        OrderTopicTagEnum.banLiShopOrderPaid, msg);

                  producer.send(message);

                  rocketMQManager.sendNormalMsg(message, null);

                  return;

               }