gh-10083: Scope: spring-integration-cassandra

1. Replaced springframework Nullable with jsepcify Nullable.
2. Replaced springframewor NonNullApi and NonNullFields with jspecify NullMarked

Signed-off-by: Anayonkar Shivalkar <[email protected]>

Author: anayonkars

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

@@ -1,6 +1,5 @@
 /**
  * Provides Apache Cassandra Components support for the Java DSL.
  */
-@org.springframework.lang.NonNullApi
-@org.springframework.lang.NonNullFields
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.cassandra.dsl;

spring-integration-cassandra/src/main/java/org/springframework/integration/cassandra/outbound/CassandraMessageHandler.java

@@ -27,6 +27,7 @@
 import com.datastax.oss.driver.api.core.cql.SimpleStatement;
 import com.datastax.oss.driver.api.core.cql.Statement;
 import com.datastax.oss.driver.api.querybuilder.QueryBuilder;
+import org.jspecify.annotations.Nullable;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
@@ -50,7 +51,6 @@
 import org.springframework.integration.handler.AbstractReplyProducingMessageHandler;
 import org.springframework.integration.handler.ExpressionEvaluatingMessageProcessor;
 import org.springframework.integration.handler.MessageProcessor;
-import org.springframework.lang.Nullable;
 import org.springframework.messaging.Message;
 import org.springframework.util.Assert;
 
@@ -85,8 +85,10 @@ public class CassandraMessageHandler extends AbstractReplyProducingMessageHandle
 	 */
 	private WriteOptions writeOptions;
 
+	@SuppressWarnings("NullAway.Init")
 	private ReactiveSessionMessageCallback sessionMessageCallback;
 
+	@SuppressWarnings("NullAway.Init")
 	private EvaluationContext evaluationContext;
 
 	public CassandraMessageHandler(ReactiveCassandraOperations cassandraOperations) {
@@ -161,6 +163,7 @@ public void setParameterExpressions(Map<String, Expression> parameterExpressions
 		this.parameterExpressions.putAll(parameterExpressions);
 	}
 
+	@SuppressWarnings("NullAway")
 	public void setStatementProcessor(MessageProcessor<Statement<?>> statementProcessor) {
 		Assert.notNull(statementProcessor, "'statementProcessor' must not be null.");
 		this.sessionMessageCallback =
@@ -191,6 +194,7 @@ protected void doInit() {
 	}
 
 	@Override
+	@SuppressWarnings("NullAway")
 	protected Object handleRequestMessage(Message<?> requestMessage) {
 		Object payload = requestMessage.getPayload();
 
@@ -218,7 +222,7 @@ protected Object handleRequestMessage(Message<?> requestMessage) {
 		}
 	}
 
-	@SuppressWarnings("unchecked")
+	@SuppressWarnings({"unchecked", "NullAway"})
 	private Mono<? extends WriteResult> handleInsert(Object payload) {
 		if (this.ingestQuery != null) {
 			Assert.isInstanceOf(List.class, payload,

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

@@ -1,5 +1,5 @@
 /**
  * Provides classes supporting Cassandra outbound endpoints.
  */
-@org.springframework.lang.NonNullApi
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.cassandra.outbound;