Index

A B C D E F G H I L M O P R S T
All Classes and Interfaces|All Packages

A

Admin() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Admin

Authentication() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Authentication

B

BackupCluster() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Failover.BackupCluster

C

Cache() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer.Cache

Client() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Client

Consumer() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer

customize(T) - Method in interface org.springframework.boot.pulsar.autoconfigure.PulsarContainerFactoryCustomizer

Customize the container factory.

D

DeadLetterPolicy() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer.DeadLetterPolicy

Defaults() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults

E

equals(Object) - Method in record class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.SchemaInfo

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.TypeMapping

Indicates whether some other object is "equal to" this one.

F

Failover() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Failover

Function() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Function

G

getAccessMode() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

getAdmin() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties

getAdminUrl() - Method in interface org.springframework.boot.pulsar.autoconfigure.PulsarConnectionDetails

URL user to connect to the admin endpoint.

getAuthentication() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Admin

getAuthentication() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Client

getAuthentication() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Failover.BackupCluster

getBackupClusters() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Failover

getBrokerUrl() - Method in interface org.springframework.boot.pulsar.autoconfigure.PulsarConnectionDetails

URL used to connect to the broker.

getCache() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

getCheckInterval() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Failover

getClient() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties

getCompressionType() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

getConcurrency() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Listener

getConnectionTimeout() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Admin

getConnectionTimeout() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Client

getConsumer() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties

getDeadLetterPolicy() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer

getDeadLetterTopic() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer.DeadLetterPolicy

getDefaults() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties

getDelay() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Failover

getExpireAfterAccess() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer.Cache

getFailover() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Client

getFunction() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties

getHashingScheme() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

getInitialCapacity() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer.Cache

getInitialPosition() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer.Subscription

getInitialSubscriptionName() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer.DeadLetterPolicy

getIo() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Threads

getListener() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties

getListener() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Threads

getLookupTimeout() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Client

getMaximumSize() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer.Cache

getMaxRedeliverCount() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer.DeadLetterPolicy

getMessageRoutingMode() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

getMode() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer.Subscription

getName() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer

getName() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer.Subscription

getName() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

getName() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Reader

getNamespace() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.Topic

getOperationTimeout() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Client

getParam() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Authentication

getPluginClassName() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Authentication

getPolicy() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Failover

getPriorityLevel() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer

getProducer() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties

getReader() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties

getReadTimeout() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Admin

getRequestTimeout() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Admin

getRetryLetterTopic() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer.DeadLetterPolicy

getSchemaType() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Listener

getSendTimeout() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

getServiceUrl() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Admin

getServiceUrl() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Client

getServiceUrl() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Failover.BackupCluster

getSubscription() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer

getSubscriptionName() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Reader

getSubscriptionRolePrefix() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Reader

getSwitchBackDelay() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Failover

getTemplate() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties

getTenant() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.Topic

getThreads() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Client

getTopic() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults

getTopicName() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

getTopics() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer

getTopics() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Reader

getTopicsMode() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer.Subscription

getTopicsPattern() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer

getTransaction() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties

getType() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer.Subscription

getTypeMappings() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults

H

hashCode() - Method in record class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.SchemaInfo

Returns a hash code value for this object.

hashCode() - Method in record class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.TypeMapping

Returns a hash code value for this object.

I

isBatchingEnabled() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

isChunkingEnabled() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

isEnabled() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Transaction

isFailFast() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Function

isObservationEnabled() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Listener

isObservationsEnabled() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Template

isPropagateFailures() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Function

isPropagateStopFailures() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Function

isReadCompacted() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer

isReadCompacted() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Reader

isRetryEnable() - Method in class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Consumer

L

Listener() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Listener

M

messageKeyType() - Method in record class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.SchemaInfo

Returns the value of the messageKeyType record component.

messageType() - Method in record class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.TypeMapping

Returns the value of the messageType record component.

O

org.springframework.boot.pulsar.autoconfigure - package org.springframework.boot.pulsar.autoconfigure

Auto-configuration for Spring for Apache Pulsar.

P

Producer() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Producer

PulsarAutoConfiguration - Class in org.springframework.boot.pulsar.autoconfigure

Auto-configuration for Apache Pulsar.

PulsarConnectionDetails - Interface in org.springframework.boot.pulsar.autoconfigure

Details required to establish a connection to a Pulsar service.

PulsarContainerFactoryCustomizer<T> - Interface in org.springframework.boot.pulsar.autoconfigure

Callback interface that can be implemented by beans wishing to customize a PulsarContainerFactory to fine-tune its auto-configuration.

PulsarProperties - Class in org.springframework.boot.pulsar.autoconfigure

Configuration properties Apache Pulsar.

PulsarProperties() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties

PulsarProperties.Admin - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Authentication - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Client - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Consumer - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Consumer.DeadLetterPolicy - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Consumer.Subscription - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Defaults - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Defaults.SchemaInfo - Record Class in org.springframework.boot.pulsar.autoconfigure

Represents a schema - holds enough information to construct an actual schema instance.

PulsarProperties.Defaults.Topic - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Defaults.TypeMapping - Record Class in org.springframework.boot.pulsar.autoconfigure

A mapping from message type to topic and/or schema info to use (at least one of topicName or schemaInfo must be specified.

PulsarProperties.Failover - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Failover.BackupCluster - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Function - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Listener - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Producer - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Producer.Cache - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Reader - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Template - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Threads - Class in org.springframework.boot.pulsar.autoconfigure

PulsarProperties.Transaction - Class in org.springframework.boot.pulsar.autoconfigure

R

Reader() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Reader

S

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

Returns the value of the schemaInfo record component.

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

Creates an instance of a SchemaInfo record class.

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

Returns the value of the schemaType record component.

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

T

Template() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Template

Threads() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Threads

Topic() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.Topic

topicName() - Method in record class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.TypeMapping

Returns the value of the topicName record component.

toString() - Method in record class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.SchemaInfo

Returns a string representation of this record class.

toString() - Method in record class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.TypeMapping

Returns a string representation of this record class.

Transaction() - Constructor for class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Transaction

TypeMapping(Class, String, PulsarProperties.Defaults.SchemaInfo) - Constructor for record class org.springframework.boot.pulsar.autoconfigure.PulsarProperties.Defaults.TypeMapping

Creates an instance of a TypeMapping record class.

A B C D E F G H I L M O P R S T
All Classes and Interfaces|All Packages