推送重发次数限制,时间限制修改
parent
e0e64e46b3
commit
21faa2b905
|
@ -56,7 +56,11 @@ public class RetrySendIndicationThread extends Thread{
|
||||||
for(ISession.IndicationMsg indicationMsg : indexToIndication.values()){
|
for(ISession.IndicationMsg indicationMsg : indexToIndication.values()){
|
||||||
long create = indicationMsg.getCreate();
|
long create = indicationMsg.getCreate();
|
||||||
int retryTimes = indicationMsg.getRetryTimes()+1;
|
int retryTimes = indicationMsg.getRetryTimes()+1;
|
||||||
if(now-create>retryTimes*300){
|
if(retryTimes>3){
|
||||||
|
LOGGER.info("uid=>{}重试Indication3次以上,未收到不再发送",session.getUid());
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
if(now-create>retryTimes*3000){
|
||||||
MessageUtil.retrySendIndication(session,indicationMsg.getMsg());
|
MessageUtil.retrySendIndication(session,indicationMsg.getMsg());
|
||||||
indicationMsg.setRetryTimes(retryTimes);
|
indicationMsg.setRetryTimes(retryTimes);
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue