Package org.redisson.api.stream

Interface StreamPendingRangeArgs

All Known Implementing Classes:
StreamPendingRangeParams
public interface StreamPendingRangeArgs
Arguments object for RStream.listPending() methods.
Author:
seakider

  • Method Details

    • groupName

      static StreamStartIdArgs<StreamCountArgs> groupName(String groupName)
      Defines groupName of pending messages
      Parameters:
      groupName - name of group
      Returns:
      next options

    • consumerName

      StreamPendingRangeArgs consumerName(String consumerName)
      Defines consumerName of pending messages
      Parameters:
      consumerName - name of consumer
      Returns:
      arguments object

    • idleTime

      StreamPendingRangeArgs idleTime(Duration idleTime)
      Defines minimum idle time limit.
      Parameters:
      idleTime - minimum idle time of messages
      Returns:
      arguments object