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

S

SCHEMA_VERSION - Static variable in class org.apache.pulsar.spring.support.PulsarHeaders

Schema version.

schemaForTypeWithObjectMapper(Class, ObjectMapper) - Static method in interface org.apache.pulsar.spring.core.JSONSchemaUtil

Create a new JSON schema that uses the provided object mapper to de/serialize objects of the specified type.

schemaForTypeWithObjectMapper(Class, ObjectMapper, Consumer) - Static method in interface org.apache.pulsar.spring.core.JSONSchemaUtil

Create a new JSON schema that uses the provided object mapper to de/serialize objects of the specified type.

schemaInfo() - Method in record class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.TypeMapping

Returns the value of the schemaInfo record component.

SchemaInfo(SchemaType, Class) - Constructor for record class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.SchemaInfo

Creates an instance of a SchemaInfo record class.

SchemaResolver - Interface in org.apache.pulsar.spring.core

Resolves schema to use for message types.

SchemaResolver.SchemaResolverCustomizer<T> - Interface in org.apache.pulsar.spring.core

Callback interface that can be implemented by beans wishing to customize the schema resolver before it is fully initialized, in particular to tune its configuration.

schemaType() - Element in annotation interface org.apache.pulsar.spring.annotation.PulsarListener

Pulsar schema type for this listener.

schemaType() - Element in annotation interface org.apache.pulsar.spring.annotation.PulsarMessage

Default schema type to use for the annotated message class.

schemaType() - Element in annotation interface org.apache.pulsar.spring.annotation.PulsarReader

Pulsar schema type for this listener.

schemaType() - Method in record class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.SchemaInfo

Returns the value of the schemaType record component.

selectImports(AnnotationMetadata) - Method in class org.apache.pulsar.spring.annotation.PulsarAnnotationsConfigurationSelector

send() - Method in interface org.apache.pulsar.spring.core.PulsarOperations.SendMessageBuilder

Send the message in a blocking manner using the configured specification.

send() - Method in class org.apache.pulsar.spring.core.PulsarTemplate.SendMessageBuilderImpl

send(T) - Method in interface org.apache.pulsar.spring.core.PulsarOperations

Sends a message to the default topic in a blocking manner.

send(T) - Method in class org.apache.pulsar.spring.core.PulsarTemplate

send(T, Schema) - Method in interface org.apache.pulsar.spring.core.PulsarOperations

Sends a message to the default topic in a blocking manner.

send(T, Schema) - Method in class org.apache.pulsar.spring.core.PulsarTemplate

send(String, T) - Method in interface org.apache.pulsar.spring.core.PulsarOperations

Sends a message to the specified topic in a blocking manner.

send(String, T) - Method in class org.apache.pulsar.spring.core.PulsarTemplate

send(String, T, Schema) - Method in interface org.apache.pulsar.spring.core.PulsarOperations

Sends a message to the specified topic in a blocking manner.

send(String, T, Schema) - Method in class org.apache.pulsar.spring.core.PulsarTemplate

sendAsync() - Method in interface org.apache.pulsar.spring.core.PulsarOperations.SendMessageBuilder

Uses the configured specification to send the message in a non-blocking manner.

sendAsync() - Method in class org.apache.pulsar.spring.core.PulsarTemplate.SendMessageBuilderImpl

sendAsync(T) - Method in interface org.apache.pulsar.spring.core.PulsarOperations

Sends a message to the default topic in a non-blocking manner.

sendAsync(T) - Method in class org.apache.pulsar.spring.core.PulsarTemplate

sendAsync(T, Schema) - Method in interface org.apache.pulsar.spring.core.PulsarOperations

Sends a message to the default topic in a non-blocking manner.

sendAsync(T, Schema) - Method in class org.apache.pulsar.spring.core.PulsarTemplate

sendAsync(String, T) - Method in interface org.apache.pulsar.spring.core.PulsarOperations

Sends a message to the specified topic in a non-blocking manner.

sendAsync(String, T) - Method in class org.apache.pulsar.spring.core.PulsarTemplate

sendAsync(String, T, Schema) - Method in interface org.apache.pulsar.spring.core.PulsarOperations

