Rosetta/rosetta-wss
0
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Фикс последнего индикатора чтения

Browse Source
This commit is contained in:
RoyceDa
2026-02-16 15:00:22 +02:00
parent 421531d73c
commit 93d5596d34
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/im/rosetta/service/services/BufferService.java
View File

@@ -86,10 +86,13 @@ public class BufferService extends Service<BufferRepository> {
List<Buffer> buffers = querySession.getQuery().setMaxResults(1).list(); List<Buffer> buffers = querySession.getQuery().setMaxResults(1).list();
if(!buffers.isEmpty()){ if(!buffers.isEmpty()){
Buffer buffer = buffers.get(0); Buffer buffer = buffers.get(0);
if(buffer.getPacketId() == packetId){ if(buffer.getPacketId() == 7){
/** /**
* Последний пакет в буфере уже является пакетом чтения, значит нет смысла добавлять еще один * Последний пакет в буфере уже является пакетом чтения, значит нет смысла добавлять еще один,
* обновляем время для поддержкания актуальности
*/ */
buffer.setTimestamp(System.currentTimeMillis());
this.getRepository().update(buffer);
return; return;
} }
} }