You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by ma...@apache.org on 2022/10/25 12:50:46 UTC
[incubator-eventmesh] branch master updated: Add NPE to check for exceptions.
This is an automated email from the ASF dual-hosted git repository.
majorhe pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/master by this push:
new 8fb8ef78 Add NPE to check for exceptions.
new 8b7f0a03 Merge pull request #1852 from FuYung/dev_fix_vicfu
8fb8ef78 is described below
commit 8fb8ef7834e6f8cd76aeff2f6d9d273f7737e8a6
Author: vicfu(付勇) <fu...@gmail.com>
AuthorDate: Tue Oct 25 20:05:52 2022 +0800
Add NPE to check for exceptions.
---
.../meshmessage/resolver/tcp/TcpMessageProtocolResolver.java | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
diff --git a/eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/tcp/TcpMessageProtocolResolver.java b/eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/tcp/TcpMessageProtocolResolver.java
index 6e199cad..f333e70d 100644
--- a/eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/tcp/TcpMessageProtocolResolver.java
+++ b/eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/tcp/TcpMessageProtocolResolver.java
@@ -30,6 +30,7 @@ import java.net.URI;
import java.nio.charset.StandardCharsets;
import java.util.HashMap;
import java.util.Map;
+import java.util.Objects;
import io.cloudevents.CloudEvent;
import io.cloudevents.SpecVersion;
@@ -101,11 +102,11 @@ public class TcpMessageProtocolResolver {
public static Package buildEventMeshMessage(CloudEvent cloudEvent) {
EventMeshMessage eventMeshMessage = new EventMeshMessage();
eventMeshMessage.setTopic(cloudEvent.getSubject());
- eventMeshMessage.setBody(new String(cloudEvent.getData().toBytes(), StandardCharsets.UTF_8));
+ eventMeshMessage.setBody(new String(Objects.requireNonNull(cloudEvent.getData()).toBytes(), StandardCharsets.UTF_8));
Map<String, String> prop = new HashMap<>();
for (String extKey : cloudEvent.getExtensionNames()) {
- prop.put(extKey, cloudEvent.getExtension(extKey).toString());
+ prop.put(extKey, Objects.requireNonNull(cloudEvent.getExtension(extKey)).toString());
}
eventMeshMessage.setProperties(prop);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org