diff --git a/src/main/java/im/rosetta/service/services/BufferService.java b/src/main/java/im/rosetta/service/services/BufferService.java index 313b848..d535434 100644 --- a/src/main/java/im/rosetta/service/services/BufferService.java +++ b/src/main/java/im/rosetta/service/services/BufferService.java @@ -86,10 +86,13 @@ public class BufferService extends Service { List buffers = querySession.getQuery().setMaxResults(1).list(); if(!buffers.isEmpty()){ Buffer buffer = buffers.get(0); - if(buffer.getPacketId() == packetId){ + if(buffer.getPacketId() == 7){ /** - * Последний пакет в буфере уже является пакетом чтения, значит нет смысла добавлять еще один + * Последний пакет в буфере уже является пакетом чтения, значит нет смысла добавлять еще один, + * обновляем время для поддержкания актуальности */ + buffer.setTimestamp(System.currentTimeMillis()); + this.getRepository().update(buffer); return; } }