Package io.quarkus.pulsar

Class PulsarClientConfigCustomizer

java.lang.Object
io.quarkus.pulsar.PulsarClientConfigCustomizer
All Implemented Interfaces:
io.smallrye.reactive.messaging.ClientCustomizer<org.apache.pulsar.client.api.ClientBuilder>, jakarta.enterprise.inject.spi.Prioritized
@ApplicationScoped public class PulsarClientConfigCustomizer extends Object implements io.smallrye.reactive.messaging.ClientCustomizer<org.apache.pulsar.client.api.ClientBuilder>

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    (package private) io.quarkus.tls.TlsConfigurationRegistry
    tlsRegistry
     

    Fields inherited from interface io.smallrye.reactive.messaging.ClientCustomizer

    CLIENT_CONFIG_CUSTOMIZER_DEFAULT_PRIORITY

  • Constructor Summary

    Constructors
    Constructor
    Description
    PulsarClientConfigCustomizer()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.pulsar.client.api.ClientBuilder
    customize(String channel, org.eclipse.microprofile.config.Config channelConfig, org.apache.pulsar.client.api.ClientBuilder builder)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    Methods inherited from interface io.smallrye.reactive.messaging.ClientCustomizer

    getPriority

  • Field Details

    • tlsRegistry

      @Inject io.quarkus.tls.TlsConfigurationRegistry tlsRegistry

  • Constructor Details

    • PulsarClientConfigCustomizer

      public PulsarClientConfigCustomizer()

  • Method Details

    • customize

      public org.apache.pulsar.client.api.ClientBuilder customize(String channel, org.eclipse.microprofile.config.Config channelConfig, org.apache.pulsar.client.api.ClientBuilder builder)
      Specified by:
      customize in interface io.smallrye.reactive.messaging.ClientCustomizer<org.apache.pulsar.client.api.ClientBuilder>