Class AbstractPulsarAnnotationsBeanPostProcessor

java.lang.Object

org.apache.pulsar.spring.annotation.AbstractPulsarAnnotationsBeanPostProcessor

All Implemented Interfaces:

Aware, BeanPostProcessor, InitializingBean, ApplicationContextAware, Ordered

Direct Known Subclasses:

PulsarListenerAnnotationBeanPostProcessor, PulsarReaderAnnotationBeanPostProcessor

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

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

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 @Nullable ApplicationContext	applicationContext
protected @Nullable BeanFactory	beanFactory
protected @Nullable BeanExpressionContext	expressionContext
protected final AbstractPulsarAnnotationsBeanPostProcessor.ListenerScope	listenerScope
protected final LogAccessor	logger
protected final AbstractPulsarAnnotationsBeanPostProcessor.PulsarHandlerMethodFactoryAdapter	messageHandlerMethodFactory
protected @Nullable BeanExpressionResolver	resolver

Fields inherited from interface 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(@Nullable Object target, String listenerBeanName, String requestedBeanName, Class<?> expectedClass)
Object	postProcessBeforeInitialization(Object bean, String beanName)
protected BeanFactory	requireNonNullBeanFactory()
protected @Nullable String	resolve(String value)
protected void	resolveAsString(Object resolvedValue, List<String> result)
protected @Nullable Object	resolveExpression(String value)
protected @Nullable Boolean	resolveExpressionAsBoolean(String value, String attribute)
protected Integer	resolveExpressionAsInteger(String value, String attribute)
protected @Nullable String	resolveExpressionAsString(String value, String attribute)
void	setApplicationContext(ApplicationContext applicationContext)
void	setBeanFactory(BeanFactory beanFactory)

Methods inherited from class Object

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

Methods inherited from interface BeanPostProcessor

postProcessAfterInitialization

Field Details

logger

protected final LogAccessor logger

beanFactory

protected @Nullable BeanFactory beanFactory

applicationContext

protected @Nullable ApplicationContext applicationContext

resolver

protected @Nullable BeanExpressionResolver resolver

expressionContext

protected @Nullable 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()

requireNonNullBeanFactory

protected BeanFactory requireNonNullBeanFactory()

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)

noBeanFoundMessage

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

resolveExpressionAsBoolean

protected @Nullable Boolean resolveExpressionAsBoolean(String value,
 String attribute)

resolveExpression

protected @Nullable Object resolveExpression(String value)

resolve

protected @Nullable String resolve(String value)

resolveExpressionAsString

protected @Nullable 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)