Blocking queues are't rethrow exceptions. #1096

redisson/src/main/java/org/redisson/RedissonBlockingDeque.java

@@ -126,8 +126,7 @@ public class RedissonBlockingDeque<V> extends RedissonDeque<V> implements RBlock
     
     @Override
     public V takeLastAndOfferFirstTo(String queueName) throws InterruptedException {
-        RFuture<V> res = takeLastAndOfferFirstToAsync(queueName);
-        return res.await().getNow();
+        return get(takeLastAndOfferFirstToAsync(queueName));
     }
     
     @Override
@@ -194,8 +193,7 @@ public class RedissonBlockingDeque<V> extends RedissonDeque<V> implements RBlock
 
     @Override
     public V takeFirst() throws InterruptedException {
-        RFuture<V> res = takeFirstAsync();
-        return res.await().getNow();
+        return get(takeFirstAsync());
     }
 
     @Override
@@ -210,8 +208,7 @@ public class RedissonBlockingDeque<V> extends RedissonDeque<V> implements RBlock
 
     @Override
     public V takeLast() throws InterruptedException {
-        RFuture<V> res = takeLastAsync();
-        return res.await().getNow();
+        return get(takeLastAsync());
     }
 
     @Override
@@ -221,8 +218,7 @@ public class RedissonBlockingDeque<V> extends RedissonDeque<V> implements RBlock
 
     @Override
     public V pollFirstFromAny(long timeout, TimeUnit unit, String ... queueNames) throws InterruptedException {
-        RFuture<V> res = pollFirstFromAnyAsync(timeout, unit, queueNames);
-        return res.await().getNow();
+        return get(pollFirstFromAnyAsync(timeout, unit, queueNames));
     }
 
     @Override
@@ -232,8 +228,7 @@ public class RedissonBlockingDeque<V> extends RedissonDeque<V> implements RBlock
 
     @Override
     public V pollLastFromAny(long timeout, TimeUnit unit, String ... queueNames) throws InterruptedException {
-        RFuture<V> res = pollLastFromAnyAsync(timeout, unit, queueNames);
-        return res.await().getNow();
+        return get(pollLastFromAnyAsync(timeout, unit, queueNames));
     }
 
     @Override
@@ -249,8 +244,7 @@ public class RedissonBlockingDeque<V> extends RedissonDeque<V> implements RBlock
 
     @Override
     public V pollFirst(long timeout, TimeUnit unit) throws InterruptedException {
-        RFuture<V> res = pollFirstAsync(timeout, unit);
-        return res.await().getNow();
+        return get(pollFirstAsync(timeout, unit));
     }
 
     @Override
@@ -260,8 +254,7 @@ public class RedissonBlockingDeque<V> extends RedissonDeque<V> implements RBlock
 
     @Override
     public V pollLast(long timeout, TimeUnit unit) throws InterruptedException {
-        RFuture<V> res = pollLastAsync(timeout, unit);
-        return res.await().getNow();
+        return get(pollLastAsync(timeout, unit));
    }
 
 }

redisson/src/main/java/org/redisson/RedissonBlockingQueue.java

@@ -79,8 +79,7 @@ public class RedissonBlockingQueue<V> extends RedissonQueue<V> implements RBlock
      */
     @Override
     public V take() throws InterruptedException {
-        RFuture<V> res = takeAsync();
-        return res.await().getNow();
+        return get(takeAsync());
     }
 
     @Override
@@ -94,8 +93,7 @@ public class RedissonBlockingQueue<V> extends RedissonQueue<V> implements RBlock
      */
     @Override
     public V poll(long timeout, TimeUnit unit) throws InterruptedException {
-        RFuture<V> res = pollAsync(timeout, unit);
-        return res.await().getNow();
+        return get(pollAsync(timeout, unit));
     }
 
     /*
@@ -104,8 +102,7 @@ public class RedissonBlockingQueue<V> extends RedissonQueue<V> implements RBlock
      */
     @Override
     public V pollFromAny(long timeout, TimeUnit unit, String ... queueNames) throws InterruptedException {
-        RFuture<V> res = pollFromAnyAsync(timeout, unit, queueNames);
-        return res.await().getNow();
+        return get(pollFromAnyAsync(timeout, unit, queueNames));
     }
 
     /*
@@ -130,14 +127,12 @@ public class RedissonBlockingQueue<V> extends RedissonQueue<V> implements RBlock
 
     @Override
     public V pollLastAndOfferFirstTo(String queueName, long timeout, TimeUnit unit) throws InterruptedException {
-        RFuture<V> res = pollLastAndOfferFirstToAsync(queueName, timeout, unit);
-        return res.await().getNow();
+        return get(pollLastAndOfferFirstToAsync(queueName, timeout, unit));
     }
     
     @Override
     public V takeLastAndOfferFirstTo(String queueName) throws InterruptedException {
-        RFuture<V> res = takeLastAndOfferFirstToAsync(queueName);
-        return res.await().getNow();
+        return get(takeLastAndOfferFirstToAsync(queueName));
     }
     
     @Override

redisson/src/main/java/org/redisson/RedissonBoundedBlockingQueue.java

@@ -31,7 +31,6 @@ import org.redisson.client.protocol.RedisCommand;
 import org.redisson.client.protocol.RedisCommands;
 import org.redisson.command.CommandExecutor;
 import org.redisson.connection.decoder.ListDrainToDecoder;
-import org.redisson.misc.PromiseDelegator;
 import org.redisson.misc.RPromise;
 import org.redisson.misc.RedissonPromise;
 import org.redisson.pubsub.SemaphorePubSub;
@@ -256,8 +255,7 @@ public class RedissonBoundedBlockingQueue<V> extends RedissonQueue<V> implements
 
     @Override
     public V takeLastAndOfferFirstTo(String queueName) throws InterruptedException {
-        RFuture<V> res = takeLastAndOfferFirstToAsync(queueName);
-        return res.await().getNow();
+        return get(takeLastAndOfferFirstToAsync(queueName));
     }
     
     @Override