Package org.springframework.pulsar.core

Class PulsarAdministration

java.lang.Object
org.springframework.pulsar.core.PulsarAdministration
All Implemented Interfaces:
Aware, SmartInitializingSingleton, ApplicationContextAware, PulsarAdministrationOperations
public class PulsarAdministration extends Object implements ApplicationContextAware, SmartInitializingSingleton, PulsarAdministrationOperations
An administration class that delegates to PulsarAdmin to create and manage topics defined in the application context.
Author:
Alexander Preuß, Chris Bono, Kirill Merkushev

  • Constructor Details

    • PulsarAdministration

      public PulsarAdministration(String serviceHttpUrl)
      Construct a default instance using the specified service url.
      Parameters:
      serviceHttpUrl - the admin http service url

    • PulsarAdministration

      public PulsarAdministration(@Nullable PulsarAdminBuilderCustomizer adminCustomizer)
      Construct an instance with the specified customizations.
      Parameters:
      adminCustomizer - the customizer to apply to the builder or null to use the default admin builder without modifications

    • PulsarAdministration

      public PulsarAdministration(List<PulsarAdminBuilderCustomizer> adminCustomizers)
      Construct an instance with the specified customizations.
      Parameters:
      adminCustomizers - the customizers to apply to the builder or null to use the default admin builder without modifications

  • Method Details