Package org.redisson.api.stream
Class StreamPendingRangeParams
java.lang.Object
org.redisson.api.stream.StreamPendingRangeParams
- All Implemented Interfaces:
StreamCountArgs,StreamEndIdArgs<StreamCountArgs>,StreamPendingRangeArgs,StreamStartIdArgs<StreamCountArgs>
public class StreamPendingRangeParams
extends Object
implements StreamPendingRangeArgs, StreamStartIdArgs<StreamCountArgs>, StreamEndIdArgs<StreamCountArgs>, StreamCountArgs
- Author:
- seakider
-
Method Summary
Modifier and TypeMethodDescriptionconsumerName(String consumerName) Defines consumerName of pending messagescount(int count) Defines messages count limit.endId(StreamMessageId endId) Defines endId in range inclusiveendIdExclusive(StreamMessageId endId) Defines endId in range exclusiveintgetCount()getEndId()Defines minimum idle time limit.booleanbooleanstartId(StreamMessageId startId) Defines startId in range inclusivestartIdExclusive(StreamMessageId startId) Defines startId in range exclusive
-
Method Details
-
consumerName
Description copied from interface:StreamPendingRangeArgsDefines consumerName of pending messages- Specified by:
consumerNamein interfaceStreamPendingRangeArgs- Parameters:
consumerName- name of consumer- Returns:
- arguments object
-
idleTime
Description copied from interface:StreamPendingRangeArgsDefines minimum idle time limit.- Specified by:
idleTimein interfaceStreamPendingRangeArgs- Parameters:
idleTime- minimum idle time of messages- Returns:
- arguments object
-
count
Description copied from interface:StreamCountArgsDefines messages count limit.- Specified by:
countin interfaceStreamCountArgs- Parameters:
count- amount of messages- Returns:
- next options
-
endId
Description copied from interface:StreamEndIdArgsDefines endId in range inclusive- Specified by:
endIdin interfaceStreamEndIdArgs<StreamCountArgs>- Parameters:
endId-- Returns:
- next options
-
endIdExclusive
Description copied from interface:StreamEndIdArgsDefines endId in range exclusive- Specified by:
endIdExclusivein interfaceStreamEndIdArgs<StreamCountArgs>- Parameters:
endId-- Returns:
- next options
-
startId
Description copied from interface:StreamStartIdArgsDefines startId in range inclusive- Specified by:
startIdin interfaceStreamStartIdArgs<StreamCountArgs>- Parameters:
startId-- Returns:
- next options
-
startIdExclusive
Description copied from interface:StreamStartIdArgsDefines startId in range exclusive- Specified by:
startIdExclusivein interfaceStreamStartIdArgs<StreamCountArgs>- Parameters:
startId-- Returns:
- next options
-
getGroupName
-
getStartId
-
getEndId
-
isStartIdExclusive
public boolean isStartIdExclusive() -
isEndIdExclusive
public boolean isEndIdExclusive() -
getCount
public int getCount() -
getConsumerName
-
getIdleTime
-