[MINOR] Fix the hardcode ip address (#767)

apache · Feb 15, 2022 · 8355069 · 8355069
1 parent 97ed081
commit 8355069
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 6 deletions.
diff --git a/...esh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java b/...esh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java
@@ -22,13 +22,10 @@
  */
 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
@@ -131,7 +131,7 @@ public static EventMeshMessage generateSyncRRMqMsg() {
     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 @@ private static EventMeshMessage generateAsyncRRMqMsg() {
     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 static EventMeshMessage generateAsyncEventMqMsg() {
     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");