Merge branch 'master_test_hw' of http://60.1.1.230/backend/jieling_server into master_test_hw
commit
e9f835fdf5
|
@ -42,6 +42,7 @@ import java.lang.reflect.Type;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
import java.util.concurrent.ConcurrentHashMap;
|
import java.util.concurrent.ConcurrentHashMap;
|
||||||
|
import java.util.concurrent.TimeUnit;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Description: session管理器
|
* Description: session管理器
|
||||||
|
@ -138,6 +139,11 @@ public class SessionManager implements INetSession<ISession>, INetReceived<ISess
|
||||||
private void ackIndication(ISession iSession, int ackId) {
|
private void ackIndication(ISession iSession, int ackId) {
|
||||||
LOGGER.info("the uid={},the ackId={}", iSession.getUid(), ackId);
|
LOGGER.info("the uid={},the ackId={}", iSession.getUid(), ackId);
|
||||||
iSession.clearIndication(ackId);
|
iSession.clearIndication(ackId);
|
||||||
|
try {
|
||||||
|
TimeUnit.SECONDS.sleep(3600);
|
||||||
|
} catch (InterruptedException e) {
|
||||||
|
e.printStackTrace();
|
||||||
|
}
|
||||||
MessageUtil.sendAck(iSession, ackId);
|
MessageUtil.sendAck(iSession, ackId);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue