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

A

AbstractPulsarAnnotationsBeanPostProcessor - Class in org.springframework.pulsar.annotation
Base class implementation for the various annotation post processors in Spring Pulsar.
AbstractPulsarAnnotationsBeanPostProcessor() - Constructor for class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope - Class in org.springframework.pulsar.annotation
 
AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter - Class in org.springframework.pulsar.annotation
 
AbstractPulsarHeaderMapper<ToPulsarHeadersContextType,ToSpringHeadersContextType> - Class in org.springframework.pulsar.support.header
Base PulsarHeaderMapper implementation that constrains which headers are mapped via header matchers.
AbstractPulsarHeaderMapper(List<String>, List<String>) - Constructor for class org.springframework.pulsar.support.header.AbstractPulsarHeaderMapper
Construct a mapper that will match the supplied inbound and outbound patterns.
AbstractPulsarListenerContainerFactory<C extends AbstractPulsarMessageListenerContainer<T>,T> - Class in org.springframework.pulsar.config
Base PulsarListenerContainerFactory implementation.
AbstractPulsarListenerContainerFactory(PulsarConsumerFactory<? super T>, PulsarContainerProperties) - Constructor for class org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory
 
AbstractPulsarListenerEndpoint<K> - Class in org.springframework.pulsar.config
Base implementation for PulsarListenerEndpoint.
AbstractPulsarListenerEndpoint() - Constructor for class org.springframework.pulsar.config.AbstractPulsarListenerEndpoint
 
AbstractPulsarMessageContainer - Class in org.springframework.pulsar.core
Base class for the various container implementations.
AbstractPulsarMessageContainer() - Constructor for class org.springframework.pulsar.core.AbstractPulsarMessageContainer
 
AbstractPulsarMessageListenerContainer<T> - Class in org.springframework.pulsar.listener
Base implementation for the PulsarMessageListenerContainer.
AbstractPulsarMessageListenerContainer(PulsarConsumerFactory<? super T>, PulsarContainerProperties) - Constructor for class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer
 
AbstractPulsarMessageReaderContainer<T> - Class in org.springframework.pulsar.reader
Core implementation for PulsarMessageReaderContainer.
AbstractPulsarMessageReaderContainer(PulsarReaderFactory<? super T>, PulsarReaderContainerProperties) - Constructor for class org.springframework.pulsar.reader.AbstractPulsarMessageReaderContainer
 
AbstractPulsarMessageToSpringMessageAdapter<V> - Class in org.springframework.pulsar.listener.adapter
An abstract MessageListener adapter providing the necessary infrastructure to extract the payload from a Pulsar message.
AbstractPulsarMessageToSpringMessageAdapter(Object, Method) - Constructor for class org.springframework.pulsar.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter
 
AbstractPulsarReaderContainerFactory<C extends AbstractPulsarMessageReaderContainer<T>,T> - Class in org.springframework.pulsar.config
Base PulsarReaderContainerFactory implementation.
AbstractPulsarReaderContainerFactory(PulsarReaderFactory<? super T>, PulsarReaderContainerProperties) - Constructor for class org.springframework.pulsar.config.AbstractPulsarReaderContainerFactory
 
AbstractPulsarReaderEndpoint<K> - Class in org.springframework.pulsar.config
Base implementation for PulsarListenerEndpoint.
AbstractPulsarReaderEndpoint() - Constructor for class org.springframework.pulsar.config.AbstractPulsarReaderEndpoint
 
AbstractReactivePulsarListenerEndpoint<T> - Class in org.springframework.pulsar.reactive.config
Base implementation for ReactivePulsarListenerEndpoint.
AbstractReactivePulsarListenerEndpoint() - Constructor for class org.springframework.pulsar.reactive.config.AbstractReactivePulsarListenerEndpoint
 
acceptIfNotNull(T, Consumer<T>) - Method in class org.springframework.pulsar.support.JavaUtils
Invoke Consumer.accept(Object) with the value if it is not null.
ackMode() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener
Override the container default ack mode of BATCH.
AckMode - Enum Class in org.springframework.pulsar.listener
Enumeration for ack mode.
acknowledge() - Method in interface org.springframework.pulsar.listener.Acknowledgement
Manually acknowledges the current message that the listener is operating upon.
acknowledge(List<MessageId>) - Method in interface org.springframework.pulsar.listener.Acknowledgement
Manually acknowledges a list of messages based on their message id's.
acknowledge(MessageId) - Method in interface org.springframework.pulsar.listener.Acknowledgement
Manually acknowledges by the message id.
Acknowledgement - Interface in org.springframework.pulsar.listener
Contract for manual acknowledgment.
ackTimeoutRedeliveryBackoff - Variable in class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer
 
ackTimeoutRedeliveryBackoff() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener
The bean name or a 'SpEL' expression that resolves to a RedeliveryBackoff to use on the consumer to control the redelivery backoff of messages after an acknowledgment timeout.
addCustomSchemaMapping(Class<?>, Schema<?>) - Method in class org.springframework.pulsar.core.DefaultSchemaResolver
Adds a custom mapping from message type to schema.
addCustomTopicMapping(Class<?>, String) - Method in class org.springframework.pulsar.core.DefaultTopicResolver
Adds a custom mapping from message type to topic.
addListener(String, Object) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope
 
afterPropertiesSet() - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
afterPropertiesSet() - Method in class org.springframework.pulsar.config.AbstractPulsarListenerEndpoint
 
afterPropertiesSet() - Method in class org.springframework.pulsar.config.AbstractPulsarReaderEndpoint
 
afterPropertiesSet() - Method in class org.springframework.pulsar.config.PulsarListenerEndpointRegistrar
 
afterPropertiesSet() - Method in class org.springframework.pulsar.config.PulsarReaderEndpointRegistrar
 
afterPropertiesSet() - Method in class org.springframework.pulsar.reactive.config.AbstractReactivePulsarListenerEndpoint
 
afterSingletonsInstantiated() - Method in class org.springframework.pulsar.annotation.PulsarListenerAnnotationBeanPostProcessor
 
afterSingletonsInstantiated() - Method in class org.springframework.pulsar.annotation.PulsarReaderAnnotationBeanPostProcessor
 
afterSingletonsInstantiated() - Method in class org.springframework.pulsar.core.PulsarAdministration
 
afterSingletonsInstantiated() - Method in class org.springframework.pulsar.core.PulsarTemplate
If observations are enabled, attempt to obtain the Observation registry and convention.
afterSingletonsInstantiated() - Method in class org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor
 
applicationContext - Variable in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
archive() - Method in record class org.springframework.pulsar.function.PulsarFunction
 
archive() - Method in interface org.springframework.pulsar.function.PulsarFunctionOperations
Gets the url or path to the archive that represents the function.
archive() - Method in record class org.springframework.pulsar.function.PulsarSink
 
archive() - Method in record class org.springframework.pulsar.function.PulsarSource
 
asMap() - Method in interface org.springframework.pulsar.cache.provider.CacheProvider
Returns a view of the entries stored in the cache as a thread-safe map.
asMap() - Method in class org.springframework.pulsar.cache.provider.caffeine.CaffeineCacheProvider
 
assertBeanFactory() - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
autoStartup - Variable in class org.springframework.pulsar.core.AbstractPulsarMessageContainer
 
autoStartup() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener
Set to true or false, to override the default setting in the container factory.
autoStartup() - Element in annotation interface org.springframework.pulsar.annotation.PulsarReader
 
autoStartup() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener
Set to true or false, to override the default setting in the container factory.
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