fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPPreInfoServiceImpl.java
@@ -131,6 +131,8 @@ UserLevelChangedMQMsg msg = new UserLevelChangedMQMsg(info.getUid(), oldLevel, 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); }