Class PulsarReaderEndpointRegistrar
java.lang.Object
org.springframework.pulsar.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 -
Method Summary
Modifier and TypeMethodDescriptionvoidprotected voidvoidregisterEndpoint(PulsarReaderEndpoint endpoint, ReaderContainerFactory<?, ?> factory) voidsetBeanFactory(BeanFactory beanFactory) voidsetContainerFactory(ReaderContainerFactory<?, ?> containerFactory) voidsetContainerFactoryBeanName(String containerFactoryBeanName) voidsetEndpointRegistry(GenericReaderEndpointRegistry endpointRegistry)
-
Constructor Details
-
PulsarReaderEndpointRegistrar
-
-
Method Details
-
setEndpointRegistry
-
getEndpointRegistry
-
setContainerFactory
-
setContainerFactoryBeanName
-
setBeanFactory
- Specified by:
setBeanFactoryin interfaceBeanFactoryAware
-
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSetin interfaceInitializingBean
-
registerAllEndpoints
protected void registerAllEndpoints() -
registerEndpoint
public void registerEndpoint(PulsarReaderEndpoint endpoint, @Nullable ReaderContainerFactory<?, ?> factory)
-