From 1d5c4ac7ab5f978fb05339cc6e897d40c2e8fbc1 Mon Sep 17 00:00:00 2001
From: Volodymyr Babak <volodymyr.babak@gmail.com>
Date: Tue, 3 Jun 2025 15:48:26 +0300
Subject: [PATCH] VersionsStore - added try/catch for cleanup task

---
 .../thingsboard/server/edqs/util/VersionsStore.java  | 12 ++++++++----
 1 file changed, 8 insertions(+), 4 deletions(-)

diff --git a/common/edqs/src/main/java/org/thingsboard/server/edqs/util/VersionsStore.java b/common/edqs/src/main/java/org/thingsboard/server/edqs/util/VersionsStore.java
index c8c8f76761..f348e9cf9e 100644
--- a/common/edqs/src/main/java/org/thingsboard/server/edqs/util/VersionsStore.java
+++ b/common/edqs/src/main/java/org/thingsboard/server/edqs/util/VersionsStore.java
@@ -54,11 +54,15 @@ public class VersionsStore {
 
     private void startCleanupTask() {
         cleaner.scheduleAtFixedRate(() -> {
-            long now = System.currentTimeMillis();
-            for (Map.Entry<EdqsObjectKey, TimedValue> entry : versions.entrySet()) {
-                if (now - entry.getValue().lastUpdated > expirationMillis) {
-                    versions.remove(entry.getKey(), entry.getValue());
+            try {
+                long now = System.currentTimeMillis();
+                for (Map.Entry<EdqsObjectKey, TimedValue> entry : versions.entrySet()) {
+                    if (now - entry.getValue().lastUpdated > expirationMillis) {
+                        versions.remove(entry.getKey(), entry.getValue());
+                    }
                 }
+            } catch (Exception e) {
+                log.error("Cleanup task failed", e);
             }
         }, expirationMillis, expirationMillis, TimeUnit.MILLISECONDS);
     }