From 5079cb84622e59e909daed8fc14ddf17ea9cd263 Mon Sep 17 00:00:00 2001 From: Nikita Koksharov Date: Thu, 3 Feb 2022 09:40:33 +0300 Subject: [PATCH] refactoring --- redisson/src/main/java/org/redisson/jcache/JCache.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/redisson/src/main/java/org/redisson/jcache/JCache.java b/redisson/src/main/java/org/redisson/jcache/JCache.java index 544114920..412b47316 100644 --- a/redisson/src/main/java/org/redisson/jcache/JCache.java +++ b/redisson/src/main/java/org/redisson/jcache/JCache.java @@ -521,7 +521,7 @@ public class JCache extends RedissonObject implements Cache, CacheAs RFuture putAllValues(Map map) { double syncId = ThreadLocalRandom.current().nextDouble(); - RFuture> res = putAllOperation(syncId, null, getRawName(), map); + RFuture> res = putAllOperation(commandExecutor, syncId, null, getRawName(), map); RFuture result = handlePutAllResult(syncId, res); return result; @@ -577,7 +577,8 @@ public class JCache extends RedissonObject implements Cache, CacheAs return result; } - RFuture> putAllOperation(double syncId, MasterSlaveEntry msEntry, String name, Map map) { + RFuture> putAllOperation(CommandAsyncExecutor commandExecutor, double syncId, + MasterSlaveEntry msEntry, String name, Map map) { Long creationTimeout = getCreationTimeout(); Long updateTimeout = getUpdateTimeout();