Add nullability to org.springframework.messaging.core package

Author: cppwfs

spring-integration-core/src/main/java/org/springframework/integration/core/ErrorMessagePublisher.java

@@ -54,10 +54,13 @@ public class ErrorMessagePublisher implements BeanFactoryAware {
 
 	protected final MessagingTemplate messagingTemplate = new MessagingTemplate(); // NOSONAR final
 
+	@SuppressWarnings("NullAway.Init")
 	private DestinationResolver<MessageChannel> channelResolver;
 
+	@Nullable
 	private MessageChannel channel;
 
+	@Nullable
 	private String channelName;
 
 	private ErrorMessageStrategy errorMessageStrategy = new DefaultErrorMessageStrategy();
@@ -79,6 +82,7 @@ public ErrorMessageStrategy getErrorMessageStrategy() {
 		return this.errorMessageStrategy;
 	}
 
+	@Nullable
 	public MessageChannel getChannel() {
 		populateChannel();
 		return this.channel;
@@ -146,7 +150,7 @@ public void publish(Message<?> inputMessage, MessagingException exception) {
 	 * @param failedMessage the message.
 	 * @param throwable the throwable.
 	 */
-	public void publish(@Nullable Message<?> inputMessage, Message<?> failedMessage, Throwable throwable) {
+	public void publish(@Nullable Message<?> inputMessage, @Nullable Message<?> failedMessage, Throwable throwable) {
 		publish(throwable, ErrorMessageUtils.getAttributeAccessor(inputMessage, failedMessage));
 	}
 

spring-integration-core/src/main/java/org/springframework/integration/core/MessagingTemplate.java

@@ -44,6 +44,7 @@ public class MessagingTemplate extends GenericMessagingTemplate {
 
 	private final Lock lock = new ReentrantLock();
 
+	@SuppressWarnings("NullAway.Init")
 	private BeanFactory beanFactory;
 
 	private volatile boolean throwExceptionOnLateReplySet;
@@ -84,7 +85,7 @@ public void setThrowExceptionOnLateReply(boolean throwExceptionOnLateReply) {
 	 * backward compatibility.
 	 * @param channel the channel to set.
 	 */
-	public void setDefaultChannel(MessageChannel channel) {
+	public void setDefaultChannel(@Nullable MessageChannel channel) {
 		super.setDefaultDestination(channel);
 	}
 
@@ -109,6 +110,7 @@ public Message<?> sendAndReceive(MessageChannel destination, Message<?> requestM
 		return super.sendAndReceive(destination, requestMessage);
 	}
 
+	@Nullable
 	public Object receiveAndConvert(MessageChannel destination, long timeout) {
 		Message<?> message = doReceive(destination, timeout);
 		if (message != null) {
@@ -118,7 +120,7 @@ public Object receiveAndConvert(MessageChannel destination, long timeout) {
 			return null;
 		}
 	}
-
+	@Nullable
 	public Message<?> receive(MessageChannel destination, long timeout) {
 		return doReceive(destination, timeout);
 	}

spring-integration-core/src/main/java/org/springframework/integration/core/package-info.java

@@ -1,4 +1,5 @@
 /**
  * Provides core classes.
  */
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.core;