fix indication
parent
13b83b1050
commit
c7a280108d
|
@ -41,6 +41,9 @@ public class RetrySendIndicationThread extends Thread{
|
||||||
long now = TimeUtils.now();
|
long now = TimeUtils.now();
|
||||||
Set<Integer> removeIds = new HashSet<>();
|
Set<Integer> removeIds = new HashSet<>();
|
||||||
for(ISession session : sessionMap.values()){
|
for(ISession session : sessionMap.values()){
|
||||||
|
if(session == null){
|
||||||
|
continue;
|
||||||
|
}
|
||||||
if(!session.getChannel().isClosed()&&session.getChannel().isConnected()){
|
if(!session.getChannel().isClosed()&&session.getChannel().isConnected()){
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue