diff --git a/src/main/java/org/redisson/Redisson.java b/src/main/java/org/redisson/Redisson.java index 917c835c7f8..13f4f3cfd3b 100644 --- a/src/main/java/org/redisson/Redisson.java +++ b/src/main/java/org/redisson/Redisson.java @@ -15,29 +15,16 @@ */ package org.redisson; +import com.lambdaworks.redis.RedisAsyncConnection; import io.netty.util.concurrent.Future; - -import java.util.UUID; - import org.redisson.async.ResultOperation; import org.redisson.connection.ConnectionManager; import org.redisson.connection.MasterSlaveConnectionManager; import org.redisson.connection.SentinelConnectionManager; import org.redisson.connection.SingleConnectionManager; -import org.redisson.core.RAtomicLong; -import org.redisson.core.RBucket; -import org.redisson.core.RCountDownLatch; -import org.redisson.core.RDeque; -import org.redisson.core.RHyperLogLog; -import org.redisson.core.RList; -import org.redisson.core.RLock; -import org.redisson.core.RMap; -import org.redisson.core.RQueue; -import org.redisson.core.RSet; -import org.redisson.core.RSortedSet; -import org.redisson.core.RTopic; +import org.redisson.core.*; -import com.lambdaworks.redis.RedisAsyncConnection; +import java.util.UUID; /** * Main infrastructure class allows to get access @@ -46,7 +33,7 @@ * @author Nikita Koksharov * */ -public class Redisson { +public class Redisson implements RedissonClient { private final ConnectionManager connectionManager; private final Config config; @@ -94,6 +81,7 @@ public static Redisson create(Config config) { * @param name of object * @return */ + @Override public RBucket getBucket(String name) { return new RedissonBucket(connectionManager, name); } @@ -104,6 +92,7 @@ public RBucket getBucket(String name) { * @param name of object * @return */ + @Override public RHyperLogLog getHyperLogLog(String name) { return new RedissonHyperLogLog(connectionManager, name); } @@ -114,6 +103,7 @@ public RHyperLogLog getHyperLogLog(String name) { * @param name of the distributed list * @return distributed list */ + @Override public RList getList(String name) { return new RedissonList(connectionManager, name); } @@ -124,6 +114,7 @@ public RList getList(String name) { * @param name of the distributed map * @return distributed map */ + @Override public RMap getMap(String name) { return new RedissonMap(connectionManager, name); } @@ -134,6 +125,7 @@ public RMap getMap(String name) { * @param name of the distributed lock * @return distributed lock */ + @Override public RLock getLock(String name) { return new RedissonLock(connectionManager, name, id); } @@ -144,6 +136,7 @@ public RLock getLock(String name) { * @param name of the distributed set * @return distributed set */ + @Override public RSet getSet(String name) { return new RedissonSet(connectionManager, name); } @@ -154,6 +147,7 @@ public RSet getSet(String name) { * @param name of the distributed set * @return distributed set */ + @Override public RSortedSet getSortedSet(String name) { return new RedissonSortedSet(connectionManager, name); } @@ -164,6 +158,7 @@ public RSortedSet getSortedSet(String name) { * @param name of the distributed topic * @return distributed topic */ + @Override public RTopic getTopic(String name) { return new RedissonTopic(connectionManager, name); } @@ -174,6 +169,7 @@ public RTopic getTopic(String name) { * @param name of the distributed queue * @return distributed queue */ + @Override public RQueue getQueue(String name) { return new RedissonQueue(connectionManager, name); } @@ -184,6 +180,7 @@ public RQueue getQueue(String name) { * @param name of the distributed queue * @return distributed queue */ + @Override public RDeque getDeque(String name) { return new RedissonDeque(connectionManager, name); } @@ -194,6 +191,7 @@ public RDeque getDeque(String name) { * @param name of the distributed "atomic long" * @return distributed "atomic long" */ + @Override public RAtomicLong getAtomicLong(String name) { return new RedissonAtomicLong(connectionManager, name); } @@ -204,6 +202,7 @@ public RAtomicLong getAtomicLong(String name) { * @param name of the distributed "count down latch" * @return distributed "count down latch" */ + @Override public RCountDownLatch getCountDownLatch(String name) { return new RedissonCountDownLatch(connectionManager, name, id); } diff --git a/src/main/java/org/redisson/RedissonClient.java b/src/main/java/org/redisson/RedissonClient.java new file mode 100644 index 00000000000..6bf277626a9 --- /dev/null +++ b/src/main/java/org/redisson/RedissonClient.java @@ -0,0 +1,29 @@ +package org.redisson; + +import org.redisson.core.*; + +public interface RedissonClient { + RBucket getBucket(String name); + + RHyperLogLog getHyperLogLog(String name); + + RList getList(String name); + + RMap getMap(String name); + + RLock getLock(String name); + + RSet getSet(String name); + + RSortedSet getSortedSet(String name); + + RTopic getTopic(String name); + + RQueue getQueue(String name); + + RDeque getDeque(String name); + + RAtomicLong getAtomicLong(String name); + + RCountDownLatch getCountDownLatch(String name); +}