Class PulsarProperties.Client
java.lang.Object
org.springframework.pulsar.autoconfigure.PulsarProperties.Client
- Enclosing class:
- PulsarProperties
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionorg.apache.pulsar.client.api.ProxyProtocolvoidsetAuthentication(Map<String, String> authentication) voidsetAuthParams(String authParams) voidsetAuthPluginClassName(String authPluginClassName) voidsetConnectionTimeout(Duration connectionTimeout) voidsetDnsLookupBindAddress(String dnsLookupBindAddress) voidsetDnsLookupBindPort(Integer dnsLookupBindPort) voidsetEnableBusyWait(Boolean enableBusyWait) voidsetEnableTransaction(Boolean enableTransaction) voidsetInitialBackoffInterval(Duration initialBackoffInterval) voidsetKeepAliveInterval(Duration keepAliveInterval) voidsetListenerName(String listenerName) voidsetLookupTimeout(Duration lookupTimeout) voidsetMaxBackoffInterval(Duration maxBackoffInterval) voidsetMaxConcurrentLookupRequest(Integer maxConcurrentLookupRequest) voidsetMaxLookupRedirects(Integer maxLookupRedirects) voidsetMaxLookupRequest(Integer maxLookupRequest) voidsetMaxNumberOfRejectedRequestPerConnection(Integer maxNumberOfRejectedRequestPerConnection) voidsetMemoryLimit(DataSize memoryLimit) voidsetNumConnectionsPerBroker(Integer numConnectionsPerBroker) voidsetNumIoThreads(Integer numIoThreads) voidsetNumListenerThreads(Integer numListenerThreads) voidsetOperationTimeout(Duration operationTimeout) voidsetProxyProtocol(org.apache.pulsar.client.api.ProxyProtocol proxyProtocol) voidsetProxyServiceUrl(String proxyServiceUrl) voidsetRequestTimeout(Duration requestTimeout) voidsetServiceUrl(String serviceUrl) voidsetSocks5ProxyAddress(String socks5ProxyAddress) voidsetSocks5ProxyPassword(String socks5ProxyPassword) voidsetSocks5ProxyUsername(String socks5ProxyUsername) voidsetSslProvider(String sslProvider) voidsetStatsInterval(Duration statsInterval) voidsetTlsAllowInsecureConnection(Boolean tlsAllowInsecureConnection) voidsetTlsCiphers(Set<String> tlsCiphers) voidsetTlsHostnameVerificationEnable(Boolean tlsHostnameVerificationEnable) voidsetTlsProtocols(Set<String> tlsProtocols) voidsetTlsTrustCertsFilePath(String tlsTrustCertsFilePath) voidsetTlsTrustStorePassword(String tlsTrustStorePassword) voidsetTlsTrustStorePath(String tlsTrustStorePath) voidsetTlsTrustStoreType(String tlsTrustStoreType) voidsetUseKeyStoreTls(Boolean useKeyStoreTls) voidsetUseTcpNoDelay(Boolean useTcpNoDelay) void
-
Constructor Details
-
Client
public Client()
-
-
Method Details
-
getServiceUrl
-
setServiceUrl
-
getListenerName
-
setListenerName
-
getAuthPluginClassName
-
setAuthPluginClassName
-
getAuthParams
-
setAuthParams
-
getAuthentication
-
setAuthentication
-
getOperationTimeout
-
setOperationTimeout
-
getLookupTimeout
-
setLookupTimeout
-
getNumIoThreads
-
setNumIoThreads
-
getNumListenerThreads
-
setNumListenerThreads
-
getNumConnectionsPerBroker
-
setNumConnectionsPerBroker
-
getUseTcpNoDelay
-
setUseTcpNoDelay
-
getUseTls
-
setUseTls
-
getTlsHostnameVerificationEnable
-
setTlsHostnameVerificationEnable
-
getTlsTrustCertsFilePath
-
setTlsTrustCertsFilePath
-
getTlsAllowInsecureConnection
-
setTlsAllowInsecureConnection
-
getUseKeyStoreTls
-
setUseKeyStoreTls
-
getSslProvider
-
setSslProvider
-
getTlsTrustStoreType
-
setTlsTrustStoreType
-
getTlsTrustStorePath
-
setTlsTrustStorePath
-
getTlsTrustStorePassword
-
setTlsTrustStorePassword
-
getTlsCiphers
-
setTlsCiphers
-
getTlsProtocols
-
setTlsProtocols
-
getStatsInterval
-
setStatsInterval
-
getMaxConcurrentLookupRequest
-
setMaxConcurrentLookupRequest
-
getMaxLookupRequest
-
setMaxLookupRequest
-
getMaxLookupRedirects
-
setMaxLookupRedirects
-
getMaxNumberOfRejectedRequestPerConnection
-
setMaxNumberOfRejectedRequestPerConnection
public void setMaxNumberOfRejectedRequestPerConnection(Integer maxNumberOfRejectedRequestPerConnection) -
getKeepAliveInterval
-
setKeepAliveInterval
-
getConnectionTimeout
-
setConnectionTimeout
-
getRequestTimeout
-
setRequestTimeout
-
getInitialBackoffInterval
-
setInitialBackoffInterval
-
getMaxBackoffInterval
-
setMaxBackoffInterval
-
getEnableBusyWait
-
setEnableBusyWait
-
getMemoryLimit
-
setMemoryLimit
-
getProxyServiceUrl
-
setProxyServiceUrl
-
getProxyProtocol
public org.apache.pulsar.client.api.ProxyProtocol getProxyProtocol() -
setProxyProtocol
public void setProxyProtocol(org.apache.pulsar.client.api.ProxyProtocol proxyProtocol) -
getEnableTransaction
-
setEnableTransaction
-
getDnsLookupBindAddress
-
setDnsLookupBindAddress
-
getDnsLookupBindPort
-
setDnsLookupBindPort
-
getSocks5ProxyAddress
-
setSocks5ProxyAddress
-
getSocks5ProxyUsername
-
setSocks5ProxyUsername
-
getSocks5ProxyPassword
-
setSocks5ProxyPassword
-
buildProperties
-