Upgrade to Jackson 3.0.0-rc10

* Upgrade to the latest Spring deps `SNAPSHOT`s, including Reactor
* Fix Jackson test to use a new `registeredModules()` API
* Fix `Transformers` & `IntegrationReactiveUtils` for Nullability enforced by Reactor API

Author: artembilan

build.gradle

@@ -69,7 +69,7 @@ ext {
     hsqldbVersion = '2.7.4'
     h2Version = '2.3.232'
     jacksonVersion = '2.20.0'
-    jackson3Version = '3.0.0-rc9'
+    jackson3Version = '3.0.0-rc10'
     jaxbVersion = '4.0.5'
     jcifsVersion = '2.1.40'
     jeroMqVersion = '0.6.0'
@@ -84,8 +84,8 @@ ext {
     lettuceVersion = '6.8.1.RELEASE'
     log4jVersion = '2.25.1'
     mailVersion = '2.0.4'
-    micrometerTracingVersion = '1.6.0-M3'
-    micrometerVersion = '1.16.0-M3'
+    micrometerTracingVersion = '1.6.0-SNAPSHOT'
+    micrometerVersion = '1.16.0-SNAPSHOT'
     mockitoVersion = '5.19.0'
     mongoDriverVersion = '5.6.0'
     mysqlVersion = '9.4.0'
@@ -94,18 +94,18 @@ ext {
     postgresVersion = '42.7.8'
     protobufVersion = '4.32.1'
     r2dbch2Version = '1.0.0.RELEASE'
-    reactorVersion = '2025.0.0-M7'
+    reactorVersion = '2025.0.0-SNAPSHOT'
     resilience4jVersion = '2.3.0'
     romeToolsVersion = '2.1.0'
     rsocketVersion = '1.1.5'
     servletApiVersion = '6.1.0'
     smackVersion = '4.4.8'
     springAmqpVersion = '4.0.0-SNAPSHOT'
-    springDataVersion = '2025.1.0-M6'
+    springDataVersion = '2025.1.0-SNAPSHOT'
     springGraphqlVersion = '2.0.0-SNAPSHOT'
-    springKafkaVersion = '4.0.0-M5'
+    springKafkaVersion = '4.0.0-SNAPSHOT'
     springSecurityVersion = '7.0.0-SNAPSHOT'
-    springVersion = '7.0.0-M9'
+    springVersion = '7.0.0-SNAPSHOT'
     springWsVersion = '5.0.0-SNAPSHOT'
     testcontainersVersion = '1.21.3'
     tomcatVersion = '11.0.11'

spring-integration-core/src/main/java/org/springframework/integration/dsl/Transformers.java

@@ -311,7 +311,7 @@ public static StreamTransformer fromStream(String charset) {
 		return new StreamTransformer(charset);
 	}
 
-	@SuppressWarnings("unchecked")
+	@SuppressWarnings({"unchecked", "NullAway"})
 	static <I, O> Flux<Message<O>> transformWithFunction(Publisher<Message<I>> publisher,
 			Function<? super Flux<Message<I>>, ? extends Publisher<O>> fluxFunction) {
 

spring-integration-core/src/main/java/org/springframework/integration/util/IntegrationReactiveUtils.java

@@ -119,22 +119,21 @@ public static ContextView captureReactorContext() {
 	 * When {@link MessageSource#receive()} returns {@code null}, the source {@link Mono}
 	 * goes to the {@link Mono#repeatWhenEmpty} state and performs a {@code delay}
 	 * based on the {@link #DELAY_WHEN_EMPTY_KEY} {@link Duration} entry in the subscriber context
-	 * or falls back to 1 second duration.
+	 * or falls back to 1-second duration.
 	 * If a produced message has an
 	 * {@link org.springframework.integration.IntegrationMessageHeaderAccessor#ACKNOWLEDGMENT_CALLBACK} header
 	 * it is ack'ed in the {@link Mono#doOnSuccess} and nack'ed in the {@link Mono#doOnError}.
 	 * @param messageSource the {@link MessageSource} to adapt.
 	 * @param <T> the expected payload type.
 	 * @return a {@link Flux} which pulls messages from the {@link MessageSource} on demand.
 	 */
+	@SuppressWarnings("NullAway")
 	public static <T> Flux<Message<T>> messageSourceToFlux(MessageSource<T> messageSource) {
 		return Mono.
 				<Message<T>>create(monoSink ->
 				monoSink.onRequest(value -> monoSink.success(messageSource.receive())))
 				.doOnSuccess((message) -> {
-					if (message != null) {
-						AckUtils.autoAck(StaticMessageHeaderAccessor.getAcknowledgmentCallback(message));
-					}
+					AckUtils.autoAck(StaticMessageHeaderAccessor.getAcknowledgmentCallback(message));
 				})
 				.doOnError(MessagingException.class,
 						(ex) -> {
@@ -189,12 +188,12 @@ private static <T> Flux<Message<T>> adaptSubscribableChannelToPublisher(Subscrib
 			Sinks.Many<Message<T>> sink = Sinks.many().unicast().onBackpressureError();
 			MessageHandler messageHandler = (message) -> {
 				Message<?> messageToEmit = message;
-					ContextView contextView = IntegrationReactiveUtils.captureReactorContext();
-					if (!contextView.isEmpty()) {
-						messageToEmit = MutableMessageBuilder.fromMessage(message)
-								.setHeader(IntegrationMessageHeaderAccessor.REACTOR_CONTEXT, contextView)
-								.build();
-					}
+				ContextView contextView = IntegrationReactiveUtils.captureReactorContext();
+				if (!contextView.isEmpty()) {
+					messageToEmit = MutableMessageBuilder.fromMessage(message)
+							.setHeader(IntegrationMessageHeaderAccessor.REACTOR_CONTEXT, contextView)
+							.build();
+				}
 				while (true) {
 					switch (sink.tryEmitNext((Message<T>) messageToEmit)) {
 						case FAIL_NON_SERIALIZED:

spring-integration-core/src/test/java/org/springframework/integration/support/json/JacksonJsonObjectMapperTests.java

@@ -72,8 +72,8 @@ void compareAutoDiscoveryVsManualModules() {
 				.addModules(kotlinModule)
 				.build();
 
-		Set<String> autoModuleNames = getModuleNames(mapper.getObjectMapper().getRegisteredModules());
-		Set<String> manualModuleNames = getModuleNames(manualMapper.getRegisteredModules());
+		Set<String> autoModuleNames = getModuleNames(mapper.getObjectMapper().registeredModules().stream());
+		Set<String> manualModuleNames = getModuleNames(manualMapper.registeredModules().stream());
 
 		assertThat(autoModuleNames).isEqualTo(manualModuleNames);
 	}

spring-integration-core/src/test/java/org/springframework/integration/support/json/JacksonMessagingUtilsTests.java

@@ -53,7 +53,7 @@ void setUp() {
 	@Test
 	void shouldIncludeKotlinModule() {
 		KotlinModule kotlinModule = new KotlinModule.Builder().build();
-		Set<String> registeredModuleNames = getModuleNames(mapper.getRegisteredModules());
+		Set<String> registeredModuleNames = getModuleNames(mapper.registeredModules().stream());
 		assertThat(registeredModuleNames).contains(kotlinModule.getModuleName());
 	}