Package io.awspring.cloud.sqs.annotation

Class AbstractListenerAnnotationBeanPostProcessor<A extends Annotation>

java.lang.Object

io.awspring.cloud.sqs.annotation.AbstractListenerAnnotationBeanPostProcessor<A>

All Implemented Interfaces:

Aware, BeanFactoryAware, BeanPostProcessor, SmartInitializingSingleton

Direct Known Subclasses:

SqsListenerAnnotationBeanPostProcessor

public abstract class AbstractListenerAnnotationBeanPostProcessor<A extends Annotation>
extends Object
implements BeanPostProcessor, BeanFactoryAware, SmartInitializingSingleton

BeanPostProcessor implementation that scans beans for a @SqsListener annotation, extracts information to a SqsEndpoint, and registers it in the EndpointRegistrar.

Since:

3.0

Author:

Tomaz Fernandes, Joao Calassio, José Iêdo, Matej Nedic

Constructor Summary

Constructors

Constructor	Description
AbstractListenerAnnotationBeanPostProcessor()

Method Summary

Modifier and Type	Method	Description
void	afterSingletonsInstantiated()
protected void	configureDefaultHandlerMethodFactory(DefaultMessageHandlerMethodFactory handlerMethodFactory)
protected Collection<HandlerMethodArgumentResolver>	createAdditionalArgumentResolvers()
protected Collection<HandlerMethodArgumentResolver>	createAdditionalArgumentResolvers(MessageConverter messageConverter, @Nullable JacksonMessageConverterMigration wrapper)
protected List<HandlerMethodArgumentResolver>	createArgumentResolvers(MessageConverter messageConverter)
protected CompositeMessageConverter	createCompositeMessageConverter()
protected abstract Endpoint	createEndpoint(A sqsListenerAnnotation)
protected EndpointRegistrar	createEndpointRegistrar()
protected abstract Endpoint	createMultiMethodEndpoint(A sqsListenerAnnotation, List<Method> methods, @Nullable Method defaultMethod, Object bean)
protected void	detectAnnotationsAndRegisterEndpoints(Object bean, Class<?> targetClass)
protected abstract Class<A>	getAnnotationClass()
protected BeanFactory	getBeanFactory()
protected @Nullable ConfigurableBeanFactory	getConfigurableBeanFactory()
protected abstract Method	getDefaultHandlerMethod(Class<?> targetClass, List<Method> handlerMethods)
protected String	getEndpointId(String id)
protected @Nullable BeanExpressionResolver	getExpressionResolver()
protected abstract String	getGeneratedIdPrefix()
protected abstract Set<Method>	getHandlerMethods(Class<?> targetClass)
protected abstract String	getMessageListenerContainerRegistryBeanName()
protected void	initializeHandlerMethodFactory()
Object	postProcessAfterInitialization(Object bean, String beanName)
protected @Nullable AcknowledgementMode	resolveAcknowledgement(String value)
protected @Nullable Integer	resolveAsInteger(String value, String propertyName)
protected String	resolveAsString(String value, String propertyName)
protected Collection<String>	resolveEndpointNames(String[] endpointNames)
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

postProcessBeforeInitialization

Constructor Details

AbstractListenerAnnotationBeanPostProcessor

public AbstractListenerAnnotationBeanPostProcessor()

Method Details

postProcessAfterInitialization

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

Specified by:

postProcessAfterInitialization in interface BeanPostProcessor

Throws:

BeansException

createEndpointRegistrar

protected EndpointRegistrar createEndpointRegistrar()

getConfigurableBeanFactory

protected @Nullable ConfigurableBeanFactory getConfigurableBeanFactory()

getBeanFactory

protected BeanFactory getBeanFactory()

detectAnnotationsAndRegisterEndpoints

protected void detectAnnotationsAndRegisterEndpoints(Object bean,
 Class<?> targetClass)

getAnnotationClass

protected abstract Class<A> getAnnotationClass()

getHandlerMethods

protected abstract Set<Method> getHandlerMethods(Class<?> targetClass)

getDefaultHandlerMethod

protected abstract Method getDefaultHandlerMethod(Class<?> targetClass,
 List<Method> handlerMethods)

createEndpoint

protected abstract Endpoint createEndpoint(A sqsListenerAnnotation)

createMultiMethodEndpoint

protected abstract Endpoint createMultiMethodEndpoint(A sqsListenerAnnotation,
 List<Method> methods,
 @Nullable Method defaultMethod,
 Object bean)

resolveEndpointNames

protected Collection<String> resolveEndpointNames(String[] endpointNames)

getExpressionResolver

protected @Nullable BeanExpressionResolver getExpressionResolver()

resolveAsString

protected String resolveAsString(String value,
 String propertyName)

resolveAsInteger

protected @Nullable Integer resolveAsInteger(String value,
 String propertyName)

resolveAcknowledgement

protected @Nullable AcknowledgementMode resolveAcknowledgement(String value)

getEndpointId

protected String getEndpointId(String id)

getGeneratedIdPrefix

protected abstract String getGeneratedIdPrefix()

afterSingletonsInstantiated

public void afterSingletonsInstantiated()

Specified by:

afterSingletonsInstantiated in interface SmartInitializingSingleton

getMessageListenerContainerRegistryBeanName

protected abstract String getMessageListenerContainerRegistryBeanName()

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

initializeHandlerMethodFactory

protected void initializeHandlerMethodFactory()

configureDefaultHandlerMethodFactory

protected void configureDefaultHandlerMethodFactory(DefaultMessageHandlerMethodFactory handlerMethodFactory)

createAdditionalArgumentResolvers

protected Collection<HandlerMethodArgumentResolver> createAdditionalArgumentResolvers(MessageConverter messageConverter,
 @Nullable JacksonMessageConverterMigration wrapper)

createAdditionalArgumentResolvers

protected Collection<HandlerMethodArgumentResolver> createAdditionalArgumentResolvers()

createCompositeMessageConverter

protected CompositeMessageConverter createCompositeMessageConverter()

createArgumentResolvers

protected List<HandlerMethodArgumentResolver> createArgumentResolvers(MessageConverter messageConverter)