Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
R
- RAW_DATA - Static variable in class org.springframework.pulsar.support.PulsarHeaders
-
Raw message data as bytes.
- REACTIVE_PULSAR_LISTENER_ANNOTATION_PROCESSOR_BEAN_NAME - Static variable in class org.springframework.pulsar.config.PulsarListenerBeanNames
-
The bean name of the internally managed Pulsar listener annotation processor.
- REACTIVE_PULSAR_LISTENER_ENDPOINT_REGISTRY_BEAN_NAME - Static variable in class org.springframework.pulsar.config.PulsarListenerBeanNames
-
The bean name of the internally managed Pulsar listener endpoint registry.
- ReactiveMessageConsumerBuilderCustomizer<T> - Interface in org.springframework.pulsar.reactive.core
-
The interface to customize a
ReactiveMessageConsumerBuilder
. - ReactiveMessageReaderBuilderCustomizer<T> - Interface in org.springframework.pulsar.reactive.core
-
The interface to customize a
ReactiveMessageReaderBuilder
. - ReactiveMessageSenderBuilderCustomizer<T> - Interface in org.springframework.pulsar.reactive.core
-
The interface to customize a
ReactiveMessageSenderBuilder
. - ReactivePulsarBootstrapConfiguration - Class in org.springframework.pulsar.reactive.config.annotation
-
An
ImportBeanDefinitionRegistrar
class that registers aReactivePulsarListenerAnnotationBeanPostProcessor
bean capable of processing Spring's @ReactivePulsarListener
annotation. - ReactivePulsarBootstrapConfiguration() - Constructor for class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarBootstrapConfiguration
- reactivePulsarConsumerFactory(ReactivePulsarClient) - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveAutoConfiguration
- ReactivePulsarConsumerFactory<T> - Interface in org.springframework.pulsar.reactive.core
-
Pulsar reactive consumer factory interface.
- ReactivePulsarContainerProperties<T> - Class in org.springframework.pulsar.reactive.listener
-
Contains runtime properties for a reactive listener container.
- ReactivePulsarContainerProperties() - Constructor for class org.springframework.pulsar.reactive.listener.ReactivePulsarContainerProperties
- ReactivePulsarListener - Annotation Interface in org.springframework.pulsar.reactive.config.annotation
-
Annotation that marks a method to be the target of a Pulsar message listener on the specified topics.
- ReactivePulsarListenerAnnotationBeanPostProcessor<V> - Class in org.springframework.pulsar.reactive.config.annotation
-
Bean post-processor that registers methods annotated with
ReactivePulsarListener
to be invoked by a Pulsar message listener container created under the covers by aReactivePulsarListenerContainerFactory
according to the parameters of the annotation. - ReactivePulsarListenerAnnotationBeanPostProcessor() - Constructor for class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor
- ReactivePulsarListenerAnnotationBeanPostProcessor.AnnotationEnhancer - Interface in org.springframework.pulsar.reactive.config.annotation
- ReactivePulsarListenerConfigurationSelector - Class in org.springframework.pulsar.reactive.config.annotation
-
A
DeferredImportSelector
implementation with the lowest order to importReactivePulsarBootstrapConfiguration
as late as possible. - ReactivePulsarListenerConfigurationSelector() - Constructor for class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerConfigurationSelector
- ReactivePulsarListenerContainerFactory<T> - Interface in org.springframework.pulsar.reactive.config
-
Factory for Pulsar reactive message listener containers.
- ReactivePulsarListenerEndpoint<T> - Interface in org.springframework.pulsar.reactive.config
-
Model for a Pulsar reactive listener endpoint.
- ReactivePulsarListenerEndpointAdapter<T> - Class in org.springframework.pulsar.reactive.config
-
Adapter to avoid having to implement all methods.
- ReactivePulsarListenerEndpointAdapter() - Constructor for class org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpointAdapter
- ReactivePulsarListenerEndpointRegistry<T> - Class in org.springframework.pulsar.reactive.config
-
Creates the necessary
ReactivePulsarMessageListenerContainer
instances for the registered endpoints. - ReactivePulsarListenerEndpointRegistry() - Constructor for class org.springframework.pulsar.reactive.config.ReactivePulsarListenerEndpointRegistry
- ReactivePulsarListeners - Annotation Interface in org.springframework.pulsar.reactive.config.annotation
-
Container annotation that aggregates several
ReactivePulsarListener
annotations. - ReactivePulsarMessageHandler - Interface in org.springframework.pulsar.reactive.listener
-
Reactive message handler used by
DefaultReactivePulsarMessageListenerContainer
. - ReactivePulsarMessageListenerContainer<T> - Interface in org.springframework.pulsar.reactive.listener
-
Internal abstraction used by the framework representing a reactive message listener container.
- ReactivePulsarOneByOneMessageHandler<T> - Interface in org.springframework.pulsar.reactive.listener
-
Message handler class with a
ReactivePulsarOneByOneMessageHandler.received(org.apache.pulsar.client.api.Message<T>)
method for use inReactiveMessagePipelineBuilder.messageHandler(java.util.function.Function<org.apache.pulsar.client.api.Message<T>, org.reactivestreams.Publisher<java.lang.Void>>)
. - ReactivePulsarOperations<T> - Interface in org.springframework.pulsar.reactive.core
-
The Pulsar reactive send operations contract.
- ReactivePulsarOperations.SendMessageBuilder<T> - Interface in org.springframework.pulsar.reactive.core
-
Builder that can be used to configure and send a message.
- reactivePulsarReaderFactory(ReactivePulsarClient) - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveAutoConfiguration
- ReactivePulsarReaderFactory<T> - Interface in org.springframework.pulsar.reactive.core
-
The strategy to create a
ReactiveMessageReader
instance(s). - ReactivePulsarRuntimeHints - Class in org.springframework.pulsar.reactive.aot
-
RuntimeHintsRegistrar
for Spring for Apache Pulsar. - ReactivePulsarRuntimeHints() - Constructor for class org.springframework.pulsar.reactive.aot.ReactivePulsarRuntimeHints
- reactivePulsarSenderFactory(ReactivePulsarClient, ObjectProvider<ReactiveMessageSenderCache>) - Method in class org.springframework.pulsar.autoconfigure.PulsarReactiveAutoConfiguration
- ReactivePulsarSenderFactory<T> - Interface in org.springframework.pulsar.reactive.core
-
The strategy to create a
ReactiveMessageSender
instance(s). - ReactivePulsarStreamingHandler<T> - Interface in org.springframework.pulsar.reactive.listener
-
Message handler class with a
ReactivePulsarStreamingHandler.received(reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>)
method for use inReactiveMessagePipelineBuilder.streamingMessageHandler(java.util.function.Function<reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>, org.reactivestreams.Publisher<org.apache.pulsar.reactive.client.api.MessageResult<java.lang.Void>>>)
. - ReactivePulsarTemplate<T> - Class in org.springframework.pulsar.reactive.core
-
A thread-safe template for executing high-level reactive Pulsar operations.
- ReactivePulsarTemplate(ReactivePulsarSenderFactory<T>) - Constructor for class org.springframework.pulsar.reactive.core.ReactivePulsarTemplate
-
Construct a template instance with observation configuration.
- ReactivePulsarTemplate.SendMessageBuilderImpl<T> - Class in org.springframework.pulsar.reactive.core
- ReactiveSpringPulsarBootApp - Class in org.springframework.pulsar.example
- ReactiveSpringPulsarBootApp() - Constructor for class org.springframework.pulsar.example.ReactiveSpringPulsarBootApp
- Reader() - Constructor for class org.springframework.pulsar.autoconfigure.PulsarReactiveProperties.Reader
- received(Consumer<T>, List<Message<T>>) - Method in interface org.springframework.pulsar.listener.PulsarBatchAcknowledgingMessageListener
- received(Consumer<T>, List<Message<T>>) - Method in interface org.springframework.pulsar.listener.PulsarBatchMessageListener
- received(Consumer<T>, List<Message<T>>, Acknowledgement) - Method in interface org.springframework.pulsar.listener.PulsarBatchAcknowledgingMessageListener
- received(Consumer<T>, List<Message<T>>, Acknowledgement) - Method in interface org.springframework.pulsar.listener.PulsarBatchMessageListener
- received(Consumer<T>, Message<T>) - Method in interface org.springframework.pulsar.listener.PulsarAcknowledgingMessageListener
- received(Consumer<T>, Message<T>) - Method in interface org.springframework.pulsar.listener.PulsarBatchMessageListener
- received(Consumer<T>, Message<T>, Acknowledgement) - Method in interface org.springframework.pulsar.listener.PulsarAcknowledgingMessageListener
- received(Consumer<T>, Message<T>, Acknowledgement) - Method in interface org.springframework.pulsar.listener.PulsarRecordMessageListener
- received(Consumer<V>, List<Message<V>>, Acknowledgement) - Method in class org.springframework.pulsar.listener.adapter.PulsarBatchMessagingMessageListenerAdapter
- received(Consumer<V>, Message<V>, Acknowledgement) - Method in class org.springframework.pulsar.listener.adapter.PulsarRecordMessagingMessageListenerAdapter
- received(Consumer<V>, Message<V>, Acknowledgement) - Method in class org.springframework.pulsar.reactive.listener.adapter.PulsarRecordMessagingMessageListenerAdapter
- received(Message<T>) - Method in interface org.springframework.pulsar.reactive.listener.ReactivePulsarOneByOneMessageHandler
-
Callback passed to
ReactiveMessagePipelineBuilder.messageHandler(java.util.function.Function<org.apache.pulsar.client.api.Message<T>, org.reactivestreams.Publisher<java.lang.Void>>)
that will be called for each received message. - received(Message<V>) - Method in class org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveOneByOneMessagingMessageListenerAdapter
- received(Flux<Message<T>>) - Method in interface org.springframework.pulsar.reactive.listener.ReactivePulsarStreamingHandler
-
Callback passed to
ReactiveMessagePipelineBuilder.streamingMessageHandler(java.util.function.Function<reactor.core.publisher.Flux<org.apache.pulsar.client.api.Message<T>>, org.reactivestreams.Publisher<org.apache.pulsar.reactive.client.api.MessageResult<java.lang.Void>>>)
that will be applied to the flux of received message. - received(Flux<Message<V>>) - Method in class org.springframework.pulsar.reactive.listener.adapter.PulsarReactiveStreamingMessagingMessageListenerAdapter
- RECORD - Enum constant in enum class org.springframework.pulsar.listener.AckMode
-
Record ack mode.
- recovererForConsumer(Consumer<T>) - Method in class org.springframework.pulsar.listener.PulsarDeadLetterPublishingRecoverer
- recovererForConsumer(Consumer<T>) - Method in interface org.springframework.pulsar.listener.PulsarMessageRecovererFactory
-
Provides a message recoverer
PulsarMessageRecoverer
. - recoverMessage(Consumer<T>, Message<T>, Exception) - Method in class org.springframework.pulsar.listener.DefaultPulsarConsumerErrorHandler
- recoverMessage(Consumer<T>, Message<T>, Exception) - Method in interface org.springframework.pulsar.listener.PulsarConsumerErrorHandler
-
Recover the message based on the implementation provided.
- recoverMessage(Message<T>, Exception) - Method in interface org.springframework.pulsar.listener.PulsarMessageRecoverer
-
Recover a failed message, for e.g.
- REDELIVERY_COUNT - Static variable in class org.springframework.pulsar.support.PulsarHeaders
-
Redelivery count.
- registerAllEndpoints() - Method in class org.springframework.pulsar.config.PulsarListenerEndpointRegistrar
- registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.pulsar.annotation.PulsarBootstrapConfiguration
- registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarBootstrapConfiguration
- registerEndpoint(ListenerEndpoint, ListenerContainerFactory<?, ?>) - Method in class org.springframework.pulsar.config.PulsarListenerEndpointRegistrar
- registerHints(RuntimeHints, ClassLoader) - Method in class org.springframework.pulsar.aot.PulsarRuntimeHints
- registerHints(RuntimeHints, ClassLoader) - Method in class org.springframework.pulsar.reactive.aot.ReactivePulsarRuntimeHints
- registerListenerContainer(E, ListenerContainerFactory<? extends C, E>) - Method in class org.springframework.pulsar.config.ListenerEndpointRegistry
- registerListenerContainer(E, ListenerContainerFactory<? extends C, E>, boolean) - Method in class org.springframework.pulsar.config.ListenerEndpointRegistry
- REPLICATED_FROM - Static variable in class org.springframework.pulsar.support.PulsarHeaders
-
Cluster where the message is replicated from.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form