fix proto
parent
13634f35de
commit
24ee84be59
|
|
@ -299,7 +299,6 @@ public class ProtocolsManager implements ProtocolsAbstract {
|
||||||
iSession.setOfflineType(ErrorCode.reloginCode);
|
iSession.setOfflineType(ErrorCode.reloginCode);
|
||||||
backUpMsgToRedis(iSession);
|
backUpMsgToRedis(iSession);
|
||||||
OnlineUserManager.userOffline(uid);
|
OnlineUserManager.userOffline(uid);
|
||||||
LOGGER.info("the channel={}",iSession.getCtx().channel());
|
|
||||||
return 1;
|
return 1;
|
||||||
}
|
}
|
||||||
return 0;
|
return 0;
|
||||||
|
|
@ -401,7 +400,6 @@ public class ProtocolsManager implements ProtocolsAbstract {
|
||||||
}
|
}
|
||||||
|
|
||||||
String key = RedisUtil.getInstence().getKey(RedisKey.RESPONSE_OFFLINE, Integer.toString(session.getUid()));
|
String key = RedisUtil.getInstence().getKey(RedisKey.RESPONSE_OFFLINE, Integer.toString(session.getUid()));
|
||||||
LOGGER.info("the uid={},the offlineIndex={},",session.getUid(),session.getIndexToMessage().keySet().iterator().next());
|
|
||||||
RedisUtil.getInstence().set(key,gson.toJson(session.getIndexToMessage()));
|
RedisUtil.getInstence().set(key,gson.toJson(session.getIndexToMessage()));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue