You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/11/03 14:04:08 UTC
[incubator-eventmesh] branch master updated: fix CI error: java sdk
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 fe86134f fix CI error: java sdk
new 9676fe05 Merge pull request #2110 from horoc/fix-ci-error-sdk
fe86134f is described below
commit fe86134ff87b2608c4aa58482e84588d90067990
Author: horoc <ho...@gmail.com>
AuthorDate: Thu Nov 3 20:04:38 2022 +0800
fix CI error: java sdk
---
.../client/grpc/util/EventMeshClientUtil.java | 6 ++++-
.../client/http/demo/SyncRequestInstance.java | 28 ++++++++++++----------
2 files changed, 20 insertions(+), 14 deletions(-)
diff --git a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtil.java b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtil.java
index 2b415655..b50f70a6 100644
--- a/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtil.java
+++ b/eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtil.java
@@ -33,7 +33,11 @@ import org.apache.eventmesh.common.utils.ThreadUtils;
import org.apache.commons.lang3.StringUtils;
import java.nio.charset.StandardCharsets;
-import java.util.*;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.Optional;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
diff --git a/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/http/demo/SyncRequestInstance.java b/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/http/demo/SyncRequestInstance.java
index 51ec2af6..7e4c5f01 100644
--- a/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/http/demo/SyncRequestInstance.java
+++ b/eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/http/demo/SyncRequestInstance.java
@@ -17,13 +17,15 @@
package org.apache.eventmesh.client.http.demo;
-import org.apache.commons.lang3.StringUtils;
import org.apache.eventmesh.client.http.conf.EventMeshHttpClientConfig;
import org.apache.eventmesh.client.http.producer.EventMeshHttpProducer;
import org.apache.eventmesh.common.EventMeshMessage;
import org.apache.eventmesh.common.utils.IPUtils;
import org.apache.eventmesh.common.utils.RandomStringUtils;
import org.apache.eventmesh.common.utils.ThreadUtils;
+
+import org.apache.commons.lang3.StringUtils;
+
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@@ -45,27 +47,27 @@ public class SyncRequestInstance {
}
EventMeshHttpClientConfig eventMeshClientConfig = EventMeshHttpClientConfig.builder()
- .liteEventMeshAddr(eventMeshIPPort)
- .producerGroup("EventMeshTest-producerGroup")
- .env("env")
- .idc("idc")
- .ip(IPUtils.getLocalAddress())
- .sys("1234")
- .pid(String.valueOf(ThreadUtils.getPID())).build();
+ .liteEventMeshAddr(eventMeshIPPort)
+ .producerGroup("EventMeshTest-producerGroup")
+ .env("env")
+ .idc("idc")
+ .ip(IPUtils.getLocalAddress())
+ .sys("1234")
+ .pid(String.valueOf(ThreadUtils.getPID())).build();
eventMeshHttpProducer = new EventMeshHttpProducer(eventMeshClientConfig);
long startTime = System.currentTimeMillis();
EventMeshMessage eventMeshMessage = EventMeshMessage.builder()
- .bizSeqNo(RandomStringUtils.generateNum(30))
- .content("contentStr with special protocal")
- .topic(topic)
- .uniqueId(RandomStringUtils.generateNum(30)).build();
+ .bizSeqNo(RandomStringUtils.generateNum(30))
+ .content("contentStr with special protocal")
+ .topic(topic)
+ .uniqueId(RandomStringUtils.generateNum(30)).build();
EventMeshMessage rsp = eventMeshHttpProducer.request(eventMeshMessage, 10000);
if (logger.isDebugEnabled()) {
logger.debug("sendmsg : {}, return : {}, cost:{}ms", eventMeshMessage.getContent(), rsp.getContent(),
- System.currentTimeMillis() - startTime);
+ System.currentTimeMillis() - startTime);
}
} catch (Exception e) {
logger.warn("send msg failed", e);
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org