refactoring

redisson/src/main/java/org/redisson/command/CommandAsyncExecutor.java

@@ -133,9 +133,6 @@ public interface CommandAsyncExecutor {
 
     <T, R> RFuture<R> readRandomAsync(RedisClient client, Codec codec, RedisCommand<T> command, Object... params);
 
-    <V, R> RFuture<R> async(boolean readOnlyMode, NodeSource source, Codec codec,
-                            RedisCommand<V> command, Object[] params, boolean ignoreRedirect, boolean noRetry);
-
     <V> RFuture<V> pollFromAnyAsync(String name, Codec codec, RedisCommand<?> command, long secondsTimeout, String... queueNames);
 
     ByteBuf encode(Codec codec, Object value);

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 <V, R> RFuture<R> async(boolean readOnlyMode, NodeSource source, Codec codec,
+    protected <V, R> RFuture<R> async(boolean readOnlyMode, NodeSource source, Codec codec,
             RedisCommand<V> command, Object[] params, boolean ignoreRedirect, boolean noRetry) {
         RedisCommand<V> cmnd = getServiceManager().resp3(command);
 

redisson/src/main/java/org/redisson/reactive/CommandReactiveBatchService.java

@@ -69,7 +69,7 @@ public class CommandReactiveBatchService extends CommandReactiveService implemen
     }
     
     @Override
-    public <V, R> RFuture<R> async(boolean readOnlyMode, NodeSource nodeSource,
+    protected <V, R> RFuture<R> async(boolean readOnlyMode, NodeSource nodeSource,
                                         Codec codec, RedisCommand<V> command, Object[] params, boolean ignoreRedirect, boolean noRetry) {
         return batchService.async(readOnlyMode, nodeSource, codec, command, params, ignoreRedirect, noRetry);
     }

redisson/src/main/java/org/redisson/rx/CommandRxBatchService.java

@@ -70,7 +70,7 @@ public class CommandRxBatchService extends CommandRxService implements BatchServ
     }
     
     @Override
-    public <V, R> RFuture<R> async(boolean readOnlyMode, NodeSource nodeSource,
+    protected <V, R> RFuture<R> async(boolean readOnlyMode, NodeSource nodeSource,
             Codec codec, RedisCommand<V> command, Object[] params, boolean ignoreRedirect, boolean noRetry) {
         return batchService.async(readOnlyMode, nodeSource, codec, command, params, ignoreRedirect, noRetry);
     }