Skip to content

Commit 3e5d569

Browse files
authored
[ISSUE apache#3095] Handling possible NullPointerException[MessageUtils] (apache#4870)
1 parent 0336fa3 commit 3e5d569

File tree

1 file changed

+3
-2
lines changed
  • eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common

1 file changed

+3
-2
lines changed

Diff for: eventmesh-sdks/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/MessageUtils.java

+3-2
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,7 @@
3232

3333
import java.util.ArrayList;
3434
import java.util.List;
35+
import java.util.Objects;
3536
import java.util.concurrent.ThreadLocalRandom;
3637
import java.util.stream.IntStream;
3738

@@ -83,12 +84,12 @@ public static Package buildPackage(Object message, Command command) {
8384
final Package msg = getPackage(command);
8485
if (message instanceof CloudEvent) {
8586
final CloudEvent cloudEvent = (CloudEvent) message;
86-
Preconditions.checkNotNull(cloudEvent.getDataContentType(), "DateContentType cannot be null");
87+
Preconditions.checkNotNull(Objects.requireNonNull(cloudEvent.getDataContentType()), "DateContentType cannot be null");
8788
msg.getHeader().putProperty(Constants.PROTOCOL_TYPE, CLOUD_EVENTS_PROTOCOL_NAME);
8889
msg.getHeader().putProperty(Constants.PROTOCOL_VERSION, cloudEvent.getSpecVersion().toString());
8990
msg.getHeader().putProperty(Constants.PROTOCOL_DESC, "tcp");
9091

91-
final byte[] bodyByte = EventFormatProvider.getInstance().resolveFormat(cloudEvent.getDataContentType())
92+
final byte[] bodyByte = Objects.requireNonNull(EventFormatProvider.getInstance().resolveFormat(cloudEvent.getDataContentType()))
9293
.serialize((CloudEvent) message);
9394
msg.setBody(bodyByte);
9495
} else if (message instanceof EventMeshMessage) {

0 commit comments

Comments
 (0)