rcoketmq集中管理

admin

2020-07-01 c54fb6a88876be994906d57d2d18e844686964d0

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java

@@ -38,6 +38,7 @@
import com.yeshi.fanli.service.inter.user.vip.UserLevelUpgradedNotifyService;

import com.yeshi.fanli.service.inter.user.vip.UserVIPPreInfoService;

import com.yeshi.fanli.service.inter.user.vip.UserVipConfigService;

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.TimeUtil;

@@ -88,8 +89,8 @@
   @Resource(name = "taskExecutor")

   private TaskExecutor executor;



   @Resource(name = "producer")

   private Producer producer;

   @Resource

   private RocketMQManager rocketMQManager;



   @Resource

   private TeamUserLevelStatisticService teamUserLevelStatisticService;

@@ -132,8 +133,7 @@
               UserLevelUtil.getByLevel(info.getProcess()), new Date());

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

         //延时10s发送

         message.setStartDeliverTime(System.currentTimeMillis()+1000*10L);

         producer.send(message);

         rocketMQManager.sendNormalMsg(message,1000*10L, null);

      }



   }