gh-10083: Scope: spring-integration-cassandra

Handled suppression of NullAway warnings by adding explicit null checks.

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

Author: anayonkars

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

@@ -1,5 +1,5 @@
 /*
- * Copyright 2022 the original author or authors.
+ * Copyright 2022-2025 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -17,4 +17,5 @@
 /**
  * Provides classes for Cassandra parsers and namespace handlers.
  */
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.cassandra.config.xml;

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

@@ -163,14 +163,16 @@ 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 =
-				(session, requestMessage) ->
-						session.execute(
-								QueryOptionsUtil.addQueryOptions(statementProcessor.processMessage(requestMessage),
-										this.writeOptions));
+				(session, requestMessage) -> {
+					Statement<?> statement = statementProcessor.processMessage(requestMessage);
+					Assert.notNull(statement, "Statement must not be null");
+					return session.execute(
+							QueryOptionsUtil.addQueryOptions(statement,
+									this.writeOptions));
+				};
 		this.mode = Type.STATEMENT;
 	}
 
@@ -194,7 +196,7 @@ protected void doInit() {
 	}
 
 	@Override
-	@SuppressWarnings("NullAway")
+	@Nullable
 	protected Object handleRequestMessage(Message<?> requestMessage) {
 		Object payload = requestMessage.getPayload();
 
@@ -222,9 +224,10 @@ protected Object handleRequestMessage(Message<?> requestMessage) {
 		}
 	}
 
-	@SuppressWarnings({"unchecked", "NullAway"})
+	@SuppressWarnings("unchecked")
 	private Mono<? extends WriteResult> handleInsert(Object payload) {
-		if (this.ingestQuery != null) {
+		final String localIngestQuery = this.ingestQuery;
+		if (localIngestQuery != null) {
 			Assert.isInstanceOf(List.class, payload,
 					"to perform 'ingest' the 'payload' must be of 'List<List<?>>' type.");
 			List<?> list = (List<?>) payload;
@@ -236,7 +239,7 @@ private Mono<? extends WriteResult> handleInsert(Object payload) {
 			return this.cassandraOperations.getReactiveCqlOperations()
 					.execute((ReactiveSessionCallback<WriteResult>) session ->
 							session.prepare(
-											QueryOptionsUtil.addQueryOptions(SimpleStatement.newInstance(this.ingestQuery),
+											QueryOptionsUtil.addQueryOptions(SimpleStatement.newInstance(localIngestQuery),
 													this.writeOptions))
 									.flatMapMany(s ->
 											Flux.fromIterable(rows)