Interface StreamReadGroupArgs


  • public interface StreamReadGroupArgs
    Arguments object for RStream.readGroup() methods.
    Author:
    Nikita Koksharov
    • 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