Uses of Interface
com.rabbitmq.stream.ConsumerBuilder
Packages that use ConsumerBuilder
-
Uses of ConsumerBuilder in com.rabbitmq.stream
Methods in com.rabbitmq.stream that return ConsumerBuilderModifier 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.listeners
(Resource.StateListener... listeners) AddResource.StateListener
s to the consumer.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).