Skip to content

Commit b0b6ae8

Browse files
committed
feat(impv): Add pending method to StreamOperations
1 parent 3c0ca2c commit b0b6ae8

File tree

2 files changed

+19
-0
lines changed

2 files changed

+19
-0
lines changed

src/main/java/org/springframework/data/redis/core/DefaultStreamOperations.java

Lines changed: 15 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
package org.springframework.data.redis.core;
1717

1818
import java.nio.charset.StandardCharsets;
19+
import java.time.Duration;
1920
import java.util.ArrayList;
2021
import java.util.Arrays;
2122
import java.util.Collections;
@@ -222,13 +223,27 @@ public PendingMessages pending(K key, String group, Range<?> range, long count)
222223
return execute(connection -> connection.xPending(rawKey, group, range, count));
223224
}
224225

226+
@Override
227+
public PendingMessages pending(K key, String group, Range<?> range, long count, Duration idle) {
228+
229+
byte[] rawKey = rawKey(key);
230+
return execute(connection -> connection.xPending(rawKey, group, range, count, idle));
231+
}
232+
225233
@Override
226234
public PendingMessages pending(K key, Consumer consumer, Range<?> range, long count) {
227235

228236
byte[] rawKey = rawKey(key);
229237
return execute(connection -> connection.xPending(rawKey, consumer, range, count));
230238
}
231239

240+
@Override
241+
public PendingMessages pending(K key, Consumer consumer, Range<?> range, long count, Duration idle) {
242+
243+
byte[] rawKey = rawKey(key);
244+
return execute(connection -> connection.xPending(rawKey, consumer, range, count, idle));
245+
}
246+
232247
@Override
233248
public PendingMessagesSummary pending(K key, String group) {
234249

src/main/java/org/springframework/data/redis/core/StreamOperations.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -376,6 +376,8 @@ default PendingMessages pending(K key, Consumer consumer) {
376376
*/
377377
PendingMessages pending(K key, String group, Range<?> range, long count);
378378

379+
PendingMessages pending(K key, String group, Range<?> range, long count, Duration idle);
380+
379381
/**
380382
* Obtain detailed information about pending {@link PendingMessage messages} for a given {@link Range} and
381383
* {@link Consumer} within a {@literal consumer group}.
@@ -390,6 +392,8 @@ default PendingMessages pending(K key, Consumer consumer) {
390392
*/
391393
PendingMessages pending(K key, Consumer consumer, Range<?> range, long count);
392394

395+
PendingMessages pending(K key, Consumer consumer, Range<?> range, long count, Duration idle);
396+
393397
/**
394398
* Get the length of a stream.
395399
*

0 commit comments

Comments
 (0)