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

C

CacheProvider<K,V> - Interface in org.springframework.pulsar.cache.provider
Defines the contract for a cache provider.
CacheProviderFactory<K,V> - Interface in org.springframework.pulsar.cache.provider
Interface to create instances of CacheProvider.
CacheProviderFactory.EvictionListener<K,V> - Interface in org.springframework.pulsar.cache.provider
Interface for a cache eviction listener.
CachingPulsarProducerFactory<T> - Class in org.springframework.pulsar.core
A PulsarProducerFactory that extends the default implementation by caching the created producers.
CachingPulsarProducerFactory(PulsarClient, String, List<ProducerBuilderCustomizer<T>>, TopicResolver, Duration, Long, Integer) - Constructor for class org.springframework.pulsar.core.CachingPulsarProducerFactory
Construct a caching producer factory with the specified values for the cache configuration.
CaffeineCacheProvider<K,V> - Class in org.springframework.pulsar.cache.provider.caffeine
Cache provider implementation backed by a Caffeine cache.
CaffeineCacheProvider(Cache<K, V>) - Constructor for class org.springframework.pulsar.cache.provider.caffeine.CaffeineCacheProvider
 
CaffeineCacheProviderFactory<K,V> - Class in org.springframework.pulsar.cache.provider.caffeine
Factory to create instances of CaffeineCacheProvider.
CaffeineCacheProviderFactory() - Constructor for class org.springframework.pulsar.cache.provider.caffeine.CaffeineCacheProviderFactory
 
checkProxy(Method, Object) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor
 
clearMessage() - Method in class org.springframework.pulsar.listener.DefaultPulsarConsumerErrorHandler
 
clearMessage() - Method in interface org.springframework.pulsar.listener.PulsarConsumerErrorHandler
Clear the message in error from managing (such as resetting any thread state etc.).
concurrency() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener
Override the container factory's concurrency setting for this listener.
concurrency() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener
Override the container factory's concurrency setting for this listener.
ConcurrentPulsarListenerContainerFactory<T> - Class in org.springframework.pulsar.config
Concrete implementation for PulsarListenerContainerFactory.
ConcurrentPulsarListenerContainerFactory(PulsarConsumerFactory<? super T>, PulsarContainerProperties) - Constructor for class org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory
 
ConcurrentPulsarMessageListenerContainer<T> - Class in org.springframework.pulsar.listener
Creates a concurrent execution context of DefaultPulsarMessageListenerContainer instances based on the concurrency.
ConcurrentPulsarMessageListenerContainer(PulsarConsumerFactory<? super T>, PulsarContainerProperties) - Constructor for class org.springframework.pulsar.listener.ConcurrentPulsarMessageListenerContainer
 
config() - Method in record class org.springframework.pulsar.function.PulsarFunction
Returns the value of the config record component.
config() - Method in record class org.springframework.pulsar.function.PulsarSink
Returns the value of the config record component.
config() - Method in record class org.springframework.pulsar.function.PulsarSource
Returns the value of the config record component.
configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V>) - Method in class org.springframework.pulsar.config.MethodPulsarListenerEndpoint
 
configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V>) - Method in class org.springframework.pulsar.config.MethodPulsarReaderEndpoint
 
configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter<V>) - Method in class org.springframework.pulsar.reactive.config.MethodReactivePulsarListenerEndpoint
 
configurePulsarListeners(PulsarListenerEndpointRegistrar) - Method in interface org.springframework.pulsar.annotation.PulsarListenerConfigurer
Callback allowing a PulsarListenerEndpointRegistry and specific PulsarListenerEndpoint instances to be registered against the given PulsarListenerEndpointRegistrar.
configurePulsarReaders(PulsarReaderEndpointRegistrar) - Method in interface org.springframework.pulsar.annotation.PulsarReaderConfigurer
Callback allowing a PulsarListenerEndpointRegistry and specific PulsarListenerEndpoint instances to be registered against the given PulsarListenerEndpointRegistrar.
ConsumerBuilderConfigurationUtil - Class in org.springframework.pulsar.core
Utility methods to help load configuration into a ConsumerBuilder.
consumerBuilderCustomizer - Variable in class org.springframework.pulsar.listener.AbstractPulsarMessageListenerContainer
 
