diff --git a/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java b/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java index 860c2a798..65236853a 100644 --- a/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java +++ b/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java @@ -101,6 +101,8 @@ public interface CommandAsyncExecutor { RFuture evalReadAsync(RedisClient client, MasterSlaveEntry entry, Codec codec, RedisCommand evalCommandType, String script, List keys, Object... params); + RFuture evalReadAsync(ByteBuf key, Codec codec, RedisCommand evalCommandType, String script, List keys, Object... params); + RFuture evalWriteAsync(String key, Codec codec, RedisCommand evalCommandType, String script, List keys, Object... params); RFuture evalWriteAsync(ByteBuf key, Codec codec, RedisCommand evalCommandType, String script, List keys, Object... params); diff --git a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java index e2f19e3d4..26603de11 100644 --- a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java +++ b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java @@ -455,6 +455,12 @@ public class CommandAsyncService implements CommandAsyncExecutor { return evalAsync(source, false, codec, evalCommandType, script, keys, false, params); } + @Override + public RFuture evalReadAsync(ByteBuf key, Codec codec, RedisCommand evalCommandType, String script, List keys, Object... params) { + NodeSource source = getNodeSource(key); + return evalAsync(source, true, codec, evalCommandType, script, keys, false, params); + } + @Override public RFuture evalWriteNoRetryAsync(String key, Codec codec, RedisCommand evalCommandType, String script, List keys, Object... params) { NodeSource source = getNodeSource(key);