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

Create a MessageListenerContainer for the given ListenerEndpoint.

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