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, 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) - 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.

ConcurrentPulsarListenerContainerFactory<T> - Class in org.springframework.pulsar.config

Concrete implementation for PulsarListenerContainerFactory.

ConcurrentPulsarListenerContainerFactory(PulsarConsumerFactory, 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, 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, MessageHandlerMethodFactory) - Method in class org.springframework.pulsar.config.MethodPulsarListenerEndpoint

configureListenerAdapter(AbstractPulsarMessageToSpringMessageAdapter, MessageHandlerMethodFactory) - Method in class org.springframework.pulsar.config.MethodPulsarReaderEndpoint

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.

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

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) - Method in interface org.springframework.pulsar.cache.provider.CacheProviderFactory

Create a cache provider instance with the specified options.

create(Duration, Long, Integer, CacheProviderFactory.EvictionListener) - 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, Collection, String, Map, List) - Method in class org.springframework.pulsar.core.DefaultPulsarConsumerFactory

createConsumer(Schema, Collection, String, Map, List) - Method in interface org.springframework.pulsar.core.PulsarConsumerFactory

Create a consumer.

createConsumer(Schema, Collection, String, ConsumerBuilderCustomizer) - Method in class org.springframework.pulsar.core.DefaultPulsarConsumerFactory

createConsumer(Schema, Collection, String, ConsumerBuilderCustomizer) - Method in interface org.springframework.pulsar.core.PulsarConsumerFactory

Create a 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.

createContainerInstance(PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.AbstractPulsarListenerContainerFactory

createContainerInstance(PulsarListenerEndpoint) - Method in class org.springframework.pulsar.config.ConcurrentPulsarListenerContainerFactory

createContainerInstance(PulsarReaderEndpoint) - Method in class org.springframework.pulsar.config.AbstractPulsarReaderContainerFactory

createContainerInstance(PulsarReaderEndpoint) - Method in class org.springframework.pulsar.config.DefaultPulsarReaderContainerFactory

createInvocableHandlerMethod(Object, Method) - Method in class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter

createListenerContainer(E, ListenerContainerFactory) - Method in class org.springframework.pulsar.config.GenericListenerEndpointRegistry

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

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, String) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory

createProducer(Schema, String) - Method in interface org.springframework.pulsar.core.PulsarProducerFactory

Create a producer.

createProducer(Schema, String, Collection, List) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory

createProducer(Schema, String, Collection, List) - Method in interface org.springframework.pulsar.core.PulsarProducerFactory

Create a producer.

createProducer(Schema, String, ProducerBuilderCustomizer) - Method in class org.springframework.pulsar.core.DefaultPulsarProducerFactory

createProducer(Schema, String, ProducerBuilderCustomizer) - Method in interface org.springframework.pulsar.core.PulsarProducerFactory

Create a producer.

createReader(List, MessageId, Schema, List) - Method in class org.springframework.pulsar.core.DefaultPulsarReaderFactory

createReader(List, MessageId, Schema, List) - Method in interface org.springframework.pulsar.core.PulsarReaderFactory

Creating a Pulsar Reader based on the provided topics, schema and properties.

createReaderContainer(E, ReaderContainerFactory) - Method in class org.springframework.pulsar.config.GenericReaderEndpointRegistry

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) - Method in class org.springframework.pulsar.config.AbstractPulsarReaderContainerFactory

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

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) - Method in interface org.springframework.pulsar.annotation.PulsarListenerConsumerBuilderCustomizer

Customize the ConsumerBuilder.

customize(ConsumerBuilder) - Method in interface org.springframework.pulsar.core.ConsumerBuilderCustomizer

Customize the ConsumerBuilder.

customize(ProducerBuilder) - Method in interface org.springframework.pulsar.core.ProducerBuilderCustomizer

Customizes a ProducerBuilder.

customize(ReaderBuilder) - Method in interface org.springframework.pulsar.annotation.PulsarReaderReaderBuilderCustomizer

Customize the ReaderBuilder.

customize(ReaderBuilder) - Method in interface org.springframework.pulsar.core.ReaderBuilderCustomizer

Customizes a ReaderBuilder.

customize(TypedMessageBuilder) - Method in interface org.springframework.pulsar.core.TypedMessageBuilderCustomizer

Customizes a TypedMessageBuilder.

customize(PulsarTemplate) - 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