diff --git a/redisson/src/main/java/org/redisson/command/RedisExecutor.java b/redisson/src/main/java/org/redisson/command/RedisExecutor.java
index <HASH>..<HASH> 100644
--- a/redisson/src/main/java/org/redisson/command/RedisExecutor.java
+++ b/redisson/src/main/java/org/redisson/command/RedisExecutor.java
@@ -360,7 +360,7 @@ public class RedisExecutor<V, R> {
                         connection.forceFastReconnectAsync();
                     }
                 }
-            }, popTimeout, TimeUnit.SECONDS);
+            }, popTimeout + 1, TimeUnit.SECONDS);
         } else {
             scheduledFuture = null;
         }
Fixed - stream and queue object may lost entry during execution of any blocking poll operation. #<I>