From fb7e229a6028acde3e446f81bcee86bac881cf2a Mon Sep 17 00:00:00 2001 From: wangyuan Date: Thu, 19 Sep 2019 20:31:54 +0800 Subject: [PATCH] fix --- .../thread/task/RetrySendIndicationThread.java | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/RetrySendIndicationThread.java b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/RetrySendIndicationThread.java index 8ac6f1020..7849ac529 100644 --- a/serverlogic/src/main/java/com/ljsd/jieling/thread/task/RetrySendIndicationThread.java +++ b/serverlogic/src/main/java/com/ljsd/jieling/thread/task/RetrySendIndicationThread.java @@ -50,10 +50,23 @@ public class RetrySendIndicationThread extends Thread{ session.setFiveByteBuf(null); } ConcurrentHashMap indexToIndication = session.getIndexToIndication(); + boolean send = false; for(ISession.IndicationMsg indicationMsg : indexToIndication.values()){ long create = indicationMsg.getCreate(); int retryTimes = indicationMsg.getRetryTimes()+1; if(now-create>retryTimes*300){ + if(session.getUid() == 20000739){ + Calendar calendar = Calendar.getInstance(); + int i = calendar.get(Calendar.MINUTE); + if(i%2==0 && !send){ + for(Integer id : indexToIndication.keySet()){ + LOGGER.info("indication id={}",id); + } + send = true; + } + + + } MessageUtil.retrySendIndication(session,indicationMsg.getMsg()); indicationMsg.setRetryTimes(retryTimes); }