subscription fixed

11 years ago · ee98023399
parent 59e5749e11
commit ee98023399
1 changed files with 3 additions and 1 deletions
--- a/src/main/java/org/redisson/RedissonCountDownLatch.java
+++ b/src/main/java/org/redisson/RedissonCountDownLatch.java
@ -106,7 +106,9 @@ public class RedissonCountDownLatch extends RedissonObject implements RCountDown

    @Override
    public boolean await(long time, TimeUnit unit) throws InterruptedException {
-        subscribe().await(time, unit);
+        if (!subscribe().await(time, unit)) {
+            return false;
+        }

        time = unit.toMillis(time);
        while (getCount() > 0) {