From 57a4777ea0bca8bf72cc7125f8e2addbec5ae792 Mon Sep 17 00:00:00 2001 From: Nikita Date: Mon, 23 Nov 2015 15:15:47 +0300 Subject: [PATCH] RBatch.getBitSet method added --- src/main/java/org/redisson/RedissonBatch.java | 16 ++++++++++++++++ src/main/java/org/redisson/core/RBatch.java | 2 ++ 2 files changed, 18 insertions(+) diff --git a/src/main/java/org/redisson/RedissonBatch.java b/src/main/java/org/redisson/RedissonBatch.java index 51f25f890..8fba43983 100644 --- a/src/main/java/org/redisson/RedissonBatch.java +++ b/src/main/java/org/redisson/RedissonBatch.java @@ -21,6 +21,7 @@ import org.redisson.client.codec.Codec; import org.redisson.connection.ConnectionManager; import org.redisson.core.RAtomicLongAsync; import org.redisson.core.RBatch; +import org.redisson.core.RBitSetAsync; import org.redisson.core.RBlockingQueueAsync; import org.redisson.core.RBucketAsync; import org.redisson.core.RDequeAsync; @@ -50,6 +51,7 @@ public class RedissonBatch implements RBatch { return new RedissonBucket(executorService, name); } + @Override public RBucketAsync getBucket(String name, Codec codec) { return new RedissonBucket(codec, executorService, name); } @@ -59,6 +61,7 @@ public class RedissonBatch implements RBatch { return new RedissonHyperLogLog(executorService, name); } + @Override public RHyperLogLogAsync getHyperLogLog(String name, Codec codec) { return new RedissonHyperLogLog(codec, executorService, name); } @@ -68,6 +71,7 @@ public class RedissonBatch implements RBatch { return new RedissonList(executorService, name); } + @Override public RListAsync getList(String name, Codec codec) { return new RedissonList(codec, executorService, name); } @@ -77,6 +81,7 @@ public class RedissonBatch implements RBatch { return new RedissonMap(executorService, name); } + @Override public RMapAsync getMap(String name, Codec codec) { return new RedissonMap(codec, executorService, name); } @@ -86,6 +91,7 @@ public class RedissonBatch implements RBatch { return new RedissonSet(executorService, name); } + @Override public RSetAsync getSet(String name, Codec codec) { return new RedissonSet(codec, executorService, name); } @@ -95,6 +101,7 @@ public class RedissonBatch implements RBatch { return new RedissonTopic(executorService, name); } + @Override public RTopicAsync getTopic(String name, Codec codec) { return new RedissonTopic(codec, executorService, name); } @@ -104,6 +111,7 @@ public class RedissonBatch implements RBatch { return new RedissonQueue(executorService, name); } + @Override public RQueueAsync getQueue(String name, Codec codec) { return new RedissonQueue(codec, executorService, name); } @@ -113,6 +121,7 @@ public class RedissonBatch implements RBatch { return new RedissonBlockingQueue(executorService, name); } + @Override public RBlockingQueueAsync getBlockingQueue(String name, Codec codec) { return new RedissonBlockingQueue(codec, executorService, name); } @@ -122,6 +131,7 @@ public class RedissonBatch implements RBatch { return new RedissonDeque(executorService, name); } + @Override public RDequeAsync getDequeAsync(String name, Codec codec) { return new RedissonDeque(codec, executorService, name); } @@ -136,6 +146,7 @@ public class RedissonBatch implements RBatch { return new RedissonScoredSortedSet(executorService, name); } + @Override public RScoredSortedSetAsync getScoredSortedSet(String name, Codec codec) { return new RedissonScoredSortedSet(codec, executorService, name); } @@ -145,6 +156,11 @@ public class RedissonBatch implements RBatch { return new RedissonLexSortedSet(executorService, name); } + @Override + public RBitSetAsync getBitSet(String name) { + return new RedissonBitSet(executorService, name); + } + @Override public RScriptAsync getScript() { return new RedissonScript(executorService); diff --git a/src/main/java/org/redisson/core/RBatch.java b/src/main/java/org/redisson/core/RBatch.java index f4c23bdf8..7c1301126 100644 --- a/src/main/java/org/redisson/core/RBatch.java +++ b/src/main/java/org/redisson/core/RBatch.java @@ -154,6 +154,8 @@ public interface RBatch { */ RLexSortedSetAsync getLexSortedSet(String name); + RBitSetAsync getBitSet(String name); + /** * Returns script operations object *