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 Summary

Constructors

Constructor	Description
PulsarAdministration(Map<String,Object> adminConfig)	Construct a PulsarAdministration instance using the given configuration for the underlying PulsarAdmin.
PulsarAdministration(org.apache.pulsar.client.admin.PulsarAdminBuilder adminBuilder)	Construct a PulsarAdministration instance using the given builder for the underlying PulsarAdmin.

Method Summary

Modifier and Type	Method	Description
void	afterSingletonsInstantiated()
org.apache.pulsar.client.admin.PulsarAdmin	createAdminClient()
void	createOrModifyTopics(PulsarTopic... topics)	Create or modify the given topics.
void	setApplicationContext(ApplicationContext applicationContext)

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarAdministration

public PulsarAdministration(Map<String,Object> adminConfig)

Construct a PulsarAdministration instance using the given configuration for the underlying PulsarAdmin.

Parameters:

adminConfig - the PulsarAdmin configuration

PulsarAdministration

public PulsarAdministration(org.apache.pulsar.client.admin.PulsarAdminBuilder adminBuilder)

Construct a PulsarAdministration instance using the given builder for the underlying PulsarAdmin.

Parameters:

adminBuilder - the PulsarAdminBuilder

Method Details

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface SmartInitializingSingleton

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

createAdminClient

public org.apache.pulsar.client.admin.PulsarAdmin createAdminClient()
                                                             throws org.apache.pulsar.client.api.PulsarClientException

Throws:

org.apache.pulsar.client.api.PulsarClientException

createOrModifyTopics

public void createOrModifyTopics(PulsarTopic... topics)

Description copied from interface: PulsarAdministrationOperations

Create or modify the given topics.

Specified by:

createOrModifyTopics in interface PulsarAdministrationOperations

Parameters:

topics - the topics to create or change