Uses of Interface
com.rabbitmq.stream.ConsumerBuilder
-
Uses of ConsumerBuilder in com.rabbitmq.stream
Modifier and TypeMethodDescriptionConsumerBuilder.AutoTrackingStrategy.builder()
Go back to the builder.ConsumerBuilder.FilterConfiguration.builder()
Go back to the builder.ConsumerBuilder.FlowConfiguration.builder()
Go back to the builder.ConsumerBuilder.ManualTrackingStrategy.builder()
Go back to the builder.Environment.consumerBuilder()
Create aConsumerBuilder
to configure and create aConsumer
ConsumerBuilder.consumerUpdateListener
(ConsumerUpdateListener consumerUpdateListener) Set the listener for single active consumer updates.ConsumerBuilder.messageHandler
(MessageHandler messageHandler) The callback for inbound messages.The logical name of theConsumer
.ConsumerBuilder.noTrackingStrategy()
Disable server-side offset tracking.ConsumerBuilder.offset
(OffsetSpecification offsetSpecification) The offset to start consuming from.ConsumerBuilder.singleActiveConsumer()
Declare the consumer as a single active consumer.The stream to consume from.ConsumerBuilder.subscriptionListener
(SubscriptionListener subscriptionListener) Callback on subscription.ConsumerBuilder.superStream
(String superStream) Set the consumer to consume from a super stream (partitioned stream).