Index

A B C D E F G H I J K L M N O P R S T U V W 
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.PulsarAnnotationSupportBeanNames
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.PulsarAnnotationSupportBeanNames
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 a ReactivePulsarListenerAnnotationBeanPostProcessor bean capable of processing Spring's @ReactivePulsarListener annotation.
ReactivePulsarBootstrapConfiguration() - Constructor for class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarBootstrapConfiguration
 
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 a ReactivePulsarListenerContainerFactory according to the parameters of the annotation.
ReactivePulsarListenerAnnotationBeanPostProcessor() - Constructor for class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor
 
ReactivePulsarListenerConfigurationSelector - Class in org.springframework.pulsar.reactive.config.annotation
A DeferredImportSelector implementation with the lowest order to import ReactivePulsarBootstrapConfiguration 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 in ReactiveMessagePipelineBuilder.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.SendManyMessageBuilder<T> - Interface in org.springframework.pulsar.reactive.core
 
ReactivePulsarOperations.SendMessageBuilder<O,T> - Interface in org.springframework.pulsar.reactive.core
Builder that can be used to configure and send a message.
ReactivePulsarOperations.SendOneMessageBuilder<T> - Interface in org.springframework.pulsar.reactive.core
 
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<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 in 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>>>).
ReactivePulsarTemplate<T> - Class in org.springframework.pulsar.reactive.core
A template for executing high-level reactive Pulsar operations.
ReactivePulsarTemplate(ReactivePulsarSenderFactory<T>) - Constructor for class org.springframework.pulsar.reactive.core.ReactivePulsarTemplate
Construct a template instance that uses the default schema resolver and topic resolver.
ReactivePulsarTemplate(ReactivePulsarSenderFactory<T>, SchemaResolver, TopicResolver) - Constructor for class org.springframework.pulsar.reactive.core.ReactivePulsarTemplate
Construct a template instance with a custom schema resolver and a custom topic resolver.
readerBuilderCustomizer - Variable in class org.springframework.pulsar.reader.AbstractPulsarMessageReaderContainer
 
ReaderBuilderCustomizer<T> - Interface in org.springframework.pulsar.core
The interface to customize a ReaderBuilder.
ReaderContainerFactory<C extends PulsarMessageReaderContainer,E extends PulsarReaderEndpoint<C>> - Interface in org.springframework.pulsar.config
Base container factory interface for PulsarMessageReaderContainer.
readerCustomizer() - Element in annotation interface org.springframework.pulsar.annotation.PulsarReader
The bean name or a 'SpEL' expression that resolves to a ReaderBuilderCustomizer to use to configure the reader.
ReaderFailedToStartEvent - Class in org.springframework.pulsar.event
Event to publish when the reader is failed to start.
ReaderFailedToStartEvent(Object, Object) - Constructor for class org.springframework.pulsar.event.ReaderFailedToStartEvent
Construct an instance with the provided source and container.
ReaderStartedEvent - Class in org.springframework.pulsar.event
Event to publish when the reader is started.
ReaderStartedEvent(Object, Object) - Constructor for class org.springframework.pulsar.event.ReaderStartedEvent
Construct an instance with the provided source and container.
ReaderStartingEvent - Class in org.springframework.pulsar.event
Event to publish while the reader is starting.
ReaderStartingEvent(Object, Object) - Constructor for class org.springframework.pulsar.event.ReaderStartingEvent
Construct an instance with the provided source and container.
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.PulsarBatchMessagesToSpringMessageListenerAdapter
 
received(Consumer<V>, Message<V>, Acknowledgement) - Method in class org.springframework.pulsar.listener.adapter.PulsarRecordMessageToSpringMessageListenerAdapter
 
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(Reader<V>, Message<V>) - Method in class org.springframework.pulsar.listener.adapter.PulsarRecordMessageToSpringMessageReaderAdapter
 
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
 
registerAllEndpoints() - Method in class org.springframework.pulsar.config.PulsarReaderEndpointRegistrar
 
registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.pulsar.annotation.PulsarBootstrapConfiguration
 
registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarBootstrapConfiguration
 
