Package org.springframework.pulsar.reactive.config.annotation

Class ReactivePulsarListenerAnnotationBeanPostProcessor<V>

java.lang.Object

org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerAnnotationBeanPostProcessor<V>

Type Parameters:

V - the payload type.

All Implemented Interfaces:

Aware, BeanPostProcessor, InitializingBean, SmartInitializingSingleton, ApplicationContextAware, Ordered

public class ReactivePulsarListenerAnnotationBeanPostProcessor<V>
extends AbstractPulsarAnnotationsBeanPostProcessor
implements SmartInitializingSingleton

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

Annotated methods can use flexible arguments as defined by ReactivePulsarListener.

This post-processor is automatically registered by the EnableReactivePulsar 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 EnableReactivePulsar Javadoc for complete usage details.

Author:

Christophe Bornet, Soby Chacko

See Also:

• ReactivePulsarListener
• EnableReactivePulsar
• PulsarListenerConfigurer
• PulsarListenerEndpointRegistrar
• ReactivePulsarListenerEndpointRegistry
• ReactivePulsarListenerEndpoint
• MethodReactivePulsarListenerEndpoint

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_REACTIVE_PULSAR_LISTENER_CONTAINER_FACTORY_BEAN_NAME	The bean name of the default ReactivePulsarListenerContainerFactory.

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
ReactivePulsarListenerAnnotationBeanPostProcessor()

Method Summary

Modifier and Type	Method	Description
void	afterSingletonsInstantiated()
Object	postProcessAfterInitialization(Object bean, String beanName)
Object	postProcessBeforeInitialization(Object bean, String beanName)
protected void	postProcessEndpointsBeforeRegistration()
protected void	processListener(MethodReactivePulsarListenerEndpoint<?> endpoint, ReactivePulsarListener ReactivePulsarListener, Object bean, String beanName, String[] topics, String topicPattern)
protected void	processReactivePulsarListener(ReactivePulsarListener reactivePulsarListener, Method method, Object bean, String beanName)
void	setApplicationContext(ApplicationContext applicationContext)

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

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

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_REACTIVE_PULSAR_LISTENER_CONTAINER_FACTORY_BEAN_NAME

public static final String DEFAULT_REACTIVE_PULSAR_LISTENER_CONTAINER_FACTORY_BEAN_NAME

The bean name of the default ReactivePulsarListenerContainerFactory.

See Also:

• Constant Field Values

Constructor Details

ReactivePulsarListenerAnnotationBeanPostProcessor

public ReactivePulsarListenerAnnotationBeanPostProcessor()

Method Details

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface SmartInitializingSingleton

postProcessBeforeInitialization

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

Specified by:

postProcessBeforeInitialization in interface BeanPostProcessor

Overrides:

postProcessBeforeInitialization in class AbstractPulsarAnnotationsBeanPostProcessor

Throws:

BeansException

postProcessAfterInitialization

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

Specified by:

postProcessAfterInitialization in interface BeanPostProcessor

Throws:

BeansException

processReactivePulsarListener

protected void processReactivePulsarListener(ReactivePulsarListener reactivePulsarListener,
 Method method,
 Object bean,
 String beanName)

processListener

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

postProcessEndpointsBeforeRegistration

protected void postProcessEndpointsBeforeRegistration()

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Overrides:

setApplicationContext in class AbstractPulsarAnnotationsBeanPostProcessor

Throws:

BeansException