Migrate to JSpecify for nullability constraints (take 6)

Resolves #1150

Signed-off-by: Chris Bono <[email protected]>

Author: onobc

spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java

@@ -698,14 +698,15 @@ private List<Message<T>> invokeBatchListenerInTxn(Messages<T> messages, List<Mes
 			}
 		}
 
+		@SuppressWarnings("NullAway")
 		private List<Message<T>> doInvokeBatchListener(Messages<T> messages, List<Message<T>> messageList,
 				AtomicBoolean inRetryMode, AtomicBoolean messagesPendingInBatch, @Nullable Transaction txn) {
 			try {
 				if (!CollectionUtils.isEmpty(messageList)) {
-					if (this.batchMessageListener instanceof PulsarBatchAcknowledgingMessageListener
-							&& this.ackMode.equals(AckMode.MANUAL)) {
+					if (this.batchMessageListener instanceof PulsarBatchAcknowledgingMessageListener) {
 						this.batchMessageListener.received(this.consumer, messageList,
-								new ConsumerBatchAcknowledgment(this.consumer));
+								this.ackMode.equals(AckMode.MANUAL) ? new ConsumerBatchAcknowledgment(this.consumer)
+										: null);
 					}
 					else if (this.batchMessageListener != null) {
 						this.batchMessageListener.received(this.consumer, messageList);
@@ -714,8 +715,7 @@ else if (this.batchMessageListener != null) {
 						handleBatchAcks(messages, txn);
 					}
 					if (this.pulsarConsumerErrorHandler != null) {
-						pendingMessagesHandledSuccessfully(this.pulsarConsumerErrorHandler, inRetryMode,
-								messagesPendingInBatch);
+						pendingMessagesHandledSuccessfully(this.pulsarConsumerErrorHandler, inRetryMode, messagesPendingInBatch);
 					}
 				}
 				return Collections.emptyList();

spring-pulsar/src/test/java/org/springframework/pulsar/core/PulsarAdministrationTests.java

@@ -48,15 +48,6 @@ void createdWithServiceUrlOnly() throws PulsarClientException {
 			verify(adminBuilder).build();
 		}
 
-		@Test
-		void createdWithNullCustomizer() throws PulsarClientException {
-			PulsarAdminBuilderCustomizer customizer = null;
-			var admin = new PulsarAdministration(customizer);
-			admin.setAdminBuilder(adminBuilder);
-			admin.createAdminClient();
-			verify(adminBuilder).build();
-		}
-
 		@Test
 		void createdWithSingleCustomizer() throws PulsarClientException {
 			var customizer = mock(PulsarAdminBuilderCustomizer.class);

spring-pulsar/src/test/java/org/springframework/pulsar/listener/PulsarListenerTests.java

@@ -782,13 +782,13 @@ void springMessagingMessageListenerWithHeaders() throws Exception {
 		}
 
 		@Test
-		void simpleBatchListenerWithHeaders() throws Exception {
+		void SchemaTestCasessimpleBatchListenerWithHeaders() throws Exception {
 			MessageId messageId = pulsarTemplate.newMessage("hello-simple-batch-listener")
 				.withMessageCustomizer(
 						messageBuilder -> messageBuilder.property("foo", "simpleBatchListenerWithHeaders"))
 				.withTopic("plt-simpleBatchListenerWithHeaders")
 				.send();
-			assertThat(simpleBatchListenerLatch.await(10, TimeUnit.SECONDS)).isTrue();
+			assertThat(simpleBatchListenerLatch.await(120, TimeUnit.SECONDS)).isTrue();
 			assertThat(capturedBatchData).containsExactly("hello-simple-batch-listener");
 			assertThat(batchMessageIds).containsExactly(messageId);
 			assertThat(batchTopicNames)