Class PulsarListenerEndpointRegistrar
java.lang.Object
org.springframework.pulsar.config.PulsarListenerEndpointRegistrar
- All Implemented Interfaces:
Aware,BeanFactoryAware,InitializingBean
public class PulsarListenerEndpointRegistrar
extends Object
implements BeanFactoryAware, InitializingBean
Helper bean for registering
ListenerEndpoint with a
GenericListenerEndpointRegistry.- Author:
- Soby Chacko, Christophe Bornet
-
Constructor Summary
ConstructorsConstructorDescriptionPulsarListenerEndpointRegistrar(Class<? extends ListenerContainerFactory> type) -
Method Summary
Modifier and TypeMethodDescriptionvoidprotected voidvoidregisterEndpoint(ListenerEndpoint endpoint, ListenerContainerFactory<?, ?> factory) voidsetBeanFactory(BeanFactory beanFactory) voidsetContainerFactory(ListenerContainerFactory<?, ?> containerFactory) voidsetContainerFactoryBeanName(String containerFactoryBeanName) voidsetEndpointRegistry(GenericListenerEndpointRegistry endpointRegistry)
-
Constructor Details
-
PulsarListenerEndpointRegistrar
-
-
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(ListenerEndpoint endpoint, @Nullable ListenerContainerFactory<?, ?> factory)
-