Sends a message to the specified topic in a non-blocking manner.

sendAsync(String, T, Schema) - Method in class org.apache.pulsar.spring.core.PulsarTemplate

SEQUENCE_ID - Static variable in class org.apache.pulsar.spring.support.PulsarHeaders

Message sequence id.

setAccessMode(ProducerAccessMode) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer

setAckMode(AckMode) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setAckMode(AckMode) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setAckTimeoutRedeliveryBackoff(RedeliveryBackoff) - Method in class org.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer

setAckTimeoutRedeliveryBackoff(RedeliveryBackoff) - Method in interface org.apache.pulsar.spring.listener.PulsarMessageListenerContainer

setAckTimeoutRedeliveryBackoff(RedeliveryBackoff) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

setApplicationContext(ApplicationContext) - Method in class org.apache.pulsar.spring.annotation.AbstractPulsarAnnotationsBeanPostProcessor

setApplicationContext(ApplicationContext) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerContainerFactory

setApplicationContext(ApplicationContext) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderContainerFactory

setApplicationContext(ApplicationContext) - Method in class org.apache.pulsar.spring.config.GenericListenerEndpointRegistry

setApplicationContext(ApplicationContext) - Method in class org.apache.pulsar.spring.config.GenericReaderEndpointRegistry

setApplicationContext(ApplicationContext) - Method in class org.apache.pulsar.spring.core.AbstractPulsarMessageContainer

setApplicationContext(ApplicationContext) - Method in class org.apache.pulsar.spring.core.PulsarAdministration

setApplicationContext(ApplicationContext) - Method in class org.apache.pulsar.spring.core.PulsarTemplate

setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerContainerFactory

setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderContainerFactory

setApplicationEventPublisher(ApplicationEventPublisher) - Method in class org.apache.pulsar.spring.core.AbstractPulsarMessageContainer

