| | |
|---|
| | | String key = "useractive-" + uidStr;
|
|---|
| | | Jedis jedis = jedisPool.getResource();
|
|---|
| | | try {
|
|---|
| | | if (!StringUtil.isNullOrEmpty(jedis.set(key, "1", new SetParams().nx().ex(300)))) {
|
|---|
| | | if (!StringUtil.isNullOrEmpty(jedis.set(key, "1", new SetParams().nx().ex(Constant.IS_TEST?10:300)))) {
|
|---|
| | | try {
|
|---|
| | | Long uid = Long.parseLong(uidStr);
|
|---|
| | | // Long uid = Long.parseLong(uidStr);
|
|---|
| | | // if (!Constant.IS_TEST) { // 活跃通知
|
|---|
| | | UserActiveMQMsg msg = new UserActiveMQMsg(uid, new Date());
|
|---|
| | | Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userActve, msg);
|
|---|
| | | producer.send(message);
|
|---|
| | | // UserActiveMQMsg msg = new UserActiveMQMsg(uid, new Date());
|
|---|
| | | // Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userActve, msg);
|
|---|
| | | // message.setStartDeliverTime(System.currentTimeMillis()+1000*10L);//10s后发送活跃消息
|
|---|
| | | // producer.send(message);
|
|---|
| | | // }
|
|---|
| | | } catch (Exception e) {
|
|---|
| | |
|
|---|
