Merge pull request #1023 from mytang0/fix_patch_npe

[ISSUE #1022] Two NPE problems fixes for Tcp Protocol Resolver
close #1022

Author: xwm1992

eventmesh-common/src/main/java/org/apache/eventmesh/common/config/CommonConfiguration.java

@@ -98,7 +98,9 @@ public void init() {
             }
 
             eventMeshServerTraceEnable = Boolean.parseBoolean(get(ConfKeys.KEYS_EVENTMESH_TRACE_ENABLED, () -> "false"));
-            eventMeshTracePluginType = checkNotEmpty(ConfKeys.KEYS_EVENTMESH_TRACE_PLUGIN_TYPE);
+            if (eventMeshServerTraceEnable) {
+                eventMeshTracePluginType = checkNotEmpty(ConfKeys.KEYS_EVENTMESH_TRACE_PLUGIN_TYPE);
+            }
         }
     }
 

eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/tcp/TcpMessageProtocolResolver.java

@@ -79,11 +79,19 @@ public static CloudEvent buildEvent(Header header, EventMeshMessage message) thr
                 .withData(content.getBytes(StandardCharsets.UTF_8));
 
         for (String propKey : header.getProperties().keySet()) {
-            cloudEventBuilder.withExtension(propKey, header.getProperty(propKey).toString());
+            try {
+                cloudEventBuilder.withExtension(propKey, header.getProperty(propKey).toString());
+            } catch (Exception e) {
+                throw new ProtocolHandleException(String.format("Abnormal propKey: %s", propKey), e);
+            }
         }
 
         for (String propKey : message.getProperties().keySet()) {
-            cloudEventBuilder.withExtension(propKey, message.getProperties().get(propKey));
+            try {
+                cloudEventBuilder.withExtension(propKey, message.getProperties().get(propKey));
+            } catch (Exception e) {
+                throw new ProtocolHandleException(String.format("Abnormal propKey: %s", propKey), e);
+            }
         }
 
         return cloudEventBuilder.build();

eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/MessageTransferTask.java

@@ -31,7 +31,6 @@
 import org.apache.eventmesh.protocol.api.ProtocolAdaptor;
 import org.apache.eventmesh.protocol.api.ProtocolPluginFactory;
 import org.apache.eventmesh.runtime.acl.Acl;
-import org.apache.eventmesh.runtime.boot.EventMeshServer;
 import org.apache.eventmesh.runtime.boot.EventMeshTCPServer;
 import org.apache.eventmesh.runtime.constants.EventMeshConstants;
 import org.apache.eventmesh.runtime.core.protocol.tcp.client.session.send.EventMeshTcpSendResult;
@@ -58,7 +57,6 @@
 import io.netty.channel.ChannelFutureListener;
 import io.netty.channel.ChannelHandlerContext;
 import io.opentelemetry.api.trace.Span;
-import io.opentelemetry.api.trace.SpanKind;
 import io.opentelemetry.context.Context;
 
 public class MessageTransferTask extends AbstractTask {
@@ -181,7 +179,9 @@ public void operationComplete(ChannelFuture future) throws Exception {
                             .getSeq()));
                 Utils.writeAndFlush(msg, startTime, taskExecuteTime, session.getContext(), session);
 
-                TraceUtils.finishSpanWithException(ctx, event, "MessageTransferTask failed", e);
+                if (event != null) {
+                    TraceUtils.finishSpanWithException(ctx, event, "MessageTransferTask failed", e);
+                }
             }
         }
     }