Package com.rabbitmq.stream

Interface ConsumerBuilder.AutoTrackingStrategy

Enclosing interface:
ConsumerBuilder
public static interface ConsumerBuilder.AutoTrackingStrategy
Auto-tracking strategy.

  • Method Details

    • messageCountBeforeStorage

      ConsumerBuilder.AutoTrackingStrategy messageCountBeforeStorage(int messageCountBeforeStorage)
      Number of messages before storing.

      Default is 10,000.

      Parameters:
      messageCountBeforeStorage -
      Returns:
      the auto-tracking strategy

    • flushInterval

      ConsumerBuilder.AutoTrackingStrategy flushInterval(Duration flushInterval)
      Interval to check and stored the last received offset in case of inactivity.

      Default is 5 seconds.

      Parameters:
      flushInterval -
      Returns:
      the auto-tracking strategy

    • builder

      ConsumerBuilder builder()
      Go back to the builder.
      Returns:
      the consumer builder