diff --git a/redisson/src/main/java/org/redisson/api/RQueueReactive.java b/redisson/src/main/java/org/redisson/api/RQueueReactive.java
index 941ebee2a..8219df816 100644
--- a/redisson/src/main/java/org/redisson/api/RQueueReactive.java
+++ b/redisson/src/main/java/org/redisson/api/RQueueReactive.java
@@ -49,7 +49,7 @@ public interface RQueueReactive<V> extends RCollectionReactive<V> {
      *
      * @return list of head elements
      */
-    Flux<V> poll(int limit);
+    Mono<List<V>> poll(int limit);
 
     /**
      * Inserts the specified element into this queue.
diff --git a/redisson/src/main/java/org/redisson/api/RQueueRx.java b/redisson/src/main/java/org/redisson/api/RQueueRx.java
index 0138811df..ead27ee0f 100644
--- a/redisson/src/main/java/org/redisson/api/RQueueRx.java
+++ b/redisson/src/main/java/org/redisson/api/RQueueRx.java
@@ -50,7 +50,7 @@ public interface RQueueRx<V> extends RCollectionRx<V> {
      *
      * @return list of head elements
      */
-    Flowable<V> poll(int limit);
+    Single<List<V>> poll(int limit);
 
     /**
      * Inserts the specified element into this queue.