Class PulsarReaderEndpointRegistrar

java.lang.Object

org.apache.pulsar.spring.config.PulsarReaderEndpointRegistrar

All Implemented Interfaces:

Aware, BeanFactoryAware, InitializingBean

public class PulsarReaderEndpointRegistrar
extends Object
implements BeanFactoryAware, InitializingBean

Helper bean for registering PulsarReaderEndpoint with a GenericReaderEndpointRegistry.

Author:

Soby Chacko

Constructor Summary

Constructors

Constructor	Description
PulsarReaderEndpointRegistrar(Class<? extends ReaderContainerFactory> type)

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
@Nullable GenericReaderEndpointRegistry	getEndpointRegistry()
protected void	registerAllEndpoints()
void	registerEndpoint(PulsarReaderEndpoint endpoint, @Nullable ReaderContainerFactory<?,?> factory)
protected GenericReaderEndpointRegistry	requireNonNullEndpointRegistry()
void	setBeanFactory(BeanFactory beanFactory)
void	setContainerFactory(ReaderContainerFactory<?,?> containerFactory)
void	setContainerFactoryBeanName(String containerFactoryBeanName)
void	setEndpointRegistry(GenericReaderEndpointRegistry endpointRegistry)

Methods inherited from class Object

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

Constructor Details

PulsarReaderEndpointRegistrar

public PulsarReaderEndpointRegistrar(Class<? extends ReaderContainerFactory> type)

Method Details

setEndpointRegistry

public void setEndpointRegistry(GenericReaderEndpointRegistry endpointRegistry)

getEndpointRegistry

public @Nullable GenericReaderEndpointRegistry getEndpointRegistry()

requireNonNullEndpointRegistry

protected GenericReaderEndpointRegistry requireNonNullEndpointRegistry()

setContainerFactory

public void setContainerFactory(ReaderContainerFactory<?,?> containerFactory)

setContainerFactoryBeanName

public void setContainerFactoryBeanName(String containerFactoryBeanName)

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)

Specified by:

setBeanFactory in interface BeanFactoryAware

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

registerAllEndpoints

protected void registerAllEndpoints()

registerEndpoint

public void registerEndpoint(PulsarReaderEndpoint endpoint,
 @Nullable ReaderContainerFactory<?,?> factory)