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.

read(byte[], int, int) - Method in class org.springframework.pulsar.core.JSONSchemaUtil.CustomJacksonJsonReader

read(InputStream) - Method in class org.springframework.pulsar.core.JSONSchemaUtil.CustomJacksonJsonReader

readerBuilderCustomizer - Variable in class org.springframework.pulsar.reader.AbstractPulsarMessageReaderContainer

ReaderBuilderCustomizer<T> - Interface in org.springframework.pulsar.core

Callback interface that can be implemented to customize the ReaderBuilder that is used by the PulsarReaderFactory to create readers.

ReaderContainerFactory<C,E> - 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 PulsarReaderReaderBuilderCustomizer 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, List) - Method in interface org.springframework.pulsar.listener.PulsarBatchAcknowledgingMessageListener

received(Consumer, List) - Method in interface org.springframework.pulsar.listener.PulsarBatchMessageListener

received(Consumer, List, Acknowledgement) - Method in interface org.springframework.pulsar.listener.PulsarBatchAcknowledgingMessageListener

received(Consumer, List, Acknowledgement) - Method in interface org.springframework.pulsar.listener.PulsarBatchMessageListener

received(Consumer, Message) - Method in interface org.springframework.pulsar.listener.PulsarAcknowledgingMessageListener

received(Consumer, Message) - Method in interface org.springframework.pulsar.listener.PulsarBatchMessageListener

received(Consumer, Message, Acknowledgement) - Method in interface org.springframework.pulsar.listener.PulsarAcknowledgingMessageListener

received(Consumer, Message, Acknowledgement) - Method in interface org.springframework.pulsar.listener.PulsarRecordMessageListener

received(Consumer, List, Acknowledgement) - Method in class org.springframework.pulsar.listener.adapter.PulsarBatchMessagesToSpringMessageListenerAdapter

received(Consumer, Message, Acknowledgement) - Method in class org.springframework.pulsar.listener.adapter.PulsarRecordMessageToSpringMessageListenerAdapter

received(Reader, Message) - Method in class org.springframework.pulsar.listener.adapter.PulsarRecordMessageToSpringMessageReaderAdapter

RECORD - Enum constant in enum class org.springframework.pulsar.listener.AckMode

Record ack mode.

recovererForConsumer(Consumer) - Method in class org.springframework.pulsar.listener.PulsarDeadLetterPublishingRecoverer

recovererForConsumer(Consumer) - Method in interface org.springframework.pulsar.listener.PulsarMessageRecovererFactory

Provides a message recoverer PulsarMessageRecoverer.

recoverMessage(Consumer, Message, Exception) - Method in class org.springframework.pulsar.listener.DefaultPulsarConsumerErrorHandler

recoverMessage(Consumer, Message, Exception) - Method in interface org.springframework.pulsar.listener.PulsarConsumerErrorHandler

Recover the message based on the implementation provided.

recoverMessage(Message, 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

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

registerListenerContainer(E, ListenerContainerFactory) - Method in class org.springframework.pulsar.config.GenericListenerEndpointRegistry

registerListenerContainer(E, ListenerContainerFactory, boolean) - Method in class org.springframework.pulsar.config.GenericListenerEndpointRegistry

registerReaderContainer(E, ReaderContainerFactory) - Method in class org.springframework.pulsar.config.GenericReaderEndpointRegistry

registerReaderContainer(E, ReaderContainerFactory, 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.

requireNonNullBean() - Method in class org.springframework.pulsar.config.MethodPulsarListenerEndpoint

requireNonNullBean() - Method in class org.springframework.pulsar.config.MethodPulsarReaderEndpoint

requireNonNullBeanFactory() - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

requireNonNullBeanFactory() - Method in class org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor

requireNonNullBeanFactory() - Method in class org.springframework.pulsar.annotation.PulsarReaderAnnotationBeanPostProcessor

requireNonNullBeanName() - Method in class org.springframework.pulsar.core.AbstractPulsarMessageContainer

requireNonNullEndpointRegistry() - Method in class org.springframework.pulsar.config.PulsarListenerEndpointRegistrar

requireNonNullEndpointRegistry() - Method in class org.springframework.pulsar.config.PulsarReaderEndpointRegistrar

requireNonNullInvokerHandlerMethod() - Method in class org.springframework.pulsar.listener.adapter.HandlerAdapter

requireNonNullMessageHandlerMethodFactory() - Method in class org.springframework.pulsar.config.MethodPulsarListenerEndpoint

requireNonNullMessageHandlerMethodFactory() - Method in class org.springframework.pulsar.config.MethodPulsarReaderEndpoint

requireNonNullMethod() - Method in class org.springframework.pulsar.config.MethodPulsarListenerEndpoint

requireNonNullMethod() - Method in class org.springframework.pulsar.config.MethodPulsarReaderEndpoint

resolve(String) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

resolveArgument(MethodParameter, Message) - Method in class org.springframework.pulsar.annotation.PulsarNullAwarePayloadArgumentResolver

resolveAsString(Object, List) - 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(T) - Method in interface org.springframework.pulsar.core.SchemaResolver

Get the schema to use for a particular message.

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.

resolveTopic(String, T, Supplier) - Method in class org.springframework.pulsar.core.DefaultTopicResolver

resolveTopic(String, T, Supplier) - Method in interface org.springframework.pulsar.core.TopicResolver

Resolve the topic name to use for the given message.

resolveTopic(String, Class, Supplier) - Method in class org.springframework.pulsar.core.DefaultTopicResolver

resolveTopic(String, Class, Supplier) - Method in interface org.springframework.pulsar.core.TopicResolver

Resolve the topic name to use for the given message type.

resolveTopic(String, Supplier) - Method in class org.springframework.pulsar.core.DefaultTopicResolver

resolveTopic(String, Supplier) - Method in interface org.springframework.pulsar.core.TopicResolver

Resolve the topic name to use.

resolveTopicName(String) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory

resolveToString(String) - Method in class org.springframework.pulsar.core.DefaultExpressionResolver

Resolve the given expression as a string value.

resolveToString(String) - Method in interface org.springframework.pulsar.core.ExpressionResolver

Resolve the given expression as a string value.

resume() - Method in class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer

resume() - Method in interface org.springframework.pulsar.listener.PulsarMessageListenerContainer

Resume this container, if paused.

RETRY - Enum constant in enum class org.springframework.pulsar.config.StartupFailurePolicy

Retry startup.

rollback() - Method in class org.springframework.pulsar.transaction.PulsarResourceHolder

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