Skip to content

Commit a065eb8

Browse files
GH-10083: Apply Nullability to Debezium module
Related to: #10083 Signed-off-by: Tran Ngoc Nhan <ngocnhan.tran1996@gmail.com>
1 parent 05ff0e6 commit a065eb8

File tree

4 files changed

+6
-5
lines changed

4 files changed

+6
-5
lines changed
Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,5 @@
11
/**
22
* Provides classes for supporting Debezium component via Java DSL.
33
*/
4-
@org.springframework.lang.NonNullApi
5-
@org.springframework.lang.NonNullFields
4+
@org.jspecify.annotations.NullMarked
65
package org.springframework.integration.debezium.dsl;

spring-integration-debezium/src/main/java/org/springframework/integration/debezium/inbound/DebeziumMessageProducer.java

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,13 +31,13 @@
3131
import io.debezium.engine.DebeziumEngine.RecordCommitter;
3232
import io.debezium.engine.Header;
3333
import io.debezium.engine.format.SerializationFormat;
34+
import org.jspecify.annotations.Nullable;
3435

3536
import org.springframework.core.task.SimpleAsyncTaskExecutor;
3637
import org.springframework.core.task.TaskExecutor;
3738
import org.springframework.integration.debezium.support.DebeziumHeaders;
3839
import org.springframework.integration.debezium.support.DefaultDebeziumHeaderMapper;
3940
import org.springframework.integration.endpoint.MessageProducerSupport;
40-
import org.springframework.lang.Nullable;
4141
import org.springframework.messaging.Message;
4242
import org.springframework.messaging.MessageHeaders;
4343
import org.springframework.messaging.support.HeaderMapper;
@@ -55,11 +55,13 @@ public class DebeziumMessageProducer extends MessageProducerSupport {
5555

5656
private final DebeziumEngine.Builder<ChangeEvent<byte[], byte[]>> debeziumEngineBuilder;
5757

58+
@SuppressWarnings("NullAway.Init")
5859
private DebeziumEngine<ChangeEvent<byte[], byte[]>> debeziumEngine;
5960

6061
/**
6162
* Debezium Engine is designed to be submitted to an {@link Executor}.
6263
*/
64+
@SuppressWarnings("NullAway.Init")
6365
private TaskExecutor taskExecutor;
6466

6567
private String contentType = "application/json";
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/**
22
* Provides classes for the Debezium inbound channel adapters.
33
*/
4-
@org.springframework.lang.NonNullApi
4+
@org.jspecify.annotations.NullMarked
55
package org.springframework.integration.debezium.inbound;
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/**
22
* Provides supporting classes for the Debezium channel adapters.
33
*/
4-
@org.springframework.lang.NonNullApi
4+
@org.jspecify.annotations.NullMarked
55
package org.springframework.integration.debezium.support;

0 commit comments

Comments
 (0)