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
ConstructorDescriptionPulsarListenerEndpointRegistrar
(Class<? extends ListenerContainerFactory> type) -
Method Summary
Modifier and TypeMethodDescriptionvoid
protected void
void
registerEndpoint
(ListenerEndpoint endpoint, ListenerContainerFactory<?, ?> factory) void
setBeanFactory
(BeanFactory beanFactory) void
setContainerFactory
(ListenerContainerFactory<?, ?> containerFactory) void
setContainerFactoryBeanName
(String containerFactoryBeanName) void
setEndpointRegistry
(GenericListenerEndpointRegistry endpointRegistry)
-
Constructor Details
-
PulsarListenerEndpointRegistrar
-
-
Method Details
-
setEndpointRegistry
-
getEndpointRegistry
-
setContainerFactory
-
setContainerFactoryBeanName
-
setBeanFactory
- Specified by:
setBeanFactory
in interfaceBeanFactoryAware
-
afterPropertiesSet
public void afterPropertiesSet()- Specified by:
afterPropertiesSet
in interfaceInitializingBean
-
registerAllEndpoints
protected void registerAllEndpoints() -
registerEndpoint
public void registerEndpoint(ListenerEndpoint endpoint, @Nullable ListenerContainerFactory<?, ?> factory)
-