| | |
|---|
| | | import com.yeshi.fanli.service.inter.user.UserActiveLogService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
|
|---|
| | | import com.yeshi.fanli.service.inter.user.UserInfoRegisterService;
|
|---|
| | | import com.yeshi.fanli.util.Constant;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
|
|---|
| | | import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|---|
| | |
|
|---|
| | |
|---|
| | |
|
|---|
| | | //添加活跃消息
|
|---|
| | | private void addMQMsg(Long uid) {
|
|---|
| | | if (Constant.IS_TEST) {
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | | |
|---|
| | | UserActiveMQMsg msg = new UserActiveMQMsg(uid, new Date());
|
|---|
| | | Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userActve, msg);
|
|---|
| | | message.setStartDeliverTime(System.currentTimeMillis() + 1000 * 5L);// 5s后发送活跃消息
|
|---|
