session异常处理回滚

master_haizei
grimm 2023-12-29 12:06:50 +08:00
parent ee237b4996
commit f746d02aa3
1 changed files with 1 additions and 6 deletions

View File

@ -301,12 +301,7 @@ public class SessionManager implements INetSession<ISession>, INetReceived<ISess
byte[] message = iSession.getCacheMessage(index);
if (message == null) {
//TODO error
try {
LOGGER.error("the uid={},the msg={} is processing,the index={},the sessionIndex={}", iSession.getUid(), MessageTypeProto.MessageType.valueOf(packetNetData.getMsgId()), index, iSession.getIndex());
MessageUtil.sendErrorResponse(iSession, -1, iSession.getLastMsgId(),"sessionIndex error");
} catch (Exception e) {
throw new RuntimeException(e);
}
LOGGER.error("the uid={},the msg={} is processing,the index={},the sessionIndex={}", iSession.getUid(), MessageTypeProto.MessageType.valueOf(packetNetData.getMsgId()), index, iSession.getIndex());
return 1;
} else {
LOGGER.error("the uid={},the msg={} reback", iSession.getUid(), MessageTypeProto.MessageType.valueOf(packetNetData.getMsgId()));