C-Index (Spring for Apache Pulsar 1.2.1 API)

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.).
commit() - Method in class org.springframework.pulsar.transaction.PulsarResourceHolder
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
ConcurrentPulsarListenerContainerFactoryCustomizer<T> - Interface in org.springframework.pulsar.config: Deprecated, for removal: This API element is subject to removal in a future version.
since 1.2.0 for removal in 1.4.0 in favor of org.springframework.boot.autoconfigure.pulsar.PulsarContainerFactoryCustomizer<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: Callback interface that can be implemented to customize the ConsumerBuilder that is used by the PulsarConsumerFactory to create consumers.
consumerCustomizer() - Element in annotation interface org.springframework.pulsar.annotation.PulsarListener: The bean name or a SpEL expression that resolves to a PulsarListenerConsumerBuilderCustomizer to use to configure the underlying consumer.
consumerCustomizer() - Element in annotation interface org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener: The bean name or a SpEL expression that resolves to a ReactivePulsarListenerMessageConsumerBuilderCustomizer to use to configure the underlying 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 PulsarListenerContainerFactory to use to create the message listener container responsible to serve this endpoint.
CONTINUE - Enum constant in enum class org.springframework.pulsar.config.StartupFailurePolicy: Stop the container but do not throw exception.
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 class org.springframework.pulsar.config.DefaultPulsarReaderContainerFactory
createContainer(String...) - Method in interface org.springframework.pulsar.config.PulsarContainerFactory: Create and configure a container without a listener.
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: Deprecated, for removal: This API element is subject to removal in a future version.
since 1.2.0 for removal in 1.4.0 in favor of PulsarContainerFactory.createRegisteredContainer(E)
createListenerContainer(E, ListenerContainerFactory<? extends C, E>) - Method in class org.springframework.pulsar.config.GenericListenerEndpointRegistry
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: Deprecated, for removal: This API element is subject to removal in a future version.
since 1.2.0 for removal in 1.4.0 in favor of PulsarContainerFactory.createRegisteredContainer(E)
createReaderContainer(E, ReaderContainerFactory<? extends C, E>) - Method in class org.springframework.pulsar.config.GenericReaderEndpointRegistry
createReaderContainer(String...) - Method in interface org.springframework.pulsar.config.ReaderContainerFactory: Deprecated, for removal: This API element is subject to removal in a future version.
since 1.2.0 for removal in 1.4.0 in favor of PulsarContainerFactory.createContainer(java.lang.String...)
createReaderListener(PulsarMessageReaderContainer, MessageConverter) - Method in class org.springframework.pulsar.config.AbstractPulsarReaderEndpoint
createReaderListener(PulsarMessageReaderContainer, MessageConverter) - Method in class org.springframework.pulsar.config.MethodPulsarReaderEndpoint
createRegisteredContainer(E) - Method in interface org.springframework.pulsar.config.PulsarContainerFactory: Create a message listener container for the given endpoint.
createRegisteredContainer(PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory
createRegisteredContainer(PulsarReaderEndpoint<PulsarMessageReaderContainer>) - Method in class org.springframework.pulsar.config.AbstractPulsarReaderContainerFactory
createRegisteredContainer(ReactivePulsarListenerEndpoint<T>) - Method in class org.springframework.pulsar.reactive.config.DefaultReactivePulsarListenerContainerFactory
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.
currentState() - Method in class org.springframework.pulsar.core.CachingPulsarProducerFactory
currentState() - Method in class org.springframework.pulsar.reactive.core.DefaultReactivePulsarSenderFactory
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.annotation.PulsarListenerConsumerBuilderCustomizer: Customize the ConsumerBuilder.
customize(ConsumerBuilder<T>) - Method in interface org.springframework.pulsar.core.ConsumerBuilderCustomizer: Customize the ConsumerBuilder.
customize(ProducerBuilder<T>) - Method in interface org.springframework.pulsar.core.ProducerBuilderCustomizer: Customizes a ProducerBuilder.
customize(ReaderBuilder<T>) - Method in interface org.springframework.pulsar.annotation.PulsarReaderReaderBuilderCustomizer: Customize the ReaderBuilder.
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.config.annotation.ReactivePulsarListenerMessageConsumerBuilderCustomizer: Customize the ReactiveMessageConsumerBuilder.
customize(ReactiveMessageConsumerBuilder<T>) - Method in interface org.springframework.pulsar.reactive.core.ReactiveMessageConsumerBuilderCustomizer: Customize the 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(ConcurrentPulsarListenerContainerFactory<T>) - Method in interface org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactoryCustomizer: Deprecated.

Customize a ConcurrentPulsarListenerContainerFactory.
customize(PulsarTemplate<T>) - Method in interface org.springframework.pulsar.core.PulsarTemplateCustomizer: Customize a PulsarTemplate.
customize(T) - Method in interface org.springframework.pulsar.core.SchemaResolver.SchemaResolverCustomizer: Customize the schema resolver.
customMapper(BeanFactory) - Static method in class org.springframework.pulsar.annotation.PulsarHeaderObjectMapperUtils: Gets the optional ObjectMapper to use when deserializing JSON header values.

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