ConsumerBuilderCustomizer<T> - Interface in org.springframework.pulsar.core
The interface to customize a ConsumerBuilder.
consumerCustomizer() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener
The bean name or a 'SpEL' expression that resolves to a ConsumerBuilderCustomizer to use to configure the consumer.
consumerCustomizer() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener
The bean name or a 'SpEL' expression that resolves to a ReactiveMessageConsumerBuilderCustomizer to use to configure the consumer.
ConsumerFailedToStartEvent - Class in org.springframework.pulsar.event
Event to publish when the consumer is failed to start.
ConsumerFailedToStartEvent(Object, Object) - Constructor for class org.springframework.pulsar.event.ConsumerFailedToStartEvent
Construct an instance with the provided source and container.
ConsumerStartedEvent - Class in org.springframework.pulsar.event
Event to publish when the consumer is started.
ConsumerStartedEvent(Object, Object) - Constructor for class org.springframework.pulsar.event.ConsumerStartedEvent
Construct an instance with the provided source and container.
ConsumerStartingEvent - Class in org.springframework.pulsar.event
Event to publish while the consumer is starting.
ConsumerStartingEvent(Object, Object) - Constructor for class org.springframework.pulsar.event.ConsumerStartingEvent
Construct an instance with the provided source and container.
containerFactory() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener
The bean name of the PulsarListenerContainerFactory to use to create the message listener container responsible to serve this endpoint.
containerFactory() - Element in annotation interface org.springframework.pulsar.annotation.PulsarReader
 
containerFactory() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener
The bean name of the ReactivePulsarListenerContainerFactory to use to create the message listener container responsible to serve this endpoint.
create(Duration, Long, Integer, CacheProviderFactory.EvictionListener<K, V>) - Method in interface org.springframework.pulsar.cache.provider.CacheProviderFactory
Create a cache provider instance with the specified options.
create(Duration, Long, Integer, CacheProviderFactory.EvictionListener<K, V>) - Method in class org.springframework.pulsar.cache.provider.caffeine.CaffeineCacheProviderFactory
 
create(PulsarAdmin) - Method in record class org.springframework.pulsar.function.PulsarFunction
 
create(PulsarAdmin) - Method in interface org.springframework.pulsar.function.PulsarFunctionOperations
Creates the function using the file-based create api.
create(PulsarAdmin) - Method in record class org.springframework.pulsar.function.PulsarSink
 
create(PulsarAdmin) - Method in record class org.springframework.pulsar.function.PulsarSource
 
createAdminClient() - Method in class org.springframework.pulsar.core.PulsarAdministration
 
createClient() - Method in class org.springframework.pulsar.core.DefaultPulsarClientFactory
 
