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

abort(Transaction) - Static method in class org.springframework.pulsar.transaction.PulsarTransactionUtils

Aborts a Pulsar transaction asynchronously, logging the outcome at trace level.

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.

acknowledge(Message<T>) - Static method in class org.springframework.pulsar.reactive.support.MessageUtils

Convenience method that acknowledges a Spring message by extracting its message id and passing it to MessageResult.acknowledge(MessageId).

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

Whether to automatically start the container for this listener.

autoStartup() - Element in annotation interface org.springframework.pulsar.annotation.PulsarReader

autoStartup() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener

Whether to automatically start the container for this listener.

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