diff --git a/src/main/java/org/redisson/RedissonBucket.java b/src/main/java/org/redisson/RedissonBucket.java index 58860f4e0a5..5f6b4ece68b 100644 --- a/src/main/java/org/redisson/RedissonBucket.java +++ b/src/main/java/org/redisson/RedissonBucket.java @@ -64,14 +64,24 @@ public Future setAsync(V value, long timeToLive, TimeUnit timeUnit) { return commandExecutor.writeAsync(getName(), codec, RedisCommands.SETEX, getName(), timeUnit.toSeconds(timeToLive), value); } - @Override - public boolean exists() { - return get(existsAsync()); + /** + * Use {@link #isExistsAsync()} + * + * @return + */ + @Deprecated + public Future existsAsync() { + return isExistsAsync(); } - @Override - public Future existsAsync() { - return commandExecutor.readAsync(getName(), codec, RedisCommands.EXISTS, getName()); + /** + * Use {@link #isExists()} + * + * @return + */ + @Deprecated + public boolean exists() { + return isExists(); } } diff --git a/src/main/java/org/redisson/RedissonObject.java b/src/main/java/org/redisson/RedissonObject.java index 39d68da0970..07c85e825bd 100644 --- a/src/main/java/org/redisson/RedissonObject.java +++ b/src/main/java/org/redisson/RedissonObject.java @@ -112,4 +112,14 @@ public Future deleteAsync() { return commandExecutor.writeAsync(getName(), RedisCommands.DEL_SINGLE, getName()); } + @Override + public boolean isExists() { + return get(isExistsAsync()); + } + + @Override + public Future isExistsAsync() { + return commandExecutor.readAsync(getName(), codec, RedisCommands.EXISTS, getName()); + } + } diff --git a/src/main/java/org/redisson/core/RBucket.java b/src/main/java/org/redisson/core/RBucket.java index dea49cfdc95..126da8d26dd 100644 --- a/src/main/java/org/redisson/core/RBucket.java +++ b/src/main/java/org/redisson/core/RBucket.java @@ -32,6 +32,12 @@ public interface RBucket extends RExpirable, RBucketAsync { void set(V value, long timeToLive, TimeUnit timeUnit); + /** + * Use {@link #isExists()} + * + * @return + */ + @Deprecated boolean exists(); } diff --git a/src/main/java/org/redisson/core/RBucketAsync.java b/src/main/java/org/redisson/core/RBucketAsync.java index efb5c3ea9bd..10950102799 100644 --- a/src/main/java/org/redisson/core/RBucketAsync.java +++ b/src/main/java/org/redisson/core/RBucketAsync.java @@ -34,6 +34,12 @@ public interface RBucketAsync extends RExpirableAsync { Future setAsync(V value, long timeToLive, TimeUnit timeUnit); + /** + * Use {@link #isExistsAsync()} + * + * @return + */ + @Deprecated Future existsAsync(); } diff --git a/src/main/java/org/redisson/core/RObject.java b/src/main/java/org/redisson/core/RObject.java index e01383fd826..51a49b0d0f2 100644 --- a/src/main/java/org/redisson/core/RObject.java +++ b/src/main/java/org/redisson/core/RObject.java @@ -69,4 +69,11 @@ public interface RObject extends RObjectAsync { */ boolean renamenx(String newName); + /** + * Check object existence + * + * @return true if object exists and false otherwise + */ + boolean isExists(); + } diff --git a/src/main/java/org/redisson/core/RObjectAsync.java b/src/main/java/org/redisson/core/RObjectAsync.java index a9b32f3650d..0909f58a019 100644 --- a/src/main/java/org/redisson/core/RObjectAsync.java +++ b/src/main/java/org/redisson/core/RObjectAsync.java @@ -69,4 +69,11 @@ public interface RObjectAsync { */ Future renamenxAsync(String newName); + /** + * Check object existence in async mode. + * + * @return true if object exists and false otherwise + */ + Future isExistsAsync(); + }