Package org.springframework.integration.config

Class AbstractMethodAnnotationPostProcessor<T extends Annotation>

java.lang.Object

org.springframework.integration.config.AbstractMethodAnnotationPostProcessor<T>

Type Parameters:

T - the target annotation type.

All Implemented Interfaces:

Aware, BeanFactoryAware, MethodAnnotationPostProcessor<T>

Direct Known Subclasses:

AggregatorAnnotationPostProcessor, BridgeFromAnnotationPostProcessor, BridgeToAnnotationPostProcessor, FilterAnnotationPostProcessor, InboundChannelAdapterAnnotationPostProcessor, RouterAnnotationPostProcessor, ServiceActivatorAnnotationPostProcessor, SplitterAnnotationPostProcessor, TransformerAnnotationPostProcessor

public abstract class AbstractMethodAnnotationPostProcessor<T extends Annotation>
extends Object
implements MethodAnnotationPostProcessor<T>, BeanFactoryAware

Base class for Method-level annotation post-processors.

Author:

Mark Fisher, Artem Bilan, Gary Russell, Chris Bono

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final record	AbstractMethodAnnotationPostProcessor.BeanDefinitionPropertiesMapper

Field Summary

Fields

Modifier and Type	Field	Description
protected static final String	ADVICE_CHAIN_ATTRIBUTE
protected final Class<T>	annotationType
protected final Log	logger
protected final List<String>	messageHandlerAttributes
protected static final String	SEND_TIMEOUT_ATTRIBUTE

Fields inherited from interface org.springframework.integration.config.annotation.MethodAnnotationPostProcessor

INPUT_CHANNEL_ATTRIBUTE

Constructor Summary

Constructors

Constructor	Description
AbstractMethodAnnotationPostProcessor()

Method Summary

Modifier and Type	Method	Description
protected static BeanDefinition	buildLambdaMessageProcessor(ResolvableType beanType, AnnotatedBeanDefinition beanDefinition)
protected void	checkMessageHandlerAttributes(String handlerBeanName, List<Annotation> annotations)
protected void	configurePollingEndpoint(AbstractPollingEndpoint pollingEndpoint, Poller poller)
protected AbstractEndpoint	createEndpoint(MessageHandler handler, Method method, List<Annotation> annotations)
protected BeanDefinition	createEndpointBeanDefinition(ComponentDefinition handlerBeanDefinition, ComponentDefinition beanDefinition, List<Annotation> annotations)
protected abstract MessageHandler	createHandler(Object bean, Method method, List<Annotation> annotations)	Subclasses must implement this method to create the MessageHandler.
protected AbstractEndpoint	doCreateEndpoint(MessageHandler handler, MessageChannel inputChannel, List<Annotation> annotations)
protected List<Advice>	extractAdviceChain(String beanName, List<Annotation> annotations)
protected String	generateHandlerBeanName(String originalBeanName, Method method)
protected String	generateHandlerBeanName(String originalBeanName, MergedAnnotations mergedAnnotations)
protected String	generateHandlerBeanName(String originalBeanName, MergedAnnotations mergedAnnotations, String methodName)
protected ConfigurableListableBeanFactory	getBeanFactory()
protected DestinationResolver<MessageChannel>	getChannelResolver()
protected ConversionService	getConversionService()
protected BeanDefinitionRegistry	getDefinitionRegistry()
Object	postProcess(Object bean, String beanName, Method method, List<Annotation> annotations)
void	processBeanDefinition(String beanName, AnnotatedBeanDefinition beanDefinition, List<Annotation> annotations)
protected boolean	resolveAttributeToBoolean(String attribute)
protected BeanDefinition	resolveHandlerBeanDefinition(String beanName, AnnotatedBeanDefinition beanDefinition, ResolvableType handlerBeanType, List<Annotation> annotations)
void	setBeanFactory(BeanFactory beanFactory)
protected static void	setOutputChannelIfPresent(List<Annotation> annotations, AbstractMessageProducingHandler handler)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.springframework.integration.config.annotation.MethodAnnotationPostProcessor