setAutoAckOldestOnQueueFull(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Chunking

setAutoStartup(boolean) - Method in class org.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer

setAutoStartup(boolean) - Method in interface org.apache.pulsar.spring.listener.MessageListenerContainer

setAutoStartup(boolean) - Method in class org.apache.pulsar.spring.reader.AbstractPulsarMessageReaderContainer

setAutoStartup(boolean) - Method in interface org.apache.pulsar.spring.reader.PulsarMessageReaderContainer

setAutoStartup(Boolean) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setAutoStartup(Boolean) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderEndpoint

setAutoStartup(Boolean) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerContainerFactory

setAutoStartup(Boolean) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderContainerFactory

setAutoUpdatePartitions(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

setAutoUpdatePartitions(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

setAutoUpdatePartitionsInterval(Duration) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

setAutoUpdatePartitionsInterval(Duration) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

setBackupClusters(List) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Failover

setBatchIndexEnabled(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Acknowledgement

setBatchingEnabled(boolean) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer

setBatchListener(boolean) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setBatchListener(boolean) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setBatchListener(Boolean) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerContainerFactory

setBatchTimeoutMillis(int) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setBean(Object) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

setBean(Object) - Method in class org.apache.pulsar.spring.config.MethodPulsarReaderEndpoint

setBeanClassLoader(ClassLoader) - Method in class org.apache.pulsar.spring.core.DefaultSchemaResolver

setBeanClassLoader(ClassLoader) - Method in class org.apache.pulsar.spring.core.DefaultTopicResolver

setBeanFactory(BeanFactory) - Method in class org.apache.pulsar.spring.annotation.AbstractPulsarAnnotationsBeanPostProcessor

setBeanFactory(BeanFactory) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setBeanFactory(BeanFactory) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderEndpoint

setBeanFactory(BeanFactory) - Method in class org.apache.pulsar.spring.config.PulsarListenerEndpointRegistrar

setBeanFactory(BeanFactory) - Method in class org.apache.pulsar.spring.config.PulsarReaderEndpointRegistrar

setBeanFactory(BeanFactory) - Method in class org.apache.pulsar.spring.core.DefaultTopicResolver

setBeanName(String) - Method in class org.apache.pulsar.spring.core.AbstractPulsarMessageContainer

setBeanName(String) - Method in class org.apache.pulsar.spring.core.PulsarTemplate

setBeanResolver(BeanResolver) - Method in class org.apache.pulsar.spring.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

setBlockIfQueueFull(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

setCheckInterval(Duration) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Failover

setChunkingEnabled(boolean) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer

setCompressionType(CompressionType) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer

setConcurrency(int) - Method in class org.apache.pulsar.spring.listener.ConcurrentPulsarMessageListenerContainer

The maximum number of concurrent DefaultPulsarMessageListenerContainers running.

setConcurrency(int) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setConcurrency(Integer) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Listener

setConcurrency(Integer) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

Set the concurrency for this endpoint's container.

setConnectionTimeout(Duration) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Admin

setConnectionTimeout(Duration) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Client

setConsumer(PulsarConsumerProperties) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarBindingProperties

setConsumerBuilderCustomizer(ConsumerBuilderCustomizer) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

setConsumerCustomizer(ConsumerBuilderCustomizer) - Method in class org.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer

setConsumerCustomizer(ConsumerBuilderCustomizer) - Method in interface org.apache.pulsar.spring.listener.PulsarMessageListenerContainer

Set a consumer customizer on this container.

setConsumerProperties(Properties) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setConsumerStartTimeout(Duration) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

Set the max duration to wait for the consumer thread to start before logging an error.

setConsumerTaskExecutor(AsyncTaskExecutor) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setContainerFactory(ListenerContainerFactory) - Method in class org.apache.pulsar.spring.config.PulsarListenerEndpointRegistrar

setContainerFactory(ReaderContainerFactory) - Method in class org.apache.pulsar.spring.config.PulsarReaderEndpointRegistrar

setContainerFactoryBeanName(String) - Method in class org.apache.pulsar.spring.config.PulsarListenerEndpointRegistrar

setContainerFactoryBeanName(String) - Method in class org.apache.pulsar.spring.config.PulsarReaderEndpointRegistrar

setCryptoFailureAction(ConsumerCryptoFailureAction) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

setCryptoFailureAction(ProducerCryptoFailureAction) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

setDeadLetterPolicy(DeadLetterPolicy) - Method in class org.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer

setDeadLetterPolicy(DeadLetterPolicy) - Method in interface org.apache.pulsar.spring.listener.PulsarMessageListenerContainer

setDeadLetterPolicy(DeadLetterPolicy) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

setDeadLetterPolicy(PulsarProperties.Consumer.DeadLetterPolicy) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer

setDeadLetterTopic(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.DeadLetterPolicy

setDelay(Duration) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Failover

setEnabled(boolean) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Transaction

setEnabled(boolean) - Method in class org.apache.pulsar.spring.core.TransactionProperties

setEnabled(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties.Batching

setEncryptionKeys(Set) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

setEndpointRegistry(GenericListenerEndpointRegistry) - Method in class org.apache.pulsar.spring.config.PulsarListenerEndpointRegistrar

setEndpointRegistry(GenericReaderEndpointRegistry) - Method in class org.apache.pulsar.spring.config.PulsarReaderEndpointRegistrar

setEnvironment(Environment) - Method in class org.apache.pulsar.spring.core.DefaultPulsarClientFactory

setExpireAfterAccess(Duration) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer.Cache

setExpireTimeIncomplete(Duration) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Chunking

setExtendedBindingProperties(PulsarExtendedBindingProperties) - Method in class org.apache.pulsar.spring.cloud.stream.binder.PulsarMessageChannelBinder

setFailFast(boolean) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Function

setFallbackType(Class) - Method in class org.apache.pulsar.spring.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

setGroupTime(Duration) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Acknowledgement

setHandlerMethod(HandlerAdapter) - Method in class org.apache.pulsar.spring.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

setHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.apache.pulsar.spring.annotation.AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter

setHashingScheme(HashingScheme) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer

setId(String) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setId(String) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderEndpoint

setInitialCapacity(int) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer.Cache

setInitialPosition(SubscriptionInitialPosition) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.Subscription

setInitialSequenceId(Long) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

setInitialSubscriptionName(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.DeadLetterPolicy

setIo(Integer) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Threads

setLazyStartPartitionedProducers(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

setListener(Integer) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Threads

setLookupTimeout(Duration) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Client

setMaxBytes(DataSize) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties.Batching

setMaximumSize(long) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer.Cache

setMaxMessages(Integer) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties.Batching

setMaxNumBytes(int) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setMaxNumMessages(int) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setMaxPendingMessages(Integer) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Chunking

setMaxPendingMessages(Integer) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

setMaxPendingMessagesAcrossPartitions(Integer) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

setMaxPublishDelay(Duration) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties.Batching

setMaxRedeliverCount(int) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.DeadLetterPolicy

setMaxTotalReceiverQueueSizeAcrossPartitions(Integer) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

setMessageConverter(PulsarMessageConverter) - Method in class org.apache.pulsar.spring.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

setMessageConverter(MessageConverter) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerContainerFactory

Set the message converter to use if dynamic argument type matching is needed.

setMessageConverter(MessageConverter) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderContainerFactory

Set the message converter to use if dynamic argument type matching is needed.

setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

setMessageHandlerMethodFactory(MessageHandlerMethodFactory) - Method in class org.apache.pulsar.spring.config.MethodPulsarReaderEndpoint

setMessageKeyType(Class) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarConsumerProperties

setMessageKeyType(Class) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarProducerProperties

setMessageListener(Object) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setMessageRoutingMode(MessageRoutingMode) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer

setMessageType(Class) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarConsumerProperties

setMessageType(Class) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarProducerProperties

setMessagingConverter(SmartMessageConverter) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

setMessagingConverter(SmartMessageConverter) - Method in class org.apache.pulsar.spring.config.MethodPulsarReaderEndpoint

setMessagingConverter(SmartMessageConverter) - Method in class org.apache.pulsar.spring.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

setMessagingConverter(SmartMessageConverter) - Method in class org.apache.pulsar.spring.support.converter.PulsarRecordMessageConverter

setMethod(Method) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

Set the method to invoke to process a message managed by this endpoint.

setMethod(Method) - Method in class org.apache.pulsar.spring.config.MethodPulsarReaderEndpoint

Set the method to invoke to process a message managed by this endpoint.

setMode(SubscriptionMode) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.Subscription

setMultiSchema(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

setName(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer

setName(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.Subscription

setName(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer

setName(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Reader

setNamespace(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.Topic

setNegativeAckRedeliveryBackoff(RedeliveryBackoff) - Method in class org.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer

setNegativeAckRedeliveryBackoff(RedeliveryBackoff) - Method in interface org.apache.pulsar.spring.listener.PulsarMessageListenerContainer

setNegativeAckRedeliveryBackoff(RedeliveryBackoff) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

setObjectMapper(ObjectMapper) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

setObjectMapper(ObjectMapper) - Method in class org.apache.pulsar.spring.config.MethodPulsarReaderEndpoint

setObjectMapper(ObjectMapper) - Method in class org.apache.pulsar.spring.core.DefaultSchemaResolver

setObjectMapper(ObjectMapper) - Method in class org.apache.pulsar.spring.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

setObservationEnabled(boolean) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Listener

setObservationEnabled(boolean) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setObservationsEnabled(boolean) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Template

setOperationTimeout(Duration) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Client

setParam(Map) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Authentication

setPartitionCount(Integer) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarBinderConfigurationProperties

setPartitionCount(Integer) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarConsumerProperties

setPartitionCount(Integer) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarProducerProperties

setPartitionSwitchFrequencyByPublishDelay(Integer) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties.Batching

setPatternAutoDiscoveryPeriod(Integer) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

setPaused(boolean) - Method in class org.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer

setPhase(int) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerContainerFactory

setPhase(int) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderContainerFactory

setPhase(int) - Method in class org.apache.pulsar.spring.core.AbstractPulsarMessageContainer

setPluginClassName(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Authentication

setPolicy(AutoClusterFailoverBuilder.FailoverPolicy) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Failover

setPoolMessages(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

setPriorityLevel(int) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer

setProducer(PulsarProducerProperties) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarBindingProperties

setPropagateFailures(boolean) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Function

setPropagateStopFailures(boolean) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Function

setProperties(Map) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Subscription

setProperties(Map) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ProducerConfigProperties

setProperties(SortedMap) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

setPulsarConsumerErrorHandler(PulsarConsumerErrorHandler) - Method in class org.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer

setPulsarConsumerErrorHandler(PulsarConsumerErrorHandler) - Method in interface org.apache.pulsar.spring.listener.PulsarMessageListenerContainer

setPulsarConsumerErrorHandler(PulsarConsumerErrorHandler) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

setPulsarConsumerProperties(Properties) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setReadCompacted(boolean) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer

setReadCompacted(boolean) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Reader

setReaderBuilderCustomizer(ReaderBuilderCustomizer) - Method in class org.apache.pulsar.spring.config.MethodPulsarReaderEndpoint

setReaderCustomizer(ReaderBuilderCustomizer) - Method in class org.apache.pulsar.spring.reader.AbstractPulsarMessageReaderContainer

setReaderCustomizer(ReaderBuilderCustomizer) - Method in interface org.apache.pulsar.spring.reader.PulsarMessageReaderContainer

Set a reader customizer on this container.

setReaderListener(Object) - Method in class org.apache.pulsar.spring.reader.PulsarReaderContainerProperties

setReaderStartTimeout(Duration) - Method in class org.apache.pulsar.spring.reader.PulsarReaderContainerProperties

Set the timeout to wait for a reader thread to start before logging an error.

setReaderTaskExecutor(AsyncTaskExecutor) - Method in class org.apache.pulsar.spring.reader.PulsarReaderContainerProperties

setReadTimeout(Duration) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Admin

setReceiptEnabled(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Acknowledgement

setReceiverQueueSize(Integer) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

setRedeliveryDelay(Duration) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Acknowledgement

setReplicateState(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Subscription

setRequestTimeout(Duration) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Admin

setRequired(boolean) - Method in class org.apache.pulsar.spring.core.TransactionProperties

setResetIncludeHead(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

setRetryEnable(boolean) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer

setRetryLetterTopic(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.DeadLetterPolicy

setRunning(boolean) - Method in class org.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer

setRunning(boolean) - Method in class org.apache.pulsar.spring.reader.AbstractPulsarMessageReaderContainer

setSchema(Schema) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setSchema(Schema) - Method in class org.apache.pulsar.spring.reader.PulsarReaderContainerProperties

setSchemaResolver(SchemaResolver) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setSchemaResolver(SchemaResolver) - Method in class org.apache.pulsar.spring.reader.PulsarReaderContainerProperties

setSchemaType(SchemaType) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Listener

setSchemaType(SchemaType) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarConsumerProperties

setSchemaType(SchemaType) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.PulsarProducerProperties

setSchemaType(SchemaType) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setSchemaType(SchemaType) - Method in class org.apache.pulsar.spring.reader.PulsarReaderContainerProperties

setSchemaType(SchemaType) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setSchemaType(SchemaType) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderEndpoint

setSendTimeout(Duration) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer

setServiceUrl(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Admin

setServiceUrl(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Client

setServiceUrl(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Failover.BackupCluster

setStartMessageId(MessageId) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderEndpoint

setStartMessageId(MessageId) - Method in class org.apache.pulsar.spring.reader.PulsarReaderContainerProperties

setStartPaused(Boolean) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties

setStartupFailurePolicy(StartupFailurePolicy) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

The action to take on the container when a failure occurs during startup.

setStartupFailurePolicy(StartupFailurePolicy) - Method in class org.apache.pulsar.spring.reader.PulsarReaderContainerProperties

The action to take on the container when a failure occurs during startup.

setStartupFailureRetryTemplate(RetryTemplate) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

Set the template to use to retry startup when an exception occurs during startup.

setStartupFailureRetryTemplate(RetryTemplate) - Method in class org.apache.pulsar.spring.reader.PulsarReaderContainerProperties

Set the template to use to retry startup when an exception occurs during startup.

setSubscriptionName(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Reader

setSubscriptionName(String) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setSubscriptionName(String) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setSubscriptionName(String) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderEndpoint

setSubscriptionRolePrefix(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Reader

setSubscriptionType(SubscriptionType) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setSubscriptionType(SubscriptionType) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setSwitchBackDelay(Duration) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Failover

setTenant(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults.Topic

setTimeout(Duration) - Method in class org.apache.pulsar.spring.core.TransactionProperties

setTimeout(Duration) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Acknowledgement

setTimeoutTickDuration(Duration) - Method in class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Acknowledgement

setTopicBuilder(PulsarTopicBuilder) - Method in class org.apache.pulsar.spring.core.DefaultPulsarConsumerFactory

Non-fully-qualified topic names specified on the created consumers will be automatically fully-qualified with a default prefix (domain://tenant/namespace) according to the specified topic builder.

setTopicBuilder(PulsarTopicBuilder) - Method in class org.apache.pulsar.spring.core.DefaultPulsarProducerFactory

Non-fully-qualified topic names specified on the created producers will be automatically fully-qualified with a default prefix (domain://tenant/namespace) according to the specified topic builder.

setTopicBuilder(PulsarTopicBuilder) - Method in class org.apache.pulsar.spring.core.DefaultPulsarReaderFactory

Non-fully-qualified topic names specified on the created readers will be automatically fully-qualified with a default prefix (domain://tenant/namespace) according to the specified topic builder.

setTopicName(String) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Producer

setTopicPattern(String) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setTopicResolver(TopicResolver) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setTopics(String...) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setTopics(String...) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderEndpoint

setTopics(List) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer

setTopics(List) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Reader

setTopics(Set) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setTopics(List) - Method in class org.apache.pulsar.spring.reader.PulsarReaderContainerProperties

setTopicsMode(RegexSubscriptionMode) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.Subscription

setTopicsPattern(String) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties

setTopicsPattern(Pattern) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer

setTransactional(Boolean) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

setTransactionDefinition(TransactionDefinition) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties.TransactionSettings

Set a transaction definition with properties (e.g.

setTransactionManager(PulsarAwareTransactionManager) - Method in class org.apache.pulsar.spring.listener.PulsarContainerProperties.TransactionSettings

Set the transaction manager to start a transaction.

setTrustedPackages(String...) - Method in class org.apache.pulsar.spring.config.MethodPulsarListenerEndpoint

Add packages to trust for header deserialization.

setTrustedPackages(String...) - Method in class org.apache.pulsar.spring.config.MethodPulsarReaderEndpoint

Add packages to trust for header deserialization.

setTrustedPackages(String...) - Method in class org.apache.pulsar.spring.listener.adapter.AbstractPulsarMessageToSpringMessageAdapter

Add packages to trust for header deserialization.

setType(SubscriptionType) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.Subscription

setTypeMappings(List) - Method in class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Defaults

setupListenerContainer(C, MessageConverter) - Method in interface org.apache.pulsar.spring.config.ListenerEndpoint

Setup the specified message listener container with the model defined by this endpoint.

setupListenerContainer(C, MessageConverter) - Method in interface org.apache.pulsar.spring.config.PulsarReaderEndpoint

Sets up the specified message listener container with the model defined by this endpoint.

setupListenerContainer(PulsarMessageListenerContainer, MessageConverter) - Method in class org.apache.pulsar.spring.config.AbstractPulsarListenerEndpoint

setupListenerContainer(PulsarMessageReaderContainer, MessageConverter) - Method in class org.apache.pulsar.spring.config.AbstractPulsarReaderEndpoint

setupMessageListener(Object) - Method in class org.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer

setupMessageListener(Object) - Method in interface org.apache.pulsar.spring.listener.PulsarMessageListenerContainer

setupReaderListener(Object) - Method in class org.apache.pulsar.spring.reader.AbstractPulsarMessageReaderContainer

setupReaderListener(Object) - Method in interface org.apache.pulsar.spring.reader.PulsarMessageReaderContainer

shouldRetryMessage(Exception, Message) - Method in class org.apache.pulsar.spring.listener.DefaultPulsarConsumerErrorHandler

shouldRetryMessage(Exception, Message) - Method in interface org.apache.pulsar.spring.listener.PulsarConsumerErrorHandler

Decide if the failed message should be retried.

SINK - Enum constant in enum class org.apache.pulsar.spring.function.PulsarFunctionOperations.FunctionType

A Pulsar sink connector.

SOURCE - Enum constant in enum class org.apache.pulsar.spring.function.PulsarFunctionOperations.FunctionType

A Pulsar source connector.

start() - Method in class org.apache.pulsar.spring.config.GenericListenerEndpointRegistry

start() - Method in class org.apache.pulsar.spring.config.GenericReaderEndpointRegistry

start() - Method in class org.apache.pulsar.spring.core.CachingPulsarProducerFactory

start() - Method in class org.apache.pulsar.spring.function.PulsarFunctionAdministration

start() - Method in class org.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer

start() - Method in class org.apache.pulsar.spring.reader.AbstractPulsarMessageReaderContainer

startMessageId() - Element in annotation interface org.apache.pulsar.spring.annotation.PulsarReader

MessageId for this reader to start from.

StartupFailurePolicy - Enum Class in org.apache.pulsar.spring.config

The action to take on the container when a failure occurs during startup.

stop() - Method in class org.apache.pulsar.spring.config.GenericListenerEndpointRegistry

stop() - Method in class org.apache.pulsar.spring.config.GenericReaderEndpointRegistry

stop() - Method in class org.apache.pulsar.spring.core.CachingPulsarProducerFactory

stop() - Method in class org.apache.pulsar.spring.function.PulsarFunctionAdministration

stop() - Method in class org.apache.pulsar.spring.listener.AbstractPulsarMessageListenerContainer

stop() - Method in class org.apache.pulsar.spring.reader.AbstractPulsarMessageReaderContainer

stop(Runnable) - Method in class org.apache.pulsar.spring.config.GenericListenerEndpointRegistry

stop(Runnable) - Method in class org.apache.pulsar.spring.config.GenericReaderEndpointRegistry

stop(PulsarAdmin) - Method in record class org.apache.pulsar.spring.function.PulsarFunction

stop(PulsarAdmin) - Method in interface org.apache.pulsar.spring.function.PulsarFunctionOperations

Stops the function.

stop(PulsarAdmin) - Method in record class org.apache.pulsar.spring.function.PulsarSink

stop(PulsarAdmin) - Method in record class org.apache.pulsar.spring.function.PulsarSource

STOP - Enum constant in enum class org.apache.pulsar.spring.config.StartupFailurePolicy

Stop the container and throw exception.

STOP - Enum constant in enum class org.apache.pulsar.spring.function.PulsarFunctionOperations.FunctionStopPolicy

Stop the function if running.

stopPolicy() - Method in record class org.apache.pulsar.spring.function.PulsarFunction

Returns the value of the stopPolicy record component.

stopPolicy() - Method in interface org.apache.pulsar.spring.function.PulsarFunctionOperations

Gets the action to take on the function when the server is stopped.

stopPolicy() - Method in record class org.apache.pulsar.spring.function.PulsarSink

Returns the value of the stopPolicy record component.

stopPolicy() - Method in record class org.apache.pulsar.spring.function.PulsarSource

Returns the value of the stopPolicy record component.

Subscription() - Constructor for class org.apache.pulsar.spring.boot.autoconfigure.PulsarProperties.Consumer.Subscription

Subscription() - Constructor for class org.apache.pulsar.spring.cloud.stream.binder.properties.ConsumerConfigProperties.Subscription

subscriptionName() - Element in annotation interface org.apache.pulsar.spring.annotation.PulsarListener

Pulsar subscription name associated with this listener.

subscriptionType() - Element in annotation interface org.apache.pulsar.spring.annotation.PulsarListener

Pulsar subscription type for this listener - expected to be a single element array with subscription type or empty array to indicate null type.

supportsContext(Observation.Context) - Method in interface org.apache.pulsar.spring.observation.PulsarListenerObservationConvention

supportsContext(Observation.Context) - Method in interface org.apache.pulsar.spring.observation.PulsarTemplateObservationConvention

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