registerDestructionCallback(String, Runnable) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope
 
registerEndpoint(ListenerEndpoint, ListenerContainerFactory<?, ?>) - Method in class org.springframework.pulsar.config.PulsarListenerEndpointRegistrar
 
registerEndpoint(PulsarReaderEndpoint, ReaderContainerFactory<?, ?>) - Method in class org.springframework.pulsar.config.PulsarReaderEndpointRegistrar
 
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.GenericListenerEndpointRegistry
 
registerListenerContainer(E, ListenerContainerFactory<? extends C, E>, boolean) - Method in class org.springframework.pulsar.config.GenericListenerEndpointRegistry
 
registerReaderContainer(E, ReaderContainerFactory<? extends C, E>) - Method in class org.springframework.pulsar.config.GenericReaderEndpointRegistry
 
registerReaderContainer(E, ReaderContainerFactory<? extends C, E>, boolean) - Method in class org.springframework.pulsar.config.GenericReaderEndpointRegistry
 
remove(String) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope
 
removeCustomMapping(Class<?>) - Method in class org.springframework.pulsar.core.DefaultSchemaResolver
Removes the custom mapping from message type to schema.
removeCustomMapping(Class<?>) - Method in class org.springframework.pulsar.core.DefaultTopicResolver
Removes the custom mapping from message type to topic.
removeListener(String) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope
 
REPLICATED_FROM - Static variable in class org.springframework.pulsar.support.PulsarHeaders
Cluster where the message is replicated from.
resolve(String) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
resolveAsString(Object, List<String>) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
resolveContextualObject(String) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope
 
Resolved<T> - Class in org.springframework.pulsar.core
A resolved value or an exception if it could not be resolved.
resolveExpression(String) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
resolveExpressionAsBoolean(String, String) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
resolveExpressionAsInteger(String, String) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
resolveExpressionAsString(String, String) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
resolver - Variable in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
resolveSchema(Class<?>) - Method in interface org.springframework.pulsar.core.SchemaResolver
Get the schema to use for a message type.
resolveSchema(Class<?>, boolean) - Method in class org.springframework.pulsar.core.DefaultSchemaResolver
 
resolveSchema(Class<?>, boolean) - Method in interface org.springframework.pulsar.core.SchemaResolver
Get the schema to use for a message type.
resolveSchema(SchemaType, Class<?>, Class<?>) - Method in interface org.springframework.pulsar.core.SchemaResolver
Get the schema to use given a schema type and schema type information.
resolveSchema(SchemaType, ResolvableType) - Method in class org.springframework.pulsar.core.DefaultSchemaResolver
 
resolveSchema(SchemaType, ResolvableType) - Method in interface org.springframework.pulsar.core.SchemaResolver
Get the schema to use given a schema type and a message type.
resolveSchema(T) - Method in interface org.springframework.pulsar.core.SchemaResolver
Get the schema to use for a particular message.
resolveTopic(String, Class<?>, Supplier<String>) - Method in class org.springframework.pulsar.core.DefaultTopicResolver
 
resolveTopic(String, Class<?>, Supplier<String>) - Method in interface org.springframework.pulsar.core.TopicResolver
Resolve the topic name to use for the given message type.
resolveTopic(String, Supplier<String>) - Method in class org.springframework.pulsar.core.DefaultTopicResolver
 
resolveTopic(String, Supplier<String>) - Method in interface org.springframework.pulsar.core.TopicResolver
Resolve the topic name to use.
resolveTopic(String, T, Supplier<String>) - Method in class org.springframework.pulsar.core.DefaultTopicResolver
 
resolveTopic(String, T, Supplier<String>) - Method in interface org.springframework.pulsar.core.TopicResolver
Resolve the topic name to use for the given message.
resolveTopicName(String) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory
 
resume() - Method in class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer
 
resume() - Method in interface org.springframework.pulsar.listener.PulsarMessageListenerContainer
Resume this container, if paused.
running - Variable in class org.springframework.pulsar.core.AbstractPulsarMessageContainer
 
A B C D E F G H I J K L M N O P R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form