* 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

Author: artembilan

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

@@ -65,18 +65,18 @@ public class MessagePublishingInterceptor implements MethodInterceptor, BeanFact
 
 	private final PublisherMetadataSource metadataSource;
 
-	private final AtomicBoolean templateInitialized = new AtomicBoolean();
-
 	private DestinationResolver<MessageChannel> channelResolver;
 
 	private BeanFactory beanFactory;
 
 	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;
@@ -144,11 +144,12 @@ public final Object invoke(MethodInvocation invocation) throws Throwable {
 	}
 
 	private void initMessagingTemplateIfAny() {
-		if (this.templateInitialized.compareAndSet(false, true)) {
+		if (!this.templateInitialized) {
 			this.messagingTemplate.setBeanFactory(beanFactory);
 			if (this.channelResolver == null) {
 				this.channelResolver = ChannelResolverUtils.getChannelResolver(this.beanFactory);
 			}
+			this.templateInitialized = true;
 		}
 	}
 

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

@@ -572,7 +572,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) {