diff --git a/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java b/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java index ff9cf9aa4..2931dc309 100644 --- a/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java +++ b/redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java @@ -133,9 +133,6 @@ public interface CommandAsyncExecutor { RFuture readRandomAsync(RedisClient client, Codec codec, RedisCommand command, Object... params); - RFuture async(boolean readOnlyMode, NodeSource source, Codec codec, - RedisCommand command, Object[] params, boolean ignoreRedirect, boolean noRetry); - RFuture pollFromAnyAsync(String name, Codec codec, RedisCommand command, long secondsTimeout, String... queueNames); ByteBuf encode(Codec codec, Object value); diff --git a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java index 983f3da7e..612c7b23c 100644 --- a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java +++ b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java @@ -632,7 +632,7 @@ public class CommandAsyncService implements CommandAsyncExecutor { private static final AtomicBoolean SORT_RO_SUPPORTED = new AtomicBoolean(true); - public RFuture async(boolean readOnlyMode, NodeSource source, Codec codec, + protected RFuture async(boolean readOnlyMode, NodeSource source, Codec codec, RedisCommand command, Object[] params, boolean ignoreRedirect, boolean noRetry) { RedisCommand cmnd = getServiceManager().resp3(command); diff --git a/redisson/src/main/java/org/redisson/reactive/CommandReactiveBatchService.java b/redisson/src/main/java/org/redisson/reactive/CommandReactiveBatchService.java index d36cd5205..92b1f4a7b 100644 --- a/redisson/src/main/java/org/redisson/reactive/CommandReactiveBatchService.java +++ b/redisson/src/main/java/org/redisson/reactive/CommandReactiveBatchService.java @@ -69,7 +69,7 @@ public class CommandReactiveBatchService extends CommandReactiveService implemen } @Override - public RFuture async(boolean readOnlyMode, NodeSource nodeSource, + protected RFuture async(boolean readOnlyMode, NodeSource nodeSource, Codec codec, RedisCommand command, Object[] params, boolean ignoreRedirect, boolean noRetry) { return batchService.async(readOnlyMode, nodeSource, codec, command, params, ignoreRedirect, noRetry); } diff --git a/redisson/src/main/java/org/redisson/rx/CommandRxBatchService.java b/redisson/src/main/java/org/redisson/rx/CommandRxBatchService.java index df7db48b8..0664abaa9 100644 --- a/redisson/src/main/java/org/redisson/rx/CommandRxBatchService.java +++ b/redisson/src/main/java/org/redisson/rx/CommandRxBatchService.java @@ -70,7 +70,7 @@ public class CommandRxBatchService extends CommandRxService implements BatchServ } @Override - public RFuture async(boolean readOnlyMode, NodeSource nodeSource, + protected RFuture async(boolean readOnlyMode, NodeSource nodeSource, Codec codec, RedisCommand command, Object[] params, boolean ignoreRedirect, boolean noRetry) { return batchService.async(readOnlyMode, nodeSource, codec, command, params, ignoreRedirect, noRetry); }