Package org.springframework.pulsar.annotation

Class PulsarListenerAnnotationBeanPostProcessor<V>

java.lang.Object

org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

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

Type Parameters:

V - the payload type.

All Implemented Interfaces:

Aware, BeanPostProcessor, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Ordered

public class PulsarListenerAnnotationBeanPostProcessor<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 PulsarListenerContainerFactory 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, Chris Bono, Alexander Preuß

See Also:

• PulsarListener
• EnablePulsar
• PulsarListenerConfigurer
• PulsarListenerEndpointRegistrar
• PulsarListenerEndpointRegistry
• PulsarListenerEndpoint
• MethodPulsarListenerEndpoint

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_LISTENER_CONTAINER_FACTORY_BEAN_NAME	The bean name of the default PulsarListenerContainerFactory.

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

applicationContext, beanFactory, expressionContext, logger, messageHandlerMethodFactory, resolver

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
PulsarListenerAnnotationBeanPostProcessor()

Method Summary

Modifier and Type	Method	Description
void	afterSingletonsInstantiated()
Object	postProcessAfterInitialization(Object bean, String beanName)
protected void	postProcessEndpointsBeforeRegistration()
protected void	processListener(MethodPulsarListenerEndpoint<?> endpoint, PulsarListener PulsarListener, Object bean, String beanName, String[] topics, String topicPattern)
protected void	processPulsarListener(PulsarListener pulsarListener, Method method, Object bean, String beanName)

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_LISTENER_CONTAINER_FACTORY_BEAN_NAME

public static final String DEFAULT_PULSAR_LISTENER_CONTAINER_FACTORY_BEAN_NAME

The bean name of the default PulsarListenerContainerFactory.

See Also:

• Constant Field Values

Constructor Details

PulsarListenerAnnotationBeanPostProcessor

public PulsarListenerAnnotationBeanPostProcessor()

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

processPulsarListener

protected void processPulsarListener(PulsarListener pulsarListener,
 Method method,
 Object bean,
 String beanName)

processListener

protected void processListener(MethodPulsarListenerEndpoint<?> endpoint,
 PulsarListener PulsarListener,
 Object bean,
 String beanName,
 String[] topics,
 String topicPattern)

postProcessEndpointsBeforeRegistration

protected void postProcessEndpointsBeforeRegistration()