聊天修改

master_0.05_aqlm
grimm 2024-03-18 14:48:48 +08:00
parent a27e058066
commit 6aafcc9cd2
2 changed files with 2 additions and 2 deletions

View File

@ -101,7 +101,7 @@ public class ChatLogic {
LOGGER.info("getAllChatMessageInfo wrong chatType=>{} uid=>{}", chatType, uid);
break;
}
ChatProto.GetChatMessageInfoResponse getChatMessageInfoResponse = ChatProto.GetChatMessageInfoResponse
ChatProto.GetChatMessageInfoResponse getChatMessageInfoResponse = ChatProto.GetChatMessageInfoResponse
.newBuilder().addAllChatInfo(chatInfoList)
.build();
MessageUtil.sendMessage(iSession, 1, MessageTypeProto.MessageType.GET_CHAT_MESSAGE_REPONSE_VALUE, getChatMessageInfoResponse, true);

View File

@ -67,7 +67,7 @@ public class LoopQueue<T> {
long curTime = System.currentTimeMillis();
while (queueList[nextIndex] != null && nextIndex != endIndex) {
while (queueList[nextIndex].obj != null && nextIndex != endIndex) {
if (!needCompareTime && messageId >= queueList[nextIndex].messgeId) {
break;
}