Package org.springframework.pulsar.config

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

Constructors

Constructor	Description
PulsarListenerEndpointRegistrar(Class<? extends ListenerContainerFactory> type)

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
GenericListenerEndpointRegistry	getEndpointRegistry()
protected void	registerAllEndpoints()
void	registerEndpoint(ListenerEndpoint endpoint, ListenerContainerFactory<?,?> factory)
void	setBeanFactory(BeanFactory beanFactory)
void	setContainerFactory(ListenerContainerFactory<?,?> containerFactory)
void	setContainerFactoryBeanName(String containerFactoryBeanName)
void	setEndpointRegistry(GenericListenerEndpointRegistry endpointRegistry)

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarListenerEndpointRegistrar

public PulsarListenerEndpointRegistrar(Class<? extends ListenerContainerFactory> type)

Method Details

setEndpointRegistry

public void setEndpointRegistry(GenericListenerEndpointRegistry endpointRegistry)

getEndpointRegistry

@Nullable
public GenericListenerEndpointRegistry getEndpointRegistry()

setContainerFactory

public void setContainerFactory(ListenerContainerFactory<?,?> 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(ListenerEndpoint endpoint,
 @Nullable
 ListenerContainerFactory<?,?> factory)