beanAnnotationAware, getInputChannelAttribute, shouldCreateEndpoint, shouldCreateEndpoint, supportsPojoMethod

Field Details

logger

protected final Log logger

ADVICE_CHAIN_ATTRIBUTE

protected static final String ADVICE_CHAIN_ATTRIBUTE

See Also:

• Constant Field Values

SEND_TIMEOUT_ATTRIBUTE

protected static final String SEND_TIMEOUT_ATTRIBUTE

See Also:

• Constant Field Values

messageHandlerAttributes

protected final List<String> messageHandlerAttributes

annotationType

protected final Class<T extends Annotation> annotationType

Constructor Details

AbstractMethodAnnotationPostProcessor

public AbstractMethodAnnotationPostProcessor()

Method Details

setBeanFactory

public void setBeanFactory(BeanFactory beanFactory)
                    throws BeansException

Specified by:

setBeanFactory in interface BeanFactoryAware

Throws:

BeansException

getBeanFactory

protected ConfigurableListableBeanFactory getBeanFactory()

getDefinitionRegistry

protected BeanDefinitionRegistry getDefinitionRegistry()

getConversionService

protected ConversionService getConversionService()

getChannelResolver

protected DestinationResolver<MessageChannel> getChannelResolver()

processBeanDefinition

public void processBeanDefinition(String beanName,
 AnnotatedBeanDefinition beanDefinition,
 List<Annotation> annotations)

Specified by:

processBeanDefinition in interface MethodAnnotationPostProcessor<T extends Annotation>

createEndpointBeanDefinition

protected BeanDefinition createEndpointBeanDefinition(ComponentDefinition handlerBeanDefinition,
 ComponentDefinition beanDefinition,
 List<Annotation> annotations)

resolveHandlerBeanDefinition

@Nullable
protected BeanDefinition resolveHandlerBeanDefinition(String beanName,
 AnnotatedBeanDefinition beanDefinition,
 ResolvableType handlerBeanType,
 List<Annotation> annotations)

postProcess

public Object postProcess(Object bean,
 String beanName,
 Method method,
 List<Annotation> annotations)

Specified by:

postProcess in interface MethodAnnotationPostProcessor<T extends Annotation>

extractAdviceChain

protected List<Advice> extractAdviceChain(String beanName,
 List<Annotation> annotations)

createEndpoint

protected AbstractEndpoint createEndpoint(MessageHandler handler,
 Method method,
 List<Annotation> annotations)

doCreateEndpoint

protected AbstractEndpoint doCreateEndpoint(MessageHandler handler,
 MessageChannel inputChannel,
 List<Annotation> annotations)

configurePollingEndpoint

protected void configurePollingEndpoint(AbstractPollingEndpoint pollingEndpoint,
 Poller poller)

generateHandlerBeanName

protected String generateHandlerBeanName(String originalBeanName,
 Method method)

generateHandlerBeanName

protected String generateHandlerBeanName(String originalBeanName,
 MergedAnnotations mergedAnnotations)

generateHandlerBeanName

protected String generateHandlerBeanName(String originalBeanName,
 MergedAnnotations mergedAnnotations,
 @Nullable
 String methodName)

setOutputChannelIfPresent

protected static void setOutputChannelIfPresent(List<Annotation> annotations,
 AbstractMessageProducingHandler handler)

checkMessageHandlerAttributes

protected void checkMessageHandlerAttributes(String handlerBeanName,
 List<Annotation> annotations)

resolveAttributeToBoolean

protected boolean resolveAttributeToBoolean(String attribute)

buildLambdaMessageProcessor

protected static BeanDefinition buildLambdaMessageProcessor(ResolvableType beanType,
 AnnotatedBeanDefinition beanDefinition)

createHandler

protected abstract MessageHandler createHandler(Object bean,
 Method method,
 List<Annotation> annotations)

Subclasses must implement this method to create the MessageHandler.

Parameters:

bean - The bean.

method - The method.

annotations - The messaging annotation (or meta-annotation hierarchy) on the method.

Returns:

The MessageHandler.