Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[ISSUE #405] Fix args typo in examples #707

Merged
merged 1 commit into from
Jan 10, 2022
Merged

[ISSUE #405] Fix args typo in examples #707

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion ...sh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents/AsyncPublish.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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"));
Expand Down
2 changes: 1 addition & 1 deletion ...esh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents/SyncRequest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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"));
Expand Down
2 changes: 1 addition & 1 deletion ...amples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublish.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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"));
Expand Down
2 changes: 1 addition & 1 deletion ...c/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/AsyncPublishBroadcast.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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"));
Expand Down
2 changes: 1 addition & 1 deletion ...xamples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/SyncRequest.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down
2 changes: 1 addition & 1 deletion ...-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents/AsyncSubscribe.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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"));
Expand Down
2 changes: 1 addition & 1 deletion ...sh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents/SyncResponse.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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"));
Expand Down
2 changes: 1 addition & 1 deletion ...ples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/AsyncSubscribe.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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"));
Expand Down
2 changes: 1 addition & 1 deletion ...main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/AsyncSubscribeBroadcast.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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"));
Expand Down
2 changes: 1 addition & 1 deletion ...amples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage/SyncResponse.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -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")
Expand Down