diff --git a/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java b/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java index 49d584c8c..7332d826a 100644 --- a/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java +++ b/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java @@ -140,6 +140,8 @@ public interface CommandAsyncExecutor { RFuture evalWriteBatchedAsync(Codec codec, RedisCommand command, String script, List keys, SlotCallback callback); + RFuture evalReadBatchedAsync(Codec codec, RedisCommand command, String script, List keys, SlotCallback callback); + boolean isEvalShaROSupported(); void setEvalShaROSupported(boolean value); diff --git a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java index a9c9f5d5d..37735d6a5 100644 --- a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java +++ b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java @@ -583,10 +583,15 @@ public class CommandAsyncService implements CommandAsyncExecutor { @Override public RFuture evalWriteBatchedAsync(Codec codec, RedisCommand command, String script, List keys, SlotCallback callback) { - return evalWriteBatchedAsync(false, codec, command, script, keys, callback); + return evalBatchedAsync(false, codec, command, script, keys, callback); } - private RFuture evalWriteBatchedAsync(boolean readOnly, Codec codec, RedisCommand command, String script, List keys, SlotCallback callback) { + @Override + public RFuture evalReadBatchedAsync(Codec codec, RedisCommand command, String script, List keys, SlotCallback callback) { + return evalBatchedAsync(true, codec, command, script, keys, callback); + } + + private RFuture evalBatchedAsync(boolean readOnly, Codec codec, RedisCommand command, String script, List keys, SlotCallback callback) { if (!connectionManager.isClusterMode()) { Object[] keysArray = callback.createKeys(keys); Object[] paramsArray = callback.createParams(Collections.emptyList());