Package org.redisson.api.stream
Interface StreamReadGroupArgs
-
public interface StreamReadGroupArgsArguments object for RStream.readGroup() methods.- Author:
- Nikita Koksharov
-
-
Method Summary
All Methods Static Methods Instance Methods Abstract Methods Modifier and Type Method Description StreamReadGroupArgscount(int count)Defines stream data size limit.static StreamReadGroupArgsgreaterThan(StreamMessageId id)Defines to return messages of current Stream with ids greater than defined message id.static StreamReadGroupArgsneverDelivered()Defines to return messages of current Stream never delivered to any other consumer.StreamReadGroupArgsnoAck()Defines avoid of adding messages to Pending Entries List.StreamReadGroupArgstimeout(Duration timeout)Defines time interval to wait for stream data availability.
-
-
-
Method Detail
-
noAck
StreamReadGroupArgs noAck()
Defines avoid of adding messages to Pending Entries List.- Returns:
- arguments object
-
count
StreamReadGroupArgs count(int count)
Defines stream data size limit.- Parameters:
count- - stream data size limit- Returns:
- arguments object
-
timeout
StreamReadGroupArgs timeout(Duration timeout)
Defines time interval to wait for stream data availability.- Parameters:
timeout- - timeout duration- Returns:
- arguments object
-
neverDelivered
static StreamReadGroupArgs neverDelivered()
Defines to return messages of current Stream never delivered to any other consumer.- Returns:
- arguments object
-
greaterThan
static StreamReadGroupArgs greaterThan(StreamMessageId id)
Defines to return messages of current Stream with ids greater than defined message id.- Parameters:
id- - message id- Returns:
- arguments object
-
-