Package org.springframework.pulsar.autoconfigure

Class PulsarProperties.Client

java.lang.Object
org.springframework.pulsar.autoconfigure.PulsarProperties.Client
Enclosing class:
PulsarProperties
public static class PulsarProperties.Client extends Object

  • Constructor Details

    • Client

      public Client()

  • Method Details

    • getServiceUrl

      public String getServiceUrl()

    • setServiceUrl

      public void setServiceUrl(String serviceUrl)

    • getListenerName

      public String getListenerName()

    • setListenerName

      public void setListenerName(String listenerName)

    • getAuthPluginClassName

      public String getAuthPluginClassName()

    • setAuthPluginClassName

      public void setAuthPluginClassName(String authPluginClassName)

    • getAuthParams

      public String getAuthParams()

    • setAuthParams

      public void setAuthParams(String authParams)

    • getAuthentication

      public Map<String,String> getAuthentication()

    • setAuthentication

      public void setAuthentication(Map<String,String> authentication)

    • getOperationTimeout

      public Duration getOperationTimeout()

    • setOperationTimeout

      public void setOperationTimeout(Duration operationTimeout)

    • getLookupTimeout

      public Duration getLookupTimeout()

    • setLookupTimeout

      public void setLookupTimeout(Duration lookupTimeout)

    • getNumIoThreads

      public Integer getNumIoThreads()

    • setNumIoThreads

      public void setNumIoThreads(Integer numIoThreads)

    • getNumListenerThreads

      public Integer getNumListenerThreads()

    • setNumListenerThreads

      public void setNumListenerThreads(Integer numListenerThreads)

    • getNumConnectionsPerBroker

      public Integer getNumConnectionsPerBroker()

    • setNumConnectionsPerBroker

      public void setNumConnectionsPerBroker(Integer numConnectionsPerBroker)

    • getUseTcpNoDelay

      public Boolean getUseTcpNoDelay()

    • setUseTcpNoDelay

      public void setUseTcpNoDelay(Boolean useTcpNoDelay)

    • getUseTls

      public Boolean getUseTls()

    • setUseTls

      public void setUseTls(Boolean useTls)

    • getTlsHostnameVerificationEnable

      public Boolean getTlsHostnameVerificationEnable()

    • setTlsHostnameVerificationEnable

      public void setTlsHostnameVerificationEnable(Boolean tlsHostnameVerificationEnable)

    • getTlsTrustCertsFilePath

      public String getTlsTrustCertsFilePath()

    • setTlsTrustCertsFilePath

      public void setTlsTrustCertsFilePath(String tlsTrustCertsFilePath)

    • getTlsAllowInsecureConnection

      public Boolean getTlsAllowInsecureConnection()

    • setTlsAllowInsecureConnection

      public void setTlsAllowInsecureConnection(Boolean tlsAllowInsecureConnection)

    • getUseKeyStoreTls

      public Boolean getUseKeyStoreTls()

    • setUseKeyStoreTls

      public void setUseKeyStoreTls(Boolean useKeyStoreTls)

    • getSslProvider

      public String getSslProvider()

    • setSslProvider

      public void setSslProvider(String sslProvider)

    • getTlsTrustStoreType

      public String getTlsTrustStoreType()

    • setTlsTrustStoreType

      public void setTlsTrustStoreType(String tlsTrustStoreType)

    • getTlsTrustStorePath

      public String getTlsTrustStorePath()

    • setTlsTrustStorePath

      public void setTlsTrustStorePath(String tlsTrustStorePath)

    • getTlsTrustStorePassword

      public String getTlsTrustStorePassword()

    • setTlsTrustStorePassword

      public void setTlsTrustStorePassword(String tlsTrustStorePassword)

    • getTlsCiphers

      public Set<String> getTlsCiphers()

    • setTlsCiphers

      public void setTlsCiphers(Set<String> tlsCiphers)

    • getTlsProtocols

      public Set<String> getTlsProtocols()

    • setTlsProtocols

      public void setTlsProtocols(Set<String> tlsProtocols)

    • getStatsInterval

      public Duration getStatsInterval()

    • setStatsInterval

      public void setStatsInterval(Duration statsInterval)

    • getMaxConcurrentLookupRequest

      public Integer getMaxConcurrentLookupRequest()

    • setMaxConcurrentLookupRequest

      public void setMaxConcurrentLookupRequest(Integer maxConcurrentLookupRequest)

    • getMaxLookupRequest

      public Integer getMaxLookupRequest()

    • setMaxLookupRequest

      public void setMaxLookupRequest(Integer maxLookupRequest)

    • getMaxLookupRedirects

      public Integer getMaxLookupRedirects()

    • setMaxLookupRedirects

      public void setMaxLookupRedirects(Integer maxLookupRedirects)

    • getMaxNumberOfRejectedRequestPerConnection

      public Integer getMaxNumberOfRejectedRequestPerConnection()

    • setMaxNumberOfRejectedRequestPerConnection

      public void setMaxNumberOfRejectedRequestPerConnection(Integer maxNumberOfRejectedRequestPerConnection)

    • getKeepAliveInterval

      public Duration getKeepAliveInterval()

    • setKeepAliveInterval

      public void setKeepAliveInterval(Duration keepAliveInterval)

    • getConnectionTimeout

      public Duration getConnectionTimeout()

    • setConnectionTimeout

      public void setConnectionTimeout(Duration connectionTimeout)

    • getRequestTimeout

      public Duration getRequestTimeout()

    • setRequestTimeout

      public void setRequestTimeout(Duration requestTimeout)

    • getInitialBackoffInterval

      public Duration getInitialBackoffInterval()

    • setInitialBackoffInterval

      public void setInitialBackoffInterval(Duration initialBackoffInterval)

    • getMaxBackoffInterval

      public Duration getMaxBackoffInterval()

    • setMaxBackoffInterval

      public void setMaxBackoffInterval(Duration maxBackoffInterval)

    • getEnableBusyWait

      public Boolean getEnableBusyWait()

    • setEnableBusyWait

      public void setEnableBusyWait(Boolean enableBusyWait)

    • getMemoryLimit

      public DataSize getMemoryLimit()

    • setMemoryLimit

      public void setMemoryLimit(DataSize memoryLimit)

    • getProxyServiceUrl

      public String getProxyServiceUrl()

    • setProxyServiceUrl

      public void setProxyServiceUrl(String proxyServiceUrl)

    • getProxyProtocol

      public org.apache.pulsar.client.api.ProxyProtocol getProxyProtocol()

    • setProxyProtocol

      public void setProxyProtocol(org.apache.pulsar.client.api.ProxyProtocol proxyProtocol)

    • getEnableTransaction

      public Boolean getEnableTransaction()

    • setEnableTransaction

      public void setEnableTransaction(Boolean enableTransaction)

    • getDnsLookupBindAddress

      public String getDnsLookupBindAddress()

    • setDnsLookupBindAddress

      public void setDnsLookupBindAddress(String dnsLookupBindAddress)

    • getDnsLookupBindPort

      public Integer getDnsLookupBindPort()

    • setDnsLookupBindPort

      public void setDnsLookupBindPort(Integer dnsLookupBindPort)

    • getSocks5ProxyAddress

      public String getSocks5ProxyAddress()

    • setSocks5ProxyAddress

      public void setSocks5ProxyAddress(String socks5ProxyAddress)

    • getSocks5ProxyUsername

      public String getSocks5ProxyUsername()

    • setSocks5ProxyUsername

      public void setSocks5ProxyUsername(String socks5ProxyUsername)

    • getSocks5ProxyPassword

      public String getSocks5ProxyPassword()

    • setSocks5ProxyPassword

      public void setSocks5ProxyPassword(String socks5ProxyPassword)

    • buildProperties

      public Map<String,Object> buildProperties()