Package org.springframework.pulsar.core

Class DefaultPulsarClientFactory

java.lang.Object
org.springframework.pulsar.core.DefaultPulsarClientFactory
All Implemented Interfaces:
Aware, EnvironmentAware, PulsarClientFactory
public class DefaultPulsarClientFactory extends Object implements PulsarClientFactory, EnvironmentAware
Default implementation for PulsarClientFactory.
Author:
Soby Chacko, Chris Bono

  • Constructor Details

    • DefaultPulsarClientFactory

      public DefaultPulsarClientFactory(String serviceUrl)
      Construct a factory that creates clients using a default Pulsar client builder with no modifications other than the specified service url.
      Parameters:
      serviceUrl - the service url

    • DefaultPulsarClientFactory

      public DefaultPulsarClientFactory(PulsarClientBuilderCustomizer customizer)
      Construct a factory that creates clients using a customized Pulsar client builder.
      Parameters:
      customizer - the customizer to apply to the builder

  • Method Details