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 8355069 [MINOR] Fix the hardcode ip address (#767)
8355069 is described below
commit 835506939ac1345ec670f767800b26c014a04ecd
Author: ZhangJian He <sh...@gmail.com>
AuthorDate: Tue Feb 15 17:23:22 2022 +0800
[MINOR] Fix the hardcode ip address (#767)
---
.../org/apache/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java | 3 ---
.../java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java | 6 +++---
2 files changed, 3 insertions(+), 6 deletions(-)
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java
index dd7908c..7fce2ca 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java
@@ -22,13 +22,10 @@ package org.apache.eventmesh.tcp.common;
*/
public class EventMeshTestCaseTopicSet {
- // public static final String TOPIC_PRX_WQ2ClientBroadCast = "topic-broadcast-test";
public static final String TOPIC_PRX_WQ2ClientBroadCast = "TEST-TOPIC-TCP-BROADCAST";
- // public static final String TOPIC_PRX_SyncSubscribeTest = "topic-sync-test";
public static final String TOPIC_PRX_SyncSubscribeTest = "TEST-TOPIC-TCP-SYNC";
- // public static final String TOPIC_PRX_WQ2ClientUniCast = "topic-async-test";
public static final String TOPIC_PRX_WQ2ClientUniCast = "TEST-TOPIC-TCP-ASYNC";
}
diff --git a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java
index 78a2f10..f7da239 100644
--- a/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java
+++ b/eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java
@@ -131,7 +131,7 @@ public class EventMeshTestUtils {
private static EventMeshMessage generateAsyncRRMqMsg() {
EventMeshMessage mqMsg = new EventMeshMessage();
mqMsg.setTopic(TOPIC_PRX_SyncSubscribeTest);
- mqMsg.getProperties().put("replyto", "10.36.0.109@ProducerGroup-producerPool-9-access#V1_4_0#CI");
+ mqMsg.getProperties().put("replyto", "localhost@ProducerGroup-producerPool-9-access#V1_4_0#CI");
mqMsg.getProperties().put("ttl", "300000");
mqMsg.getProperties().put("propertymessagereplyto", "notnull");
mqMsg.setBody("testAsyncRR");
@@ -141,7 +141,7 @@ public class EventMeshTestUtils {
public static EventMeshMessage generateAsyncEventMqMsg() {
EventMeshMessage mqMsg = new EventMeshMessage();
mqMsg.setTopic(TOPIC_PRX_WQ2ClientUniCast);
- mqMsg.getProperties().put("replyto", "10.36.0.109@ProducerGroup-producerPool-9-access#V1_4_0#CI");
+ mqMsg.getProperties().put("replyto", "localhost@ProducerGroup-producerPool-9-access#V1_4_0#CI");
mqMsg.getProperties().put("ttl", "30000");
mqMsg.getProperties().put("propertymessagereplyto", "notnull");
mqMsg.setBody("testAsyncMessage");
@@ -151,7 +151,7 @@ public class EventMeshTestUtils {
public static EventMeshMessage generateBroadcastMqMsg() {
EventMeshMessage mqMsg = new EventMeshMessage();
mqMsg.setTopic(TOPIC_PRX_WQ2ClientBroadCast);
- mqMsg.getProperties().put("replyto", "10.36.0.109@ProducerGroup-producerPool-9-access#V1_4_0#CI");
+ mqMsg.getProperties().put("replyto", "localhost@ProducerGroup-producerPool-9-access#V1_4_0#CI");
mqMsg.getProperties().put("ttl", "30000");
mqMsg.getProperties().put("propertymessagereplyto", "notnull");
mqMsg.setBody("testAsyncMessage");
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org