GH-3945: Fix not eligible for getting processed (#3947)

* GH-3945: Fix `not eligible for getting processed`

Fixes #3945

The `IntegrationManagementConfiguration` produces an `IntegrationManagementConfigurer` which is a `BeanPostProcessor`.
According to Spring recommendation this kind of infrastructure beans must be declared as `static`.
Due to an `implements ImportAware, EnvironmentAware` nature of the `IntegrationManagementConfiguration`,
we cannot use `static @Bean` method.
But since the `IntegrationManagementConfiguration` is not involved in any bean post-processing,
it is safe to follow recommendation and mark it as a `@Role(BeanDefinition.ROLE_INFRASTRUCTURE)`.

* Fix `MessagePublishingInterceptor` to initialize `MessagingTemplate` and `DestinationResolver` lazily
* Fix `AbstractMethodAnnotationPostProcessor` to initialize `DestinationResolver` lazily

**Cherry-pick to `5.5.x`**

* Use `getChannelResolver()` internally in the `AbstractMethodAnnotationPostProcessor`
instead of direct property access which might not be initialized yet
* Use a plain `boolean` for `templateInitialized` in the `MessagePublishingInterceptor`
to avoid skips in other thread where and move on with still not initialized properties

* Remove unused import

* Fix `this.` prefix for `beanFactory` property reference

# Conflicts:
#	spring-integration-core/src/main/java/org/springframework/integration/config/annotation/AbstractMethodAnnotationPostProcessor.java

Author: artembilan

spring-integration-core/src/main/java/org/springframework/integration/aop/MessagePublishingInterceptor.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2020 the original author or authors.
+ * Copyright 2002-2022 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -70,10 +70,12 @@ public class MessagePublishingInterceptor implements MethodInterceptor, BeanFact
 
 	private MessageBuilderFactory messageBuilderFactory = new DefaultMessageBuilderFactory();
 
-	private boolean messageBuilderFactorySet;
-
 	private String defaultChannelName;
 
+	private volatile boolean messageBuilderFactorySet;
+
+	private volatile boolean templateInitialized;
+
 	public MessagePublishingInterceptor(PublisherMetadataSource metadataSource) {
 		Assert.notNull(metadataSource, "metadataSource must not be null");
 		this.metadataSource = metadataSource;
@@ -94,10 +96,6 @@ public void setChannelResolver(DestinationResolver<MessageChannel> channelResolv
 	@Override
 	public void setBeanFactory(BeanFactory beanFactory) throws BeansException {
 		this.beanFactory = beanFactory;
-		this.messagingTemplate.setBeanFactory(beanFactory);
-		if (this.channelResolver == null) {
-			this.channelResolver = ChannelResolverUtils.getChannelResolver(this.beanFactory);
-		}
 	}
 
 	protected MessageBuilderFactory getMessageBuilderFactory() {
@@ -111,8 +109,9 @@ protected MessageBuilderFactory getMessageBuilderFactory() {
 	}
 
 	@Override
-	public final Object invoke(final MethodInvocation invocation) throws Throwable {
-		final StandardEvaluationContext context = ExpressionUtils.createStandardEvaluationContext(this.beanFactory);
+	public final Object invoke(MethodInvocation invocation) throws Throwable {
+		initMessagingTemplateIfAny();
+		StandardEvaluationContext context = ExpressionUtils.createStandardEvaluationContext(this.beanFactory);
 		Class<?> targetClass = AopUtils.getTargetClass(invocation.getThis());
 		final Method method = AopUtils.getMostSpecificMethod(invocation.getMethod(), targetClass);
 		String[] argumentNames = resolveArgumentNames(method);
@@ -143,6 +142,16 @@ public final Object invoke(final MethodInvocation invocation) throws Throwable {
 		}
 	}
 
+	private void initMessagingTemplateIfAny() {
+		if (!this.templateInitialized) {
+			this.messagingTemplate.setBeanFactory(this.beanFactory);
+			if (this.channelResolver == null) {
+				this.channelResolver = ChannelResolverUtils.getChannelResolver(this.beanFactory);
+			}
+			this.templateInitialized = true;
+		}
+	}
+
 	private String[] resolveArgumentNames(Method method) {
 		return this.parameterNameDiscoverer.getParameterNames(method);
 	}
@@ -163,20 +172,14 @@ private void publishMessage(Method method, StandardEvaluationContext context) {
 			}
 			Message<?> message = builder.build();
 			String channelName = this.metadataSource.getChannelName(method);
-			MessageChannel channel = null;
 			if (channelName != null) {
-				Assert.state(this.channelResolver != null, "ChannelResolver is required to resolve channel names.");
-				channel = this.channelResolver.resolveDestination(channelName);
-			}
-			if (channel != null) {
-				this.messagingTemplate.send(channel, message);
+				this.messagingTemplate.send(channelName, message);
 			}
 			else {
 				String channelNameToUse = this.defaultChannelName;
 				if (channelNameToUse != null && this.messagingTemplate.getDefaultDestination() == null) {
 					Assert.state(this.channelResolver != null, "ChannelResolver is required to resolve channel names.");
-					this.messagingTemplate.setDefaultChannel(
-							this.channelResolver.resolveDestination(channelNameToUse));
+					this.messagingTemplate.setDefaultChannel(this.channelResolver.resolveDestination(channelNameToUse));
 					this.defaultChannelName = null;
 				}
 				this.messagingTemplate.send(message);

spring-integration-core/src/main/java/org/springframework/integration/config/IntegrationManagementConfiguration.java

@@ -43,6 +43,7 @@
  * @since 4.2
  */
 @Configuration(proxyBeanMethods = false)
+@Role(BeanDefinition.ROLE_INFRASTRUCTURE)
 public class IntegrationManagementConfiguration implements ImportAware, EnvironmentAware {
 
 	private AnnotationAttributes attributes;

spring-integration-core/src/main/java/org/springframework/integration/config/annotation/AbstractMethodAnnotationPostProcessor.java

@@ -125,25 +125,33 @@ public abstract class AbstractMethodAnnotationPostProcessor<T extends Annotation
 
 	protected final ConversionService conversionService; // NOSONAR
 
-	protected final DestinationResolver<MessageChannel> channelResolver; // NOSONAR
-
 	protected final Class<T> annotationType; // NOSONAR
 
+	private volatile DestinationResolver<MessageChannel> channelResolver;
+
 	@SuppressWarnings(UNCHECKED)
 	public AbstractMethodAnnotationPostProcessor(ConfigurableListableBeanFactory beanFactory) {
 		Assert.notNull(beanFactory, "'beanFactory' must not be null");
 		this.messageHandlerAttributes.add(SEND_TIMEOUT_ATTRIBUTE);
 		this.beanFactory = beanFactory;
 		this.definitionRegistry = (BeanDefinitionRegistry) beanFactory;
-		this.conversionService = this.beanFactory.getConversionService() != null
-				? this.beanFactory.getConversionService()
-				: DefaultConversionService.getSharedInstance();
-		this.channelResolver = ChannelResolverUtils.getChannelResolver(beanFactory);
+		this.conversionService =
+				this.beanFactory.getConversionService() != null
+						? this.beanFactory.getConversionService()
+						: DefaultConversionService.getSharedInstance();
 		this.annotationType =
 				(Class<T>) GenericTypeResolver.resolveTypeArgument(this.getClass(),
 						MethodAnnotationPostProcessor.class);
 	}
 
+
+	protected DestinationResolver<MessageChannel> getChannelResolver() {
+		if (this.channelResolver == null) {
+			this.channelResolver = ChannelResolverUtils.getChannelResolver(this.beanFactory);
+		}
+		return this.channelResolver;
+	}
+
 	@Override
 	public Object postProcess(Object bean, String beanName, Method method, List<Annotation> annotations) {
 		Object sourceHandler = null;
@@ -332,7 +340,7 @@ protected AbstractEndpoint createEndpoint(MessageHandler handler, @SuppressWarni
 		if (StringUtils.hasText(inputChannelName)) {
 			MessageChannel inputChannel;
 			try {
-				inputChannel = this.channelResolver.resolveDestination(inputChannelName);
+				inputChannel = getChannelResolver().resolveDestination(inputChannelName);
 			}
 			catch (DestinationResolutionException e) {
 				if (e.getCause() instanceof NoSuchBeanDefinitionException) {