From 034b480a6ca641f9b2670c146b0a78e8190c72be Mon Sep 17 00:00:00 2001
From: Sergey Matvienko <smatvienko@thingsboard.io>
Date: Tue, 16 Apr 2024 16:47:27 +0200
Subject: [PATCH] RedisTbTransactionalCache refactored to make doGet using the
 rawKey and the Redis connection precalculated slot based on hash

---
 .../thingsboard/server/cache/RedisTbTransactionalCache.java | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/common/cache/src/main/java/org/thingsboard/server/cache/RedisTbTransactionalCache.java b/common/cache/src/main/java/org/thingsboard/server/cache/RedisTbTransactionalCache.java
index bb5af26c3e..35ef07f0ce 100644
--- a/common/cache/src/main/java/org/thingsboard/server/cache/RedisTbTransactionalCache.java
+++ b/common/cache/src/main/java/org/thingsboard/server/cache/RedisTbTransactionalCache.java
@@ -78,7 +78,7 @@ public abstract class RedisTbTransactionalCache<K extends Serializable, V extend
     public TbCacheValueWrapper<V> get(K key) {
         try (var connection = connectionFactory.getConnection()) {
             byte[] rawKey = getRawKey(key);
-            byte[] rawValue = connection.stringCommands().get(rawKey);
+            byte[] rawValue = doGet(connection, rawKey);
             if (rawValue == null) {
                 return null;
             } else if (Arrays.equals(rawValue, BINARY_NULL_VALUE)) {
@@ -95,6 +95,10 @@ public abstract class RedisTbTransactionalCache<K extends Serializable, V extend
         }
     }
 
+    protected byte[] doGet(RedisConnection connection, byte[] rawKey) {
+        return connection.stringCommands().get(rawKey);
+    }
+
     @Override
     public void put(K key, V value) {
         try (var connection = connectionFactory.getConnection()) {