This is an automated email from the ASF dual-hosted git repository.
mikexue 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 abd1cfec7 [ISSUE #3458]Fix EventMeshHttpProducer publish Read timed out
new 41a21459d Merge pull request #3459 from mxsm/eventmesh-3458
abd1cfec7 is described below
commit abd1cfec7e202092a7a54976828be41f35286796
Author: mxsm <[email protected]>
AuthorDate: Thu Mar 16 23:21:46 2023 +0800
[ISSUE #3458]Fix EventMeshHttpProducer publish Read timed out
---
.../runtime/core/protocol/http/producer/EventMeshProducer.java | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
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
index 7e4c47d1a..f58f20ea6 100644
---
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.consumergroup.ProducerGroupConf;
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 class EventMeshProducer {
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());
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
