public interface PulsarClientConfiguration
| Modifier and Type | Method and Description |
|---|---|
org.apache.pulsar.client.api.Authentication |
getAuthentication() |
default java.util.Optional<java.lang.Integer> |
getIoThreads() |
default java.util.Optional<java.lang.Integer> |
getListenerThreads() |
java.lang.String |
getServiceUrl() |
default java.util.Optional<org.apache.pulsar.client.api.ServiceUrlProvider> |
getServiceUrlProvider() |
default boolean |
getShutdownOnSubscriberError() |
java.util.Optional<java.lang.String> |
getSslProvider() |
java.util.Optional<java.lang.Boolean> |
getTlsAllowInsecureConnection() |
java.util.Optional<java.lang.String> |
getTlsCertFilePath() |
java.util.Optional<java.util.Set<java.lang.String>> |
getTlsCiphers() |
java.util.Optional<java.util.Set<java.lang.String>> |
getTlsProtocols() |
java.util.Optional<java.lang.String> |
getTlsTrustStorePath() |
java.util.Optional<java.lang.Boolean> |
getTlsVerifyHostname() |
java.lang.String getServiceUrl()
default java.util.Optional<org.apache.pulsar.client.api.ServiceUrlProvider> getServiceUrlProvider()
org.apache.pulsar.client.api.Authentication getAuthentication()
default java.util.Optional<java.lang.Integer> getIoThreads()
default java.util.Optional<java.lang.Integer> getListenerThreads()
java.util.Optional<java.lang.String> getSslProvider()
java.util.Optional<java.lang.String> getTlsTrustStorePath()
java.util.Optional<java.lang.String> getTlsCertFilePath()
java.util.Optional<java.lang.Boolean> getTlsVerifyHostname()
java.util.Optional<java.lang.Boolean> getTlsAllowInsecureConnection()
java.util.Optional<java.util.Set<java.lang.String>> getTlsCiphers()
java.util.Optional<java.util.Set<java.lang.String>> getTlsProtocols()
default boolean getShutdownOnSubscriberError()