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 Type	Method	Description
StreamPendingRangeArgs	consumerName(String consumerName)	Defines consumerName of pending messages
StreamPendingRangeArgs	count(int count)	Defines messages count limit.
StreamCountArgs	endId(StreamMessageId endId)	Defines endId in range inclusive
StreamCountArgs	endIdExclusive(StreamMessageId endId)	Defines endId in range exclusive
String	getConsumerName()
int	getCount()
StreamMessageId	getEndId()
String	getGroupName()
Duration	getIdleTime()
StreamMessageId	getStartId()
StreamPendingRangeArgs	idleTime(Duration idleTime)	Defines minimum idle time limit.
boolean	isEndIdExclusive()
boolean	isStartIdExclusive()
StreamEndIdArgs<StreamCountArgs>	startId(StreamMessageId startId)	Defines startId in range inclusive
StreamEndIdArgs<StreamCountArgs>	startIdExclusive(StreamMessageId startId)	Defines startId in range exclusive

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

consumerName

public StreamPendingRangeArgs consumerName(String consumerName)

Description copied from interface: StreamPendingRangeArgs

Defines consumerName of pending messages

Specified by:

consumerName in interface StreamPendingRangeArgs

Parameters:

consumerName - name of consumer

Returns:

arguments object

idleTime

public StreamPendingRangeArgs idleTime(Duration idleTime)

Description copied from interface: StreamPendingRangeArgs

Defines minimum idle time limit.

Specified by:

idleTime in interface StreamPendingRangeArgs

Parameters:

idleTime - minimum idle time of messages

Returns:

arguments object

count

public StreamPendingRangeArgs count(int count)

Description copied from interface: StreamCountArgs

Defines messages count limit.

Specified by:

count in interface StreamCountArgs

Parameters:

count - amount of messages

Returns:

next options

endId

public StreamCountArgs endId(StreamMessageId endId)

Description copied from interface: StreamEndIdArgs

Defines endId in range inclusive

Specified by:

endId in interface StreamEndIdArgs<StreamCountArgs>

Parameters:

endId -

Returns:

next options

endIdExclusive

public StreamCountArgs endIdExclusive(StreamMessageId endId)

Description copied from interface: StreamEndIdArgs

Defines endId in range exclusive

Specified by:

endIdExclusive in interface StreamEndIdArgs<StreamCountArgs>

Parameters:

endId -

Returns:

next options

startId

public StreamEndIdArgs<StreamCountArgs> startId(StreamMessageId startId)

Description copied from interface: StreamStartIdArgs

Defines startId in range inclusive

Specified by:

startId in interface StreamStartIdArgs<StreamCountArgs>

Parameters:

startId -

Returns:

next options

startIdExclusive

public StreamEndIdArgs<StreamCountArgs> startIdExclusive(StreamMessageId startId)

Description copied from interface: StreamStartIdArgs

Defines startId in range exclusive

Specified by:

startIdExclusive in interface StreamStartIdArgs<StreamCountArgs>

Parameters:

startId -

Returns:

next options

getGroupName

public String getGroupName()

getStartId

public StreamMessageId getStartId()

getEndId

public StreamMessageId getEndId()

isStartIdExclusive

public boolean isStartIdExclusive()

isEndIdExclusive

public boolean isEndIdExclusive()

getCount

public int getCount()

getConsumerName

public String getConsumerName()

getIdleTime

public Duration getIdleTime()