diff --git a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java index bfe43fb0..075e92e4 100644 --- a/broker/src/main/java/io/moquette/persistence/DatabaseStore.java +++ b/broker/src/main/java/io/moquette/persistence/DatabaseStore.java @@ -2477,6 +2477,8 @@ public class DatabaseStore { builder.setDeleted(deleted); long longValue = rs.getLong(index++); + if(longValue <= 0) + longValue = 1; builder.setUpdateDt(longValue); return builder.build();