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 aConsumerBuilderto configure and create aConsumerConsumerBuilder.consumerUpdateListener(ConsumerUpdateListener consumerUpdateListener) Set the listener for single active consumer updates.ConsumerBuilder.listeners(Resource.StateListener... listeners) AddResource.StateListeners 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).