fix indication
parent
32ba425900
commit
27d0588bce
|
@ -228,7 +228,7 @@ public class ProtocolsManager implements ProtocolsAbstract {
|
||||||
String key = RedisUtil.getInstence().getKey(RedisKey.INDICATION_OFFLINE, Integer.toString(session.getUid()));
|
String key = RedisUtil.getInstence().getKey(RedisKey.INDICATION_OFFLINE, Integer.toString(session.getUid()));
|
||||||
Type type = new TypeToken<Map<Integer, ISession.IndicationMsg>>(){}.getType();
|
Type type = new TypeToken<Map<Integer, ISession.IndicationMsg>>(){}.getType();
|
||||||
Object indicationInRedis = RedisUtil.getInstence().get(key);
|
Object indicationInRedis = RedisUtil.getInstence().get(key);
|
||||||
int maxMsgId = 0;
|
int maxMsgId = 1;
|
||||||
if(indicationInRedis!=null){
|
if(indicationInRedis!=null){
|
||||||
Map<Integer, ISession.IndicationMsg> map= gson.fromJson(indicationInRedis.toString(),type);
|
Map<Integer, ISession.IndicationMsg> map= gson.fromJson(indicationInRedis.toString(),type);
|
||||||
for(Map.Entry<Integer,ISession.IndicationMsg> info : map.entrySet()){
|
for(Map.Entry<Integer,ISession.IndicationMsg> info : map.entrySet()){
|
||||||
|
|
Loading…
Reference in New Issue