RBatch.getBitSet method added

pull/297/head
Nikita 9 years ago
parent d22f862fcb
commit 57a4777ea0

@ -21,6 +21,7 @@ import org.redisson.client.codec.Codec;
import org.redisson.connection.ConnectionManager; import org.redisson.connection.ConnectionManager;
import org.redisson.core.RAtomicLongAsync; import org.redisson.core.RAtomicLongAsync;
import org.redisson.core.RBatch; import org.redisson.core.RBatch;
import org.redisson.core.RBitSetAsync;
import org.redisson.core.RBlockingQueueAsync; import org.redisson.core.RBlockingQueueAsync;
import org.redisson.core.RBucketAsync; import org.redisson.core.RBucketAsync;
import org.redisson.core.RDequeAsync; import org.redisson.core.RDequeAsync;
@ -50,6 +51,7 @@ public class RedissonBatch implements RBatch {
return new RedissonBucket<V>(executorService, name); return new RedissonBucket<V>(executorService, name);
} }
@Override
public <V> RBucketAsync<V> getBucket(String name, Codec codec) { public <V> RBucketAsync<V> getBucket(String name, Codec codec) {
return new RedissonBucket<V>(codec, executorService, name); return new RedissonBucket<V>(codec, executorService, name);
} }
@ -59,6 +61,7 @@ public class RedissonBatch implements RBatch {
return new RedissonHyperLogLog<V>(executorService, name); return new RedissonHyperLogLog<V>(executorService, name);
} }
@Override
public <V> RHyperLogLogAsync<V> getHyperLogLog(String name, Codec codec) { public <V> RHyperLogLogAsync<V> getHyperLogLog(String name, Codec codec) {
return new RedissonHyperLogLog<V>(codec, executorService, name); return new RedissonHyperLogLog<V>(codec, executorService, name);
} }
@ -68,6 +71,7 @@ public class RedissonBatch implements RBatch {
return new RedissonList<V>(executorService, name); return new RedissonList<V>(executorService, name);
} }
@Override
public <V> RListAsync<V> getList(String name, Codec codec) { public <V> RListAsync<V> getList(String name, Codec codec) {
return new RedissonList<V>(codec, executorService, name); return new RedissonList<V>(codec, executorService, name);
} }
@ -77,6 +81,7 @@ public class RedissonBatch implements RBatch {
return new RedissonMap<K, V>(executorService, name); return new RedissonMap<K, V>(executorService, name);
} }
@Override
public <K, V> RMapAsync<K, V> getMap(String name, Codec codec) { public <K, V> RMapAsync<K, V> getMap(String name, Codec codec) {
return new RedissonMap<K, V>(codec, executorService, name); return new RedissonMap<K, V>(codec, executorService, name);
} }
@ -86,6 +91,7 @@ public class RedissonBatch implements RBatch {
return new RedissonSet<V>(executorService, name); return new RedissonSet<V>(executorService, name);
} }
@Override
public <V> RSetAsync<V> getSet(String name, Codec codec) { public <V> RSetAsync<V> getSet(String name, Codec codec) {
return new RedissonSet<V>(codec, executorService, name); return new RedissonSet<V>(codec, executorService, name);
} }
@ -95,6 +101,7 @@ public class RedissonBatch implements RBatch {
return new RedissonTopic<M>(executorService, name); return new RedissonTopic<M>(executorService, name);
} }
@Override
public <M> RTopicAsync<M> getTopic(String name, Codec codec) { public <M> RTopicAsync<M> getTopic(String name, Codec codec) {
return new RedissonTopic<M>(codec, executorService, name); return new RedissonTopic<M>(codec, executorService, name);
} }
@ -104,6 +111,7 @@ public class RedissonBatch implements RBatch {
return new RedissonQueue<V>(executorService, name); return new RedissonQueue<V>(executorService, name);
} }
@Override
public <V> RQueueAsync<V> getQueue(String name, Codec codec) { public <V> RQueueAsync<V> getQueue(String name, Codec codec) {
return new RedissonQueue<V>(codec, executorService, name); return new RedissonQueue<V>(codec, executorService, name);
} }
@ -113,6 +121,7 @@ public class RedissonBatch implements RBatch {
return new RedissonBlockingQueue<V>(executorService, name); return new RedissonBlockingQueue<V>(executorService, name);
} }
@Override
public <V> RBlockingQueueAsync<V> getBlockingQueue(String name, Codec codec) { public <V> RBlockingQueueAsync<V> getBlockingQueue(String name, Codec codec) {
return new RedissonBlockingQueue<V>(codec, executorService, name); return new RedissonBlockingQueue<V>(codec, executorService, name);
} }
@ -122,6 +131,7 @@ public class RedissonBatch implements RBatch {
return new RedissonDeque<V>(executorService, name); return new RedissonDeque<V>(executorService, name);
} }
@Override
public <V> RDequeAsync<V> getDequeAsync(String name, Codec codec) { public <V> RDequeAsync<V> getDequeAsync(String name, Codec codec) {
return new RedissonDeque<V>(codec, executorService, name); return new RedissonDeque<V>(codec, executorService, name);
} }
@ -136,6 +146,7 @@ public class RedissonBatch implements RBatch {
return new RedissonScoredSortedSet<V>(executorService, name); return new RedissonScoredSortedSet<V>(executorService, name);
} }
@Override
public <V> RScoredSortedSetAsync<V> getScoredSortedSet(String name, Codec codec) { public <V> RScoredSortedSetAsync<V> getScoredSortedSet(String name, Codec codec) {
return new RedissonScoredSortedSet<V>(codec, executorService, name); return new RedissonScoredSortedSet<V>(codec, executorService, name);
} }
@ -145,6 +156,11 @@ public class RedissonBatch implements RBatch {
return new RedissonLexSortedSet(executorService, name); return new RedissonLexSortedSet(executorService, name);
} }
@Override
public RBitSetAsync getBitSet(String name) {
return new RedissonBitSet(executorService, name);
}
@Override @Override
public RScriptAsync getScript() { public RScriptAsync getScript() {
return new RedissonScript(executorService); return new RedissonScript(executorService);

@ -154,6 +154,8 @@ public interface RBatch {
*/ */
RLexSortedSetAsync getLexSortedSet(String name); RLexSortedSetAsync getLexSortedSet(String name);
RBitSetAsync getBitSet(String name);
/** /**
* Returns script operations object * Returns script operations object
* *

Loading…
Cancel
Save