[ISSUE #3458]Fix EventMeshHttpProducer publish Read timed out

mxsm · mxsm · commit abd1cfec7e20 · 2023-03-16T23:21:46.000+08:00
diff --git a/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/producer/EventMeshProducer.java b/eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/producer/EventMeshProducer.java
@@ -25,6 +25,8 @@
 import org.apache.eventmesh.runtime.core.plugin.MQProducerWrapper;
 import org.apache.eventmesh.runtime.util.EventMeshUtil;
 
+import org.apache.commons.lang3.StringUtils;
+
 import java.util.Properties;
 import java.util.concurrent.atomic.AtomicBoolean;
 
@@ -86,7 +88,9 @@ public void init(EventMeshHTTPConfiguration eventMeshHttpConfiguration,
         keyValue.put("producerGroup", producerGroupConfig.getGroupName());
         keyValue.put("instanceName", EventMeshUtil.buildMeshClientID(producerGroupConfig.getGroupName(),
             eventMeshHttpConfiguration.getEventMeshCluster()));
-        keyValue.put(Constants.PRODUCER_TOKEN, producerGroupConfig.getToken());
+        if (StringUtils.isNotBlank(producerGroupConfig.getToken())) {
+            keyValue.put(Constants.PRODUCER_TOKEN, producerGroupConfig.getToken());
+        }
 
         //TODO for defibus
         keyValue.put("eventMeshIDC", eventMeshHttpConfiguration.getEventMeshIDC());
