diff --git a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java index 3b97db24f..be846876b 100644 --- a/redisson/src/main/java/org/redisson/command/CommandAsyncService.java +++ b/redisson/src/main/java/org/redisson/command/CommandAsyncService.java @@ -410,38 +410,6 @@ public class CommandAsyncService implements CommandAsyncExecutor { return evalAsync(new NodeSource(entry), false, codec, evalCommandType, script, keys, false, params); } - public RFuture evalAllAsync(boolean readOnlyMode, RedisCommand command, SlotCallback callback, String script, List keys, Object... params) { - RPromise mainPromise = new RedissonPromise(); - Collection entries = connectionManager.getEntrySet(); - AtomicInteger counter = new AtomicInteger(entries.size()); - BiConsumer listener = new BiConsumer() { - @Override - public void accept(T t, Throwable u) { - if (u != null && !(u instanceof RedisRedirectException)) { - mainPromise.tryFailure(u); - return; - } - - callback.onSlotResult(t); - if (counter.decrementAndGet() == 0 - && !mainPromise.isDone()) { - mainPromise.trySuccess(callback.onFinish()); - } - } - }; - - List args = new ArrayList(2 + keys.size() + params.length); - args.add(script); - args.add(keys.size()); - args.addAll(keys); - args.addAll(Arrays.asList(params)); - for (MasterSlaveEntry entry : entries) { - RFuture promise = async(readOnlyMode, new NodeSource(entry), connectionManager.getCodec(), command, args.toArray(), true, false); - promise.whenComplete(listener); - } - return mainPromise; - } - private RFuture loadScript(RedisClient client, String script) { MasterSlaveEntry entry = getConnectionManager().getEntry(client); if (entry.getClient().equals(client)) {