From c836b0a09313bb41da1cb7654499be6f89c4f0a3 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Tue, 21 Jan 2025 09:25:18 +0300 Subject: [PATCH] refactoring --- .../src/main/java/org/redisson/jcache/JCache.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/redisson/src/main/java/org/redisson/jcache/JCache.java b/redisson/src/main/java/org/redisson/jcache/JCache.java index 4962df84f..716faa69f 100644 --- a/redisson/src/main/java/org/redisson/jcache/JCache.java +++ b/redisson/src/main/java/org/redisson/jcache/JCache.java @@ -70,7 +70,7 @@ public class JCache extends RedissonObject implements Cache, CacheAs final JCacheManager cacheManager; final JCacheConfiguration config; - private final ConcurrentMap, Map> listeners = new ConcurrentHashMap<>(); + final ConcurrentMap, Map> listeners = new ConcurrentHashMap<>(); final Redisson redisson; private CacheLoader cacheLoader; @@ -350,7 +350,7 @@ public class JCache extends RedissonObject implements Cache, CacheAs + "end; " + "return value; ", - Arrays.asList(name, getTimeoutSetName(name)), + Arrays.asList(name, getTimeoutSetName(name)), accessTimeout, System.currentTimeMillis(), encodeMapKey(key)); } @@ -2766,7 +2766,7 @@ public class JCache extends RedissonObject implements Cache, CacheAs return oldValue; } - private void incrementOldValueListenerCounter(String counterName) { + void incrementOldValueListenerCounter(String counterName) { evalWrite(getRawName(), codec, RedisCommands.EVAL_INTEGER, "return redis.call('incr', KEYS[1]);", Arrays.asList(counterName)); @@ -3167,9 +3167,9 @@ public class JCache extends RedissonObject implements Cache, CacheAs registerCacheEntryListener(cacheEntryListenerConfiguration, true); } - private JCacheEventCodec.OSType osType; + JCacheEventCodec.OSType osType; - private void registerCacheEntryListener(CacheEntryListenerConfiguration cacheEntryListenerConfiguration, boolean addToConfig) { + void registerCacheEntryListener(CacheEntryListenerConfiguration cacheEntryListenerConfiguration, boolean addToConfig) { if (osType == null) { RFuture> serverFuture = commandExecutor.readAsync((String) null, StringCodec.INSTANCE, RedisCommands.INFO_SERVER); String os = serverFuture.toCompletableFuture().join().get("os"); @@ -3296,7 +3296,7 @@ public class JCache extends RedissonObject implements Cache, CacheAs } } - private void sendSync(boolean sync, List msg) { + void sendSync(boolean sync, List msg) { if (sync) { Object syncId = msg.get(msg.size() - 1); RSemaphore semaphore = redisson.getSemaphore(getSyncName(syncId));