RBlockingDeque added to RBatch. #320

src/main/java/org/redisson/RedissonBatch.java

@@ -23,6 +23,7 @@ import org.redisson.connection.ConnectionManager;
 import org.redisson.core.RAtomicLongAsync;
 import org.redisson.core.RBatch;
 import org.redisson.core.RBitSetAsync;
+import org.redisson.core.RBlockingDequeAsync;
 import org.redisson.core.RBlockingQueueAsync;
 import org.redisson.core.RBucketAsync;
 import org.redisson.core.RMapCacheAsync;
@@ -138,17 +139,27 @@ public class RedissonBatch implements RBatch {
     }
 
     @Override
-    public <V> RDequeAsync<V> getDequeAsync(String name) {
+    public <V> RBlockingDequeAsync<V> getBlockingDeque(String name) {
+        return new RedissonBlockingDeque<V>(executorService, name);
+    }
+
+    @Override
+    public <V> RBlockingDequeAsync<V> getBlockingDeque(String name, Codec codec) {
+        return new RedissonBlockingDeque<V>(codec, executorService, name);
+    }
+
+    @Override
+    public <V> RDequeAsync<V> getDeque(String name) {
         return new RedissonDeque<V>(executorService, name);
     }
 
     @Override
-    public <V> RDequeAsync<V> getDequeAsync(String name, Codec codec) {
+    public <V> RDequeAsync<V> getDeque(String name, Codec codec) {
         return new RedissonDeque<V>(codec, executorService, name);
     }
 
     @Override
-    public RAtomicLongAsync getAtomicLongAsync(String name) {
+    public RAtomicLongAsync getAtomicLong(String name) {
         return new RedissonAtomicLong(executorService, name);
     }
 

src/main/java/org/redisson/RedissonClient.java

@@ -467,7 +467,7 @@ public interface RedissonClient {
     RBatch createBatch();
 
     /**
-     * Returns keys operations.
+     * Returns interface with methods for Redis keys.
      * Each of Redis/Redisson object associated with own key
      *
      * @return

src/main/java/org/redisson/core/RBatch.java

@@ -172,9 +172,19 @@ public interface RBatch {
      * @param name of deque
      * @return
      */
-    <V> RDequeAsync<V> getDequeAsync(String name);
+    <V> RDequeAsync<V> getDeque(String name);
 
-    <V> RDequeAsync<V> getDequeAsync(String name, Codec codec);
+    <V> RDequeAsync<V> getDeque(String name, Codec codec);
+
+    /**
+     * Returns blocking deque instance by name.
+     *
+     * @param name of queue
+     * @return
+     */
+    <V> RBlockingDequeAsync<V> getBlockingDeque(String name);
+
+    <V> RBlockingDequeAsync<V> getBlockingDeque(String name, Codec codec);
 
     /**
      * Returns "atomic long" instance by name.
@@ -182,7 +192,7 @@ public interface RBatch {
      * @param name of the "atomic long"
      * @return
      */
-    RAtomicLongAsync getAtomicLongAsync(String name);
+    RAtomicLongAsync getAtomicLong(String name);
 
     /**
      * Returns Redis Sorted Set instance by name

src/test/java/org/redisson/RedissonBatchTest.java

@@ -48,8 +48,8 @@ public class RedissonBatchTest extends BaseTest {
             batch.getMap("test").fastPutAsync("1", "2");
             batch.getMap("test").fastPutAsync("2", "3");
             batch.getMap("test").putAsync("2", "5");
-            batch.getAtomicLongAsync("counter").incrementAndGetAsync();
+            batch.getAtomicLong("counter").incrementAndGetAsync();
-            batch.getAtomicLongAsync("counter").incrementAndGetAsync();
+            batch.getAtomicLong("counter").incrementAndGetAsync();
         }
         List<?> res = batch.execute();
         Assert.assertEquals(210*5, res.size());
@@ -84,8 +84,8 @@ public class RedissonBatchTest extends BaseTest {
         batch.getMap("test").fastPutAsync("1", "2");
         batch.getMap("test").fastPutAsync("2", "3");
         batch.getMap("test").putAsync("2", "5");
-        batch.getAtomicLongAsync("counter").incrementAndGetAsync();
+        batch.getAtomicLong("counter").incrementAndGetAsync();
-        batch.getAtomicLongAsync("counter").incrementAndGetAsync();
+        batch.getAtomicLong("counter").incrementAndGetAsync();
 
         List<?> res = batch.execute();
         Assert.assertEquals(5, res.size());