Index

A B C D E F G H I J L M N O P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

R

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

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.

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

registerBeanDefinitions(AnnotationMetadata, BeanDefinitionRegistry) - Method in class org.springframework.pulsar.annotation.PulsarBootstrapConfiguration

registerEndpoint(PulsarListenerEndpoint, PulsarListenerContainerFactory<?>) - Method in class org.springframework.pulsar.config.PulsarListenerEndpointRegistrar

registerListenerContainer(PulsarListenerEndpoint, PulsarListenerContainerFactory<?>) - Method in class org.springframework.pulsar.config.PulsarListenerEndpointRegistry

registerListenerContainer(PulsarListenerEndpoint, PulsarListenerContainerFactory<?>, boolean) - Method in class org.springframework.pulsar.config.PulsarListenerEndpointRegistry

resolveBean(BeanFactory) - Method in class org.springframework.pulsar.support.EndpointHandlerMethod

returnTypeMessageOrCollectionOf(Method) - Static method in class org.springframework.pulsar.listener.adapter.PulsarMessagingMessageListenerAdapter

A B C D E F G H I J L M N O P R S T V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form