GH-10083: Apply Nullability into webflux module

Related to: #10083

Signed-off-by: Jooyoung Pyoung <pyoungjy@gmail.com>

Author: anthologia

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

@@ -1,4 +1,5 @@
 /**
  * Provides classes for configuration - parsers, namespace handlers.
  */
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.webflux.config;

spring-integration-webflux/src/main/java/org/springframework/integration/webflux/dsl/WebFlux.java

@@ -19,10 +19,11 @@
 import java.net.URI;
 import java.util.function.Function;
 
+import org.jspecify.annotations.Nullable;
+
 import org.springframework.expression.Expression;
 import org.springframework.integration.expression.FunctionExpression;
 import org.springframework.integration.webflux.inbound.WebFluxInboundEndpoint;
-import org.springframework.lang.Nullable;
 import org.springframework.messaging.Message;
 import org.springframework.web.reactive.function.client.WebClient;
 

spring-integration-webflux/src/main/java/org/springframework/integration/webflux/dsl/WebFluxMessageHandlerSpec.java

@@ -19,6 +19,8 @@
 import java.net.URI;
 import java.util.function.Function;
 
+import org.jspecify.annotations.Nullable;
+
 import org.springframework.core.ParameterizedTypeReference;
 import org.springframework.expression.Expression;
 import org.springframework.expression.common.LiteralExpression;
@@ -27,7 +29,6 @@
 import org.springframework.integration.expression.ValueExpression;
 import org.springframework.integration.http.dsl.BaseHttpMessageHandlerSpec;
 import org.springframework.integration.webflux.outbound.WebFluxRequestExecutingMessageHandler;
-import org.springframework.lang.Nullable;
 import org.springframework.messaging.Message;
 import org.springframework.web.reactive.function.BodyExtractor;
 import org.springframework.web.reactive.function.client.WebClient;
@@ -47,8 +48,7 @@
 public class WebFluxMessageHandlerSpec
 		extends BaseHttpMessageHandlerSpec<WebFluxMessageHandlerSpec, WebFluxRequestExecutingMessageHandler> {
 
-	@Nullable
-	protected final WebClient webClient; // NOSONAR - final
+	protected final @Nullable WebClient webClient;
 
 	protected WebFluxMessageHandlerSpec(URI uri, @Nullable WebClient webClient) {
 		this(new ValueExpression<>(uri), webClient);

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

@@ -1,6 +1,5 @@
 /**
  * Provides WebFlux Components support for Spring Integration Java DSL.
  */
-@org.springframework.lang.NonNullApi
-@org.springframework.lang.NonNullFields
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.webflux.dsl;

spring-integration-webflux/src/main/java/org/springframework/integration/webflux/inbound/WebFluxInboundEndpoint.java

@@ -27,6 +27,7 @@
 import java.util.function.Supplier;
 import java.util.stream.Collectors;
 
+import org.jspecify.annotations.Nullable;
 import org.reactivestreams.Publisher;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -458,7 +459,7 @@ private List<MediaType> getProducibleMediaTypes(ResolvableType elementType) {
 				.collect(Collectors.toList());
 	}
 
-	private MediaType selectMediaType(ServerWebExchange exchange, Supplier<List<MediaType>> producibleTypesSupplier) {
+	private @Nullable MediaType selectMediaType(ServerWebExchange exchange, Supplier<List<MediaType>> producibleTypesSupplier) {
 		List<MediaType> acceptableTypes = getAcceptableTypes(exchange);
 		List<MediaType> producibleTypes = getProducibleTypes(exchange, producibleTypesSupplier);
 

spring-integration-webflux/src/main/java/org/springframework/integration/webflux/inbound/WebFluxIntegrationRequestMappingHandlerMapping.java

@@ -21,6 +21,8 @@
 import java.util.List;
 import java.util.concurrent.atomic.AtomicBoolean;
 
+import org.jspecify.annotations.Nullable;
+
 import org.springframework.beans.BeansException;
 import org.springframework.beans.factory.config.DestructionAwareBeanPostProcessor;
 import org.springframework.context.ApplicationListener;
@@ -86,6 +88,7 @@
 public class WebFluxIntegrationRequestMappingHandlerMapping extends RequestMappingHandlerMapping
 		implements ApplicationListener<ContextRefreshedEvent>, DestructionAwareBeanPostProcessor {
 
+	@SuppressWarnings("NullAway") // Reflection
 	private static final Method HANDLER_METHOD =
 			ReflectionUtils.findMethod(WebHandler.class, "handle", ServerWebExchange.class);
 
@@ -103,7 +106,10 @@ public Object postProcessBeforeInitialization(Object bean, String beanName) thro
 	@Override
 	public void postProcessBeforeDestruction(Object bean, String beanName) throws BeansException {
 		if (isHandler(bean.getClass())) {
-			unregisterMapping(getMappingForEndpoint((WebFluxInboundEndpoint) bean));
+			RequestMappingInfo mapping = getMappingForEndpoint((WebFluxInboundEndpoint) bean);
+			if (mapping != null) {
+				unregisterMapping(mapping);
+			}
 		}
 	}
 
@@ -118,13 +124,14 @@ protected boolean isHandler(Class<?> beanType) {
 	}
 
 	@Override
+	@SuppressWarnings("NullAway") // Dataflow analysis limitation
 	protected void detectHandlerMethods(Object handler) {
 		if (handler instanceof String string) {
-			handler = getApplicationContext().getBean(string); // NOSONAR never null
+			handler = getApplicationContext().getBean(string);
 		}
 		RequestMappingInfo mapping = getMappingForEndpoint((WebFluxInboundEndpoint) handler);
 		if (mapping != null) {
-			registerMapping(mapping, handler, HANDLER_METHOD); // NOSONAR never null
+			registerMapping(mapping, handler, HANDLER_METHOD);
 		}
 	}
 
@@ -134,7 +141,7 @@ protected void detectHandlerMethods(Object handler) {
 	 * {@link org.springframework.integration.http.inbound.RequestMapping}.
 	 * @see RequestMappingHandlerMapping#getMappingForMethod
 	 */
-	private RequestMappingInfo getMappingForEndpoint(WebFluxInboundEndpoint endpoint) {
+	private @Nullable RequestMappingInfo getMappingForEndpoint(WebFluxInboundEndpoint endpoint) {
 		org.springframework.web.bind.annotation.RequestMapping requestMappingAnnotation =
 				HttpContextUtils.convertRequestMappingToAnnotation(endpoint.getRequestMapping());
 		if (requestMappingAnnotation != null) {
@@ -146,7 +153,7 @@ private RequestMappingInfo getMappingForEndpoint(WebFluxInboundEndpoint endpoint
 	}
 
 	@Override
-	protected CorsConfiguration initCorsConfiguration(Object handler, Method method, RequestMappingInfo mappingInfo) {
+	protected @Nullable CorsConfiguration initCorsConfiguration(Object handler, Method method, RequestMappingInfo mappingInfo) {
 		CrossOrigin crossOrigin = ((BaseHttpInboundEndpoint) handler).getCrossOrigin();
 		if (crossOrigin != null) {
 			return buildCorsConfiguration(crossOrigin, mappingInfo);

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

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

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

@@ -1,4 +1,5 @@
 /**
  * Provides classes to support WebFlux endpoints.
  */
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.webflux.support;