Complete ZeroMQ module migration to JSpecify

- Migrate `package-info.java` files to use `@NullMarked` annotation
- Add `@SuppressWarnings("NullAway.Init")` for fields initialized in lifecycle methods

Signed-off-by: Jooyoung Pyoung <[email protected]>

Author: anthologia

spring-integration-zeromq/src/main/java/org/springframework/integration/zeromq/ZeroMqProxy.java

@@ -82,8 +82,10 @@ public class ZeroMqProxy implements InitializingBean, SmartLifecycle, BeanNameAw
 
 	private final AtomicInteger backendPort = new AtomicInteger();
 
+	@SuppressWarnings("NullAway.Init")
 	private String controlAddress;
 
+	@SuppressWarnings("NullAway.Init")
 	private Executor proxyExecutor;
 
 	@Nullable
@@ -97,6 +99,7 @@ public class ZeroMqProxy implements InitializingBean, SmartLifecycle, BeanNameAw
 	@Nullable
 	private String captureAddress;
 
+	@SuppressWarnings("NullAway.Init")
 	private String beanName;
 
 	private boolean autoStartup = true;

spring-integration-zeromq/src/main/java/org/springframework/integration/zeromq/channel/ZeroMqChannel.java

@@ -142,7 +142,7 @@ public ZeroMqChannel(ZContext context, boolean pubSub) {
 		this.subscriberData = prepareSubscriberDataFlux();
 	}
 
-	@SuppressWarnings("this-escape")
+	@SuppressWarnings({"this-escape", "NullAway"})
 	private Mono<Integer> prepareProxyMono() {
 		return Mono.defer(() -> {
 					if (this.zeroMqProxy != null) {

spring-integration-zeromq/src/main/java/org/springframework/integration/zeromq/channel/package-info.java

@@ -1,5 +1,5 @@
 /**
  * Provides classes for message channels support over ZeroMQ.
  */
-@org.springframework.lang.NonNullApi
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.zeromq.channel;

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

@@ -1,6 +1,5 @@
 /**
  * Provides classes for supporting ZeroMQ component via Java DSL.
  */
-@org.springframework.lang.NonNullApi
-@org.springframework.lang.NonNullFields
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.zeromq.dsl;

spring-integration-zeromq/src/main/java/org/springframework/integration/zeromq/inbound/ZeroMqMessageProducer.java

@@ -77,6 +77,7 @@ public class ZeroMqMessageProducer extends MessageProducerSupport {
 
 	private final SocketType socketType;
 
+	@SuppressWarnings("NullAway.Init")
 	private InboundMessageMapper<byte[]> messageMapper;
 
 	private Consumer<ZMQ.Socket> socketConfigurer = (socket) -> {
@@ -91,6 +92,7 @@ public class ZeroMqMessageProducer extends MessageProducerSupport {
 	@Nullable
 	private String connectUrl;
 
+	@SuppressWarnings("NullAway.Init")
 	private volatile Mono<ZMQ.Socket> socketMono;
 
 	private volatile boolean unwrapTopic = true;

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

@@ -1,5 +1,5 @@
 /**
  * Provides classes for inbound channel adapters over ZeroMQ.
  */
-@org.springframework.lang.NonNullApi
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.zeromq.inbound;

spring-integration-zeromq/src/main/java/org/springframework/integration/zeromq/outbound/ZeroMqMessageHandler.java

@@ -77,19 +77,23 @@ public class ZeroMqMessageHandler extends AbstractReactiveMessageHandler
 
 	private final Scheduler publisherScheduler = Schedulers.newSingle("zeroMqMessageHandlerScheduler");
 
+	@SuppressWarnings("NullAway.Init")
 	private volatile Mono<ZMQ.Socket> socketMono;
 
+	@SuppressWarnings("NullAway.Init")
 	private OutboundMessageMapper<byte[]> messageMapper;
 
 	private Consumer<ZMQ.Socket> socketConfigurer = (socket) -> {
 	};
 
 	private Expression topicExpression = new SupplierExpression<>(() -> null);
 
+	@SuppressWarnings("NullAway.Init")
 	private EvaluationContext evaluationContext;
 
 	private volatile boolean initialized;
 
+	@SuppressWarnings("NullAway.Init")
 	private volatile Disposable socketMonoSubscriber;
 
 	private volatile boolean wrapTopic = true;

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

@@ -1,5 +1,5 @@
 /**
  * Provides classes for outbound channel adapters over ZeroMQ.
  */
-@org.springframework.lang.NonNullApi
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.zeromq.outbound;

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

@@ -1,5 +1,5 @@
 /**
  * Provides common classes for supporting ZeroMQ components.
  */
-@org.springframework.lang.NonNullApi
+@org.jspecify.annotations.NullMarked
 package org.springframework.integration.zeromq;