测试环境取消活跃消息

yujian

2020-05-13 b850eee6e58029b45ada7a21a8b52d3ecb177850

测试环境取消活跃消息

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserActiveLogServiceImpl.java

@@ -17,6 +17,7 @@
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;



@@ -83,6 +84,10 @@


    //添加活跃消息

    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后发送活跃消息