Uses of Interface
com.rabbitmq.stream.ConsumerBuilder.AutoTrackingStrategy
-
Uses of ConsumerBuilder.AutoTrackingStrategy in com.rabbitmq.stream
Modifier and TypeMethodDescriptionConsumerBuilder.autoTrackingStrategy()
ConsumerBuilder.AutoTrackingStrategy.flushInterval
(Duration flushInterval) Interval to check and stored the last received offset in case of inactivity.ConsumerBuilder.AutoTrackingStrategy.messageCountBeforeStorage
(int messageCountBeforeStorage) Number of messages before storing.