Package org.springframework.pulsar.annotation

Class PulsarReaderAnnotationBeanPostProcessor<V>

java.lang.Object

org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

org.springframework.pulsar.annotation.PulsarReaderAnnotationBeanPostProcessor<V>

Type Parameters:

V - the payload type.

All Implemented Interfaces:

Aware, BeanPostProcessor, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Ordered

public class PulsarReaderAnnotationBeanPostProcessor<V>
extends AbstractPulsarAnnotationsBeanPostProcessor
implements SmartInitializingSingleton

Bean post-processor that registers methods annotated with PulsarListener to be invoked by a Pulsar message listener container created under the covers by a PulsarReaderContainerFactory according to the parameters of the annotation.

Annotated methods can use flexible arguments as defined by PulsarListener.

This post-processor is automatically registered by the EnablePulsar annotation.

Auto-detect any PulsarListenerConfigurer instances in the container, allowing for customization of the registry to be used, the default container factory or for fine-grained control over endpoints registration. See EnablePulsar Javadoc for complete usage details.

Author:

Soby Chacko

See Also:

• PulsarReader
• EnablePulsar
• PulsarReaderConfigurer
• PulsarReaderEndpointRegistrar
• PulsarReaderEndpointRegistry
• PulsarReaderEndpoint
• MethodPulsarReaderEndpoint

Nested Class Summary

Nested classes/interfaces inherited from class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope, AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter

Field Summary

Fields

Modifier and Type	Field	Description
static final String	DEFAULT_PULSAR_READER_CONTAINER_FACTORY_BEAN_NAME	The bean name of the default PulsarReaderContainerFactory.

Fields inherited from class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

beanFactory, expressionContext, listenerScope, messageHandlerMethodFactory, resolver

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
PulsarReaderAnnotationBeanPostProcessor()

Method Summary

Modifier and Type	Method	Description
void	afterSingletonsInstantiated()
Object	postProcessAfterInitialization(Object bean, String beanName)
protected void	postProcessEndpointsBeforeRegistration()
protected void	processPulsarReader(PulsarReader pulsarReader, Method method, Object bean, String beanName)
protected void	processReader(MethodPulsarReaderEndpoint<?> endpoint, PulsarReader pulsarReader, Object bean, String beanName, String[] topics)

Methods inherited from class org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

afterPropertiesSet, assertBeanFactory, checkProxy, getOrder, loadProperty, noBeanFoundMessage, postProcessBeforeInitialization, resolve, resolveAsString, resolveExpression, resolveExpressionAsBoolean, resolveExpressionAsInteger, resolveExpressionAsString, setApplicationContext, setBeanFactory

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_PULSAR_READER_CONTAINER_FACTORY_BEAN_NAME

public static final String DEFAULT_PULSAR_READER_CONTAINER_FACTORY_BEAN_NAME

The bean name of the default PulsarReaderContainerFactory.

See Also:

• Constant Field Values

Constructor Details

PulsarReaderAnnotationBeanPostProcessor

public PulsarReaderAnnotationBeanPostProcessor()

Method Details

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface SmartInitializingSingleton

postProcessAfterInitialization

public Object postProcessAfterInitialization(Object bean,
 String beanName)
                                      throws BeansException

Specified by:

postProcessAfterInitialization in interface BeanPostProcessor

Throws:

BeansException

processPulsarReader

protected void processPulsarReader(PulsarReader pulsarReader,
 Method method,
 Object bean,
 String beanName)

processReader

protected void processReader(MethodPulsarReaderEndpoint<?> endpoint,
 PulsarReader pulsarReader,
 Object bean,
 String beanName,
 String[] topics)

postProcessEndpointsBeforeRegistration

protected void postProcessEndpointsBeforeRegistration()