RObject.isExists and RObject.isExistsAsync added. #316

redisson · Dec 8, 2015 · 52a0c62 · 52a0c62
1 parent c9dd022
commit 52a0c62
Show file tree

Hide file tree

Showing 6 changed files with 52 additions and 6 deletions.
diff --git a/src/main/java/org/redisson/RedissonBucket.java b/src/main/java/org/redisson/RedissonBucket.java
@@ -64,14 +64,24 @@ public Future<Void> 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<Boolean> existsAsync() {
+        return isExistsAsync();
     }
 
-    @Override
-    public Future<Boolean> 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
@@ -112,4 +112,14 @@ public Future<Boolean> deleteAsync() {
         return commandExecutor.writeAsync(getName(), RedisCommands.DEL_SINGLE, getName());
     }
 
+    @Override
+    public boolean isExists() {
+        return get(isExistsAsync());
+    }
+
+    @Override
+    public Future<Boolean> 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
@@ -32,6 +32,12 @@ public interface RBucket<V> extends RExpirable, RBucketAsync<V> {
 
     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
@@ -34,6 +34,12 @@ public interface RBucketAsync<V> extends RExpirableAsync {
 
     Future<Void> setAsync(V value, long timeToLive, TimeUnit timeUnit);
 
+    /**
+     * Use {@link #isExistsAsync()}
+     *
+     * @return
+     */
+    @Deprecated
     Future<Boolean> existsAsync();
 
 }
diff --git 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 <code>true</code> if object exists and <code>false</code> otherwise
+     */
+    boolean isExists();
+
 }
diff --git 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<Boolean> renamenxAsync(String newName);
 
+    /**
+     * Check object existence in async mode.
+     *
+     * @return <code>true</code> if object exists and <code>false</code> otherwise
+     */
+    Future<Boolean> isExistsAsync();
+
 }