rcoketmq集中管理

admin

2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0

 fanli/src/main/java/com/yeshi/fanli/service/impl/order/tb/TaoBaoWeiQuanOrderServiceImpl.java

@@ -24,6 +24,7 @@
import com.yeshi.fanli.service.inter.order.msg.MsgOrderDetailService;

import com.yeshi.fanli.service.inter.order.msg.UserOrderMsgNotificationService;

import com.yeshi.fanli.service.inter.order.tb.TaoBaoWeiQuanOrderService;

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

import com.yeshi.fanli.util.Constant;

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

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

@@ -45,8 +46,8 @@
   @Resource

   private UserOrderWeiQuanRecordService userOrderWeiQuanRecordService;



   @Resource(name = "producer")

   private Producer producer;

   @Resource

   private RocketMQManager rocketMQManager;



   @Transactional(rollbackFor = Exception.class)

   @Override

@@ -119,7 +120,7 @@
                  Constant.SOURCE_TYPE_TAOBAO);

            Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_ORDER, OrderTopicTagEnum.taoBaoOrderWeiQuan,

                  msg);

            producer.send(message);

            rocketMQManager.sendNormalMsg(message, null);

         }

      }