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/01/10 02:55:44 UTC
[incubator-eventmesh] branch master updated: [ISSUE #405]Fix args typo in examples (#707)
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 db6b34f [ISSUE #405]Fix args typo in examples (#707)
db6b34f is described below
commit db6b34f268decbb77f620db1e07b8008fd87c62a
Author: ZhangJian He <sh...@gmail.com>
AuthorDate: Mon Jan 10 10:55:36 2022 +0800
[ISSUE #405]Fix args typo in examples (#707)
fixed #405
---
.../org/apache/eventmesh/tcp/demo/pub/cloudevents/AsyncPublish.java | 2 +-
.../java/org/apache/eventmesh/tcp/demo/pub/cloudevents/SyncRequest.java | 2 +-
.../apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublish.java | 2 +-
.../eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublishBroadcast.java | 2 +-
.../org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/SyncRequest.java | 2 +-
.../org/apache/eventmesh/tcp/demo/sub/cloudevents/AsyncSubscribe.java | 2 +-
.../org/apache/eventmesh/tcp/demo/sub/cloudevents/SyncResponse.java | 2 +-
.../apache/eventmesh/tcp/demo/sub/eventmeshmessage/AsyncSubscribe.java | 2 +-
.../tcp/demo/sub/eventmeshmessage/AsyncSubscribeBroadcast.java | 2 +-
.../apache/eventmesh/tcp/demo/sub/eventmeshmessage/SyncResponse.java | 2 +-
10 files changed, 10 insertions(+), 10 deletions(-)
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 7b1fc3b..df96422 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
@@ -40,7 +40,7 @@ public class AsyncPublish {
public static AsyncPublish handler = new AsyncPublish();
- public static void main(String[] agrs) throws Exception {
+ public static void main(String[] args) throws Exception {
Properties properties = Utils.readPropertiesFile("application.properties");
final String eventMeshIp = properties.getProperty("eventmesh.ip");
final int eventMeshTcpPort = Integer.parseInt(properties.getProperty("eventmesh.tcp.port"));
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents/SyncRequest.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents/SyncRequest.java
index 5d5b666..9e81e93 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents/SyncRequest.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents/SyncRequest.java
@@ -40,7 +40,7 @@ public class SyncRequest {
private static EventMeshTCPClient<CloudEvent> client;
- public static void main(String[] agrs) throws Exception {
+ public static void main(String[] args) throws Exception {
Properties properties = Utils.readPropertiesFile("application.properties");
final String eventMeshIp = properties.getProperty("eventmesh.ip");
final int eventMeshTcpPort = Integer.parseInt(properties.getProperty("eventmesh.tcp.port"));
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 876164b..c963e54 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
@@ -39,7 +39,7 @@ public class AsyncPublish {
public static AsyncPublish handler = new AsyncPublish();
- public static void main(String[] agrs) throws Exception {
+ public static void main(String[] args) throws Exception {
Properties properties = Utils.readPropertiesFile("application.properties");
final String eventMeshIp = properties.getProperty("eventmesh.ip");
final int eventMeshTcpPort = Integer.parseInt(properties.getProperty("eventmesh.tcp.port"));
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublishBroadcast.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublishBroadcast.java
index bc94f31..4af986e 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublishBroadcast.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublishBroadcast.java
@@ -35,7 +35,7 @@ public class AsyncPublishBroadcast {
public static Logger logger = LoggerFactory.getLogger(AsyncPublishBroadcast.class);
- public static void main(String[] agrs) throws Exception {
+ public static void main(String[] args) throws Exception {
Properties properties = Utils.readPropertiesFile("application.properties");
final String eventMeshIp = properties.getProperty("eventmesh.ip");
final int eventMeshTcpPort = Integer.parseInt(properties.getProperty("eventmesh.tcp.port"));
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/SyncRequest.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/SyncRequest.java
index 0b4ade9..67fe94a 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/SyncRequest.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/SyncRequest.java
@@ -33,7 +33,7 @@ public class SyncRequest {
private static EventMeshTCPClient<EventMeshMessage> client;
- public static void main(String[] agrs) throws Exception {
+ public static void main(String[] args) throws Exception {
UserAgent userAgent = EventMeshTestUtils.generateClient1();
EventMeshTCPClientConfig eventMeshTcpClientConfig = EventMeshTCPClientConfig.builder()
.host("127.0.0.1")
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents/AsyncSubscribe.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents/AsyncSubscribe.java
index 91719d7..7a96fa3 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents/AsyncSubscribe.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents/AsyncSubscribe.java
@@ -43,7 +43,7 @@ public class AsyncSubscribe implements ReceiveMsgHook<CloudEvent> {
private static EventMeshTCPClient<CloudEvent> client;
- public static void main(String[] agrs) throws Exception {
+ public static void main(String[] args) throws Exception {
Properties properties = Utils.readPropertiesFile("application.properties");
final String eventMeshIp = properties.getProperty("eventmesh.ip");
final int eventMeshTcpPort = Integer.parseInt(properties.getProperty("eventmesh.tcp.port"));
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents/SyncResponse.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents/SyncResponse.java
index 76292e1..326e076 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents/SyncResponse.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents/SyncResponse.java
@@ -42,7 +42,7 @@ public class SyncResponse implements ReceiveMsgHook<CloudEvent> {
private static EventMeshTCPClient<CloudEvent> client;
- public static void main(String[] agrs) throws Exception {
+ public static void main(String[] args) throws Exception {
Properties properties = Utils.readPropertiesFile("application.properties");
final String eventMeshIp = properties.getProperty("eventmesh.ip");
final int eventMeshTcpPort = Integer.parseInt(properties.getProperty("eventmesh.tcp.port"));
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/AsyncSubscribe.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/AsyncSubscribe.java
index 7803163..8fd32c8 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/AsyncSubscribe.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/AsyncSubscribe.java
@@ -41,7 +41,7 @@ public class AsyncSubscribe implements ReceiveMsgHook<EventMeshMessage> {
private static EventMeshTCPClient<EventMeshMessage> client;
- public static void main(String[] agrs) throws Exception {
+ public static void main(String[] args) throws Exception {
Properties properties = Utils.readPropertiesFile("application.properties");
final String eventMeshIp = properties.getProperty("eventmesh.ip");
final int eventMeshTcpPort = Integer.parseInt(properties.getProperty("eventmesh.tcp.port"));
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/AsyncSubscribeBroadcast.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/AsyncSubscribeBroadcast.java
index 93d0953..f43f9de 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/AsyncSubscribeBroadcast.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/AsyncSubscribeBroadcast.java
@@ -38,7 +38,7 @@ public class AsyncSubscribeBroadcast implements ReceiveMsgHook<EventMeshMessage>
public static AsyncSubscribeBroadcast handler = new AsyncSubscribeBroadcast();
- public static void main(String[] agrs) throws Exception {
+ public static void main(String[] args) throws Exception {
Properties properties = Utils.readPropertiesFile("application.properties");
final String eventMeshIp = properties.getProperty("eventmesh.ip");
final int eventMeshTcpPort = Integer.parseInt(properties.getProperty("eventmesh.tcp.port"));
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/SyncResponse.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/SyncResponse.java
index 9c7d37d..1fe8ee4 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/SyncResponse.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/SyncResponse.java
@@ -38,7 +38,7 @@ public class SyncResponse implements ReceiveMsgHook<EventMeshMessage> {
private static EventMeshTCPClient<EventMeshMessage> client;
- public static void main(String[] agrs) throws Exception {
+ public static void main(String[] args) throws Exception {
UserAgent userAgent = EventMeshTestUtils.generateClient2();
EventMeshTCPClientConfig eventMeshTcpClientConfig = EventMeshTCPClientConfig.builder()
.host("127.0.0.1")
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org