Fixed - stream and queue object may lost entry during execution of any blocking poll operation. #3302

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;
         }