rcoketmq集中管理

admin

2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/tb/UserExtraTaoBaoInfoServiceImpl.java

@@ -22,6 +22,7 @@
import com.yeshi.fanli.service.inter.user.ForbiddenUserIdentifyCodeService;

import com.yeshi.fanli.service.inter.user.UserAccountBindingHistoryService;

import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;

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

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

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

@@ -39,8 +40,8 @@
   @Resource

   private UserAccountBindingHistoryService userAccountBindingHistoryService;



   @Resource(name = "producer")

   private Producer producer;

   @Resource

   private RocketMQManager rocketMQManager;



   @Transactional(rollbackFor = Exception.class)

   @Override

@@ -202,7 +203,8 @@


      Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.taobaoBindSuccess,

            new TaoBaoBindSuccessMQMsg(uid, fromUid, taoBaoUid, new Date()));

      producer.send(message);

		
      rocketMQManager.sendNormalMsg(message, null);

   }



   /**