From 49b23d4e28213c151685f9588acf14eca9c8e8d9 Mon Sep 17 00:00:00 2001 From: Nikita Date: Wed, 24 Aug 2016 15:09:06 +0300 Subject: [PATCH] compilation fixed --- .../org/redisson/misc/PromiseDelegator.java | 29 ++++++++++++++++--- .../org/redisson/misc/RedissonPromise.java | 5 ---- 2 files changed, 25 insertions(+), 9 deletions(-) diff --git a/redisson/src/main/java/org/redisson/misc/PromiseDelegator.java b/redisson/src/main/java/org/redisson/misc/PromiseDelegator.java index 9182b5a09..b6cf398ba 100644 --- a/redisson/src/main/java/org/redisson/misc/PromiseDelegator.java +++ b/redisson/src/main/java/org/redisson/misc/PromiseDelegator.java @@ -35,106 +35,127 @@ public class PromiseDelegator implements RPromise { return promise; } + @Override public RPromise setSuccess(T result) { return promise.setSuccess(result); } + @Override public boolean isSuccess() { return promise.isSuccess(); } + @Override public boolean trySuccess(T result) { return promise.trySuccess(result); } - public boolean isCancellable() { - return promise.isCancellable(); - } - + @Override public Throwable cause() { return promise.cause(); } + @Override public Promise setFailure(Throwable cause) { return promise.setFailure(cause); } + @Override public boolean tryFailure(Throwable cause) { return promise.tryFailure(cause); } + @Override public boolean setUncancellable() { return promise.setUncancellable(); } + @Override public RPromise addListener(FutureListener listener) { return promise.addListener(listener); } + @Override public RPromise addListeners(FutureListener... listeners) { return promise.addListeners(listeners); } + @Override public RPromise removeListener(FutureListener listener) { return promise.removeListener(listener); } + @Override public RPromise removeListeners(FutureListener... listeners) { return promise.removeListeners(listeners); } + @Override public RPromise await() throws InterruptedException { return promise.await(); } + @Override public RPromise awaitUninterruptibly() { return promise.awaitUninterruptibly(); } + @Override public RPromise sync() throws InterruptedException { return promise.sync(); } + @Override public RPromise syncUninterruptibly() { return promise.syncUninterruptibly(); } + @Override public boolean await(long timeout, TimeUnit unit) throws InterruptedException { return promise.await(timeout, unit); } + @Override public boolean isCancelled() { return promise.isCancelled(); } + @Override public boolean isDone() { return promise.isDone(); } + @Override public boolean await(long timeoutMillis) throws InterruptedException { return promise.await(timeoutMillis); } + @Override public T get() throws InterruptedException, ExecutionException { return promise.get(); } + @Override public boolean awaitUninterruptibly(long timeout, TimeUnit unit) { return promise.awaitUninterruptibly(timeout, unit); } + @Override public T get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException { return promise.get(timeout, unit); } + @Override public boolean awaitUninterruptibly(long timeoutMillis) { return promise.awaitUninterruptibly(timeoutMillis); } + @Override public T getNow() { return promise.getNow(); } + @Override public boolean cancel(boolean mayInterruptIfRunning) { return promise.cancel(mayInterruptIfRunning); } diff --git a/redisson/src/main/java/org/redisson/misc/RedissonPromise.java b/redisson/src/main/java/org/redisson/misc/RedissonPromise.java index d0c2c2902..95303e46e 100644 --- a/redisson/src/main/java/org/redisson/misc/RedissonPromise.java +++ b/redisson/src/main/java/org/redisson/misc/RedissonPromise.java @@ -56,11 +56,6 @@ public class RedissonPromise implements RPromise { return promise.trySuccess(result); } - @Override - public boolean isCancellable() { - return promise.isCancellable(); - } - @Override public Throwable cause() { return promise.cause();