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/02/14 02:10:32 UTC
[incubator-eventmesh] branch master updated: [MINOR] Remove unused field in example (#766)
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 62eeb0e [MINOR] Remove unused field in example (#766)
62eeb0e is described below
commit 62eeb0eb252ec90bc729444970b9bdf4f03b92d6
Author: ZhangJian He <sh...@gmail.com>
AuthorDate: Mon Feb 14 10:10:28 2022 +0800
[MINOR] Remove unused field in example (#766)
---
.../main/java/org/apache/eventmesh/admin/rocketmq/util/NetUtils.java | 5 -----
.../http/demo/pub/eventmeshmessage/AsyncPublishInstance.java | 2 +-
.../org/apache/eventmesh/tcp/demo/pub/cloudevents/AsyncPublish.java | 2 --
.../apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublish.java | 2 --
.../src/main/java/org/apache/eventmesh/util/Utils.java | 2 +-
5 files changed, 2 insertions(+), 11 deletions(-)
diff --git a/eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/NetUtils.java b/eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/NetUtils.java
index 0feedb2..2414c17 100644
--- a/eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/NetUtils.java
+++ b/eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/NetUtils.java
@@ -22,15 +22,10 @@ import org.apache.http.Consts;
import java.io.IOException;
import java.io.InputStreamReader;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
import com.sun.net.httpserver.HttpExchange;
public class NetUtils {
- private static final Logger logger = LoggerFactory.getLogger(NetUtils.class);
-
public static String parsePostBody(HttpExchange exchange)
throws IOException {
StringBuilder body = new StringBuilder();
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/AsyncPublishInstance.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/AsyncPublishInstance.java
index 80a0092..add69de 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/AsyncPublishInstance.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/AsyncPublishInstance.java
@@ -68,7 +68,7 @@ public class AsyncPublishInstance {
.password("pass")
.build();
- try (EventMeshHttpProducer eventMeshHttpProducer = new EventMeshHttpProducer(eventMeshClientConfig);) {
+ try (EventMeshHttpProducer eventMeshHttpProducer = new EventMeshHttpProducer(eventMeshClientConfig)) {
for (int i = 0; i < messageSize; i++) {
Map<String, String> content = new HashMap<>();
content.put("content", "testPublishMessage");
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents/AsyncPublish.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents/AsyncPublish.java
index 7621885..63bcbc6 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents/AsyncPublish.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents/AsyncPublish.java
@@ -38,8 +38,6 @@ public class AsyncPublish {
private static EventMeshTCPClient<CloudEvent> client;
- public static AsyncPublish handler = new AsyncPublish();
-
public static void main(String[] args) throws Exception {
Properties properties = Utils.readPropertiesFile("application.properties");
final String eventMeshIp = properties.getProperty("eventmesh.ip");
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublish.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublish.java
index c963e54..45d4dda 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublish.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublish.java
@@ -37,8 +37,6 @@ public class AsyncPublish {
private static EventMeshTCPClient<EventMeshMessage> client;
- public static AsyncPublish handler = new AsyncPublish();
-
public static void main(String[] args) throws Exception {
Properties properties = Utils.readPropertiesFile("application.properties");
final String eventMeshIp = properties.getProperty("eventmesh.ip");
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/util/Utils.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/util/Utils.java
index d64f629..cb121da 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/util/Utils.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/util/Utils.java
@@ -66,7 +66,7 @@ public class Utils {
enumIpAddr.hasMoreElements(); ) {
InetAddress inetAddress = enumIpAddr.nextElement();
if (!inetAddress.isLoopbackAddress()) {
- String ipaddress = inetAddress.getHostAddress().toString();
+ String ipaddress = inetAddress.getHostAddress();
if (!ipaddress.contains("::") && !ipaddress.contains("0:0:")
&& !ipaddress.contains("fe80")) {
ip = ipaddress;
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org