rcoketmq集中管理

admin

2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/invite/ThreeSaleSerivceImpl.java

@@ -34,6 +34,7 @@
import com.yeshi.fanli.service.inter.user.invite.ThreeSaleExtraInfoSerivce;

import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;

import com.yeshi.fanli.service.inter.user.invite.UserInviteMsgNotificationService;

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;

@@ -84,8 +85,8 @@
   @Resource(name = "taskExecutor")

   private TaskExecutor executor;



   @Resource(name = "producer")

   private Producer producer;

   @Resource

   private RocketMQManager rocketMQManager;



   public UserInfo getBoss(final long uid) {

      return threeSaleMapper.selectBoss(uid);

@@ -441,7 +442,7 @@
               UserInviteMQMsg.STATE_SUCCESS);

         Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.inviteSuccess, msg);

         message.setStartDeliverTime(java.lang.System.currentTimeMillis() + 5000);

         producer.send(message);

         rocketMQManager.sendNormalMsg(message,5000L, null);

      }



      executor.execute(new Runnable() {