createClient() - Method in interface org.springframework.pulsar.core.PulsarClientFactory
Create a client.
createConsumer(Schema<T>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarConsumerFactory
 
createConsumer(Schema<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarConsumerFactory
Create a reactive message consumer.
createConsumer(Schema<T>, Collection<String>, String, Map<String, String>, List<ConsumerBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.core.DefaultPulsarConsumerFactory
 
createConsumer(Schema<T>, Collection<String>, String, Map<String, String>, List<ConsumerBuilderCustomizer<T>>) - Method in interface org.springframework.pulsar.core.PulsarConsumerFactory
Create a consumer.
createConsumer(Schema<T>, Collection<String>, String, ConsumerBuilderCustomizer<T>) - Method in class org.springframework.pulsar.core.DefaultPulsarConsumerFactory
 
createConsumer(Schema<T>, Collection<String>, String, ConsumerBuilderCustomizer<T>) - Method in interface org.springframework.pulsar.core.PulsarConsumerFactory
Create a consumer.
createConsumer(Schema<T>, List<ReactiveMessageConsumerBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarConsumerFactory
 
createConsumer(Schema<T>, List<ReactiveMessageConsumerBuilderCustomizer<T>>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarConsumerFactory
Create a reactive message consumer.
createContainer(String...) - Method in class org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory
 
createContainer(String...) - Method in interface org.springframework.pulsar.config.ListenerContainerFactory
Create and configure a container without a listener; used to create containers that are not used for PulsarListener annotations.
createContainer(String...) - Method in class org.springframework.pulsar.reactive.config.DefaultReactivePulsarListenerContainerFactory
 
createContainerInstance(PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory
 
createContainerInstance(PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory
 
createContainerInstance(PulsarReaderEndpoint<PulsarMessageReaderContainer>) - Method in class org.springframework.pulsar.config.AbstractPulsarReaderContainerFactory
 
createContainerInstance(PulsarReaderEndpoint<PulsarMessageReaderContainer>) - Method in class org.springframework.pulsar.config.DefaultPulsarReaderContainerFactory
 
createContainerInstance(ReactivePulsarListenerEndpoint<T>) - Method in class org.springframework.pulsar.reactive.config.DefaultReactivePulsarListenerContainerFactory
 
createInvocableHandlerMethod(Object, Method) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter
 
createListenerContainer(E) - Method in interface org.springframework.pulsar.config.ListenerContainerFactory
createListenerContainer(E, ListenerContainerFactory<? extends C, E>) - Method in class org.springframework.pulsar.config.GenericListenerEndpointRegistry
 
createListenerContainer(PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory
 
createListenerContainer(ReactivePulsarListenerEndpoint<T>) - Method in class org.springframework.pulsar.reactive.config.DefaultReactivePulsarListenerContainerFactory
 
createMessageHandler(ReactivePulsarMessageListenerContainer<T>, MessageConverter) - Method in class org.springframework.pulsar.reactive.config.AbstractReactivePulsarListenerEndpoint
 
createMessageHandler(ReactivePulsarMessageListenerContainer<V>, MessageConverter) - Method in class org.springframework.pulsar.reactive.config.MethodReactivePulsarListenerEndpoint
 
createMessageListener(PulsarMessageListenerContainer, MessageConverter) - Method in class org.springframework.pulsar.config.AbstractPulsarListenerEndpoint
 
createMessageListener(PulsarMessageListenerContainer, MessageConverter) - Method in class org.springframework.pulsar.config.MethodPulsarListenerEndpoint
 
createMessageListenerInstance(MessageConverter) - Method in class org.springframework.pulsar.config.MethodPulsarListenerEndpoint
 
createMessageListenerInstance(MessageConverter) - Method in class org.springframework.pulsar.config.MethodPulsarReaderEndpoint
 
createMessageListenerInstance(MessageConverter) - Method in class org.springframework.pulsar.reactive.config.MethodReactivePulsarListenerEndpoint
 
createOrModifyTopics(PulsarTopic...) - Method in class org.springframework.pulsar.core.PulsarAdministration
 
createOrModifyTopics(PulsarTopic...) - Method in interface org.springframework.pulsar.core.PulsarAdministrationOperations
Create or modify the given topics.
createOrUpdateUserDefinedFunctions() - Method in class org.springframework.pulsar.function.PulsarFunctionAdministration
Called during server startup, creates or updates any Pulsar functions registered by the application.
createProducer(Schema<T>, String) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory
 
createProducer(Schema<T>, String) - Method in interface org.springframework.pulsar.core.PulsarProducerFactory
Create a producer.
createProducer(Schema<T>, String, Collection<String>, List<ProducerBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory
 
createProducer(Schema<T>, String, Collection<String>, List<ProducerBuilderCustomizer<T>>) - Method in interface org.springframework.pulsar.core.PulsarProducerFactory
Create a producer.
createProducer(Schema<T>, String, ProducerBuilderCustomizer<T>) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory
 
createProducer(Schema<T>, String, ProducerBuilderCustomizer<T>) - Method in interface org.springframework.pulsar.core.PulsarProducerFactory
Create a producer.
createReader(List<String>, MessageId, Schema<T>, List<ReaderBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.core.DefaultPulsarReaderFactory
 
createReader(List<String>, MessageId, Schema<T>, List<ReaderBuilderCustomizer<T>>) - Method in interface org.springframework.pulsar.core.PulsarReaderFactory
Creating a Pulsar Reader based on the provided topics, schema and properties.
createReader(Schema<T>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarReaderFactory
 
createReader(Schema<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarReaderFactory
Create a reactive message reader.
createReader(Schema<T>, List<ReactiveMessageReaderBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarReaderFactory
 
createReader(Schema<T>, List<ReactiveMessageReaderBuilderCustomizer<T>>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarReaderFactory
Create a reactive message reader.
createReaderContainer(E) - Method in interface org.springframework.pulsar.config.ReaderContainerFactory
 
createReaderContainer(E, ReaderContainerFactory<? extends C, E>) - Method in class org.springframework.pulsar.config.GenericReaderEndpointRegistry
 
createReaderContainer(String...) - Method in class org.springframework.pulsar.config.DefaultPulsarReaderContainerFactory
 
createReaderContainer(String...) - Method in interface org.springframework.pulsar.config.ReaderContainerFactory
 
createReaderContainer(PulsarReaderEndpoint<PulsarMessageReaderContainer>) - Method in class org.springframework.pulsar.config.AbstractPulsarReaderContainerFactory
 
createReaderListener(PulsarMessageReaderContainer, MessageConverter) - Method in class org.springframework.pulsar.config.AbstractPulsarReaderEndpoint
 
createReaderListener(PulsarMessageReaderContainer, MessageConverter) - Method in class org.springframework.pulsar.config.MethodPulsarReaderEndpoint
 
createSender(Schema<T>, String) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory
 
createSender(Schema<T>, String) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarSenderFactory
Create a reactive message sender.
createSender(Schema<T>, String, List<ReactiveMessageSenderBuilderCustomizer<T>>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory
 
createSender(Schema<T>, String, List<ReactiveMessageSenderBuilderCustomizer<T>>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarSenderFactory
Create a reactive message sender.
createSender(Schema<T>, String, ReactiveMessageSenderBuilderCustomizer<T>) - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory
 
createSender(Schema<T>, String, ReactiveMessageSenderBuilderCustomizer<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactivePulsarSenderFactory
Create a reactive message sender.
createWithUrl(PulsarAdmin) - Method in record class org.springframework.pulsar.function.PulsarFunction
 
createWithUrl(PulsarAdmin) - Method in interface org.springframework.pulsar.function.PulsarFunctionOperations
Creates the function using the url-based create api.
createWithUrl(PulsarAdmin) - Method in record class org.springframework.pulsar.function.PulsarSink
 
createWithUrl(PulsarAdmin) - Method in record class org.springframework.pulsar.function.PulsarSource
 
currentMessage() - Method in class org.springframework.pulsar.listener.DefaultPulsarConsumerErrorHandler
 
currentMessage() - Method in interface org.springframework.pulsar.listener.PulsarConsumerErrorHandler
Returns the current message in error.
customize(PulsarAdminBuilder) - Method in interface org.springframework.pulsar.core.PulsarAdminBuilderCustomizer
Customizes a PulsarAdminBuilder.
customize(ClientBuilder) - Method in interface org.springframework.pulsar.core.PulsarClientBuilderCustomizer
Customizes a ClientBuilder.
customize(ConsumerBuilder<T>) - Method in interface org.springframework.pulsar.core.ConsumerBuilderCustomizer
Customizes a ConsumerBuilder.
customize(ProducerBuilder<T>) - Method in interface org.springframework.pulsar.core.ProducerBuilderCustomizer
Customizes a ProducerBuilder.
customize(ReaderBuilder<T>) - Method in interface org.springframework.pulsar.core.ReaderBuilderCustomizer
Customizes a ReaderBuilder.
customize(TypedMessageBuilder<T>) - Method in interface org.springframework.pulsar.core.TypedMessageBuilderCustomizer
Customizes a TypedMessageBuilder.
customize(MessageSpecBuilder<T>) - Method in interface org.springframework.pulsar.reactive.core.MessageSpecBuilderCustomizer
Customizes a MessageSpecBuilder.
customize(ReactiveMessageConsumerBuilder<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactiveMessageConsumerBuilderCustomizer
Customizes a ReactiveMessageConsumerBuilder.
customize(ReactiveMessageReaderBuilder<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactiveMessageReaderBuilderCustomizer
Customizes a ReactiveMessageReaderBuilder.
customize(ReactiveMessageSenderBuilder<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactiveMessageSenderBuilderCustomizer
Customizes a ReactiveMessageSenderBuilder.
customize(T) - Method in interface org.springframework.pulsar.core.SchemaResolver.SchemaResolverCustomizer
Customize the schema resolver.
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