Package org.springframework.pulsar.annotation

Class AbstractPulsarAnnotationsBeanPostProcessor

java.lang.Object

org.springframework.pulsar.annotation.AbstractPulsarAnnotationsBeanPostProcessor

All Implemented Interfaces:

Aware, BeanPostProcessor, InitializingBean, ApplicationContextAware, Ordered

Direct Known Subclasses:

PulsarListenerAnnotationBeanPostProcessor, PulsarReaderAnnotationBeanPostProcessor, ReactivePulsarListenerAnnotationBeanPostProcessor

public class AbstractPulsarAnnotationsBeanPostProcessor
extends Object
implements BeanPostProcessor, ApplicationContextAware, InitializingBean, Ordered

Base class implementation for the various annotation post processors in Spring Pulsar.

Author:

Soby Chacko

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope
protected class	AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter

Field Summary

Fields

Modifier and Type	Field	Description
protected ApplicationContext	applicationContext
protected BeanFactory	beanFactory
protected BeanExpressionContext	expressionContext
protected final AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope	listenerScope
protected final LogAccessor	logger
protected final AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter	messageHandlerMethodFactory
protected BeanExpressionResolver	resolver

Fields inherited from interface org.springframework.core.Ordered

HIGHEST_PRECEDENCE, LOWEST_PRECEDENCE

Constructor Summary

Constructors

Constructor	Description
AbstractPulsarAnnotationsBeanPostProcessor()

Method Summary

Modifier and Type	Method	Description
void	afterPropertiesSet()
protected void	assertBeanFactory()
protected Method	checkProxy(Method methodArg, Object bean)
int	getOrder()
protected void	loadProperty(Properties properties, String property, Object value)
protected String	noBeanFoundMessage(Object target, String listenerBeanName, String requestedBeanName, Class<?> expectedClass)
Object	postProcessBeforeInitialization(Object bean, String beanName)
protected String	resolve(String value)
protected void	resolveAsString(Object resolvedValue, List<String> result)
protected Object	resolveExpression(String value)
protected Boolean	resolveExpressionAsBoolean(String value, String attribute)
protected Integer	resolveExpressionAsInteger(String value, String attribute)
protected String	resolveExpressionAsString(String value, String attribute)
void	setApplicationContext(ApplicationContext applicationContext)
void	setBeanFactory(BeanFactory beanFactory)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.beans.factory.config.BeanPostProcessor

postProcessAfterInitialization

Field Details

logger

protected final LogAccessor logger

beanFactory

protected BeanFactory beanFactory

applicationContext

protected ApplicationContext applicationContext

resolver

protected BeanExpressionResolver resolver

expressionContext

protected BeanExpressionContext expressionContext

listenerScope

protected final AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope listenerScope

messageHandlerMethodFactory

protected final AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter messageHandlerMethodFactory

Constructor Details

AbstractPulsarAnnotationsBeanPostProcessor

public AbstractPulsarAnnotationsBeanPostProcessor()

Method Details

postProcessBeforeInitialization

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

Specified by:

postProcessBeforeInitialization in interface BeanPostProcessor

Throws:

BeansException

assertBeanFactory

protected void assertBeanFactory()

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)

noBeanFoundMessage

protected String noBeanFoundMessage(Object target,
 String listenerBeanName,
 String requestedBeanName,
 Class<?> expectedClass)

resolveExpressionAsBoolean

protected Boolean resolveExpressionAsBoolean(String value,
 String attribute)

resolveExpression

protected Object resolveExpression(String value)

resolve

protected String resolve(String value)

resolveExpressionAsString

protected String resolveExpressionAsString(String value,
 String attribute)

resolveAsString

protected void resolveAsString(Object resolvedValue,
 List<String> result)

checkProxy

protected Method checkProxy(Method methodArg,
 Object bean)

setApplicationContext

public void setApplicationContext(ApplicationContext applicationContext)
                           throws BeansException

Specified by:

setApplicationContext in interface ApplicationContextAware

Throws:

BeansException

afterPropertiesSet

public void afterPropertiesSet()

Specified by:

afterPropertiesSet in interface InitializingBean

getOrder

public int getOrder()

Specified by:

getOrder in interface Ordered

loadProperty

protected void loadProperty(Properties properties,
 String property,
 Object value)

resolveExpressionAsInteger

protected Integer resolveExpressionAsInteger(String value,
 String attribute)