Fixed - RTopicRx.getMessages error handling

6 years ago · dcd9dcaaef
parent 045c2c2e2a
commit dcd9dcaaef
1 changed files with 1 additions and 0 deletions
--- a/redisson/src/main/java/org/redisson/rx/RedissonTopicRx.java
+++ b/redisson/src/main/java/org/redisson/rx/RedissonTopicRx.java
@ -61,6 +61,7 @@ public class RedissonTopicRx {
                    @Override
                    public void operationComplete(Future<Integer> future) throws Exception {
                        if (!future.isSuccess()) {
+                            p.onError(future.cause());
                            return;
                        }