Refactor 'eventmesh-test' package name to org.apache #283

Author: surilli(李慧敏)

eventmesh-test/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java

@@ -5,6 +5,7 @@
 
 import java.util.concurrent.ThreadLocalRandom;
 
+import static org.apache.eventmesh.tcp.common.EventMeshTestCaseTopicSet.*;
 import static com.webank.eventmesh.common.protocol.tcp.Command.RESPONSE_TO_SERVER;
 
 public class EventMeshTestUtils {
@@ -77,7 +78,7 @@ public static Package rrResponse(Package request) {
 
     private static EventMeshMessage generateSyncRRMqMsg() {
         EventMeshMessage mqMsg = new EventMeshMessage();
-        mqMsg.setTopic(EventMeshTestCaseTopicSet.TOPIC_PRX_SyncSubscribeTest);
+        mqMsg.setTopic(TOPIC_PRX_SyncSubscribeTest);
         mqMsg.getProperties().put("msgType", "persistent");
         mqMsg.getProperties().put("TTL", "300000");
         mqMsg.getProperties().put("KEYS", generateRandomString(16));
@@ -88,7 +89,7 @@ private static EventMeshMessage generateSyncRRMqMsg() {
 
     private static EventMeshMessage generateAsyncRRMqMsg() {
         EventMeshMessage mqMsg = new EventMeshMessage();
-        mqMsg.setTopic(EventMeshTestCaseTopicSet.TOPIC_PRX_SyncSubscribeTest);
+        mqMsg.setTopic(TOPIC_PRX_SyncSubscribeTest);
         mqMsg.getProperties().put("REPLY_TO", "10.36.0.109@ProducerGroup-producerPool-9-access#V1_4_0#CI");
         mqMsg.getProperties().put("TTL", "300000");
         mqMsg.getProperties().put("PROPERTY_MESSAGE_REPLY_TO", "notnull");
@@ -98,7 +99,7 @@ private static EventMeshMessage generateAsyncRRMqMsg() {
 
     private static EventMeshMessage generateAsyncEventMqMsg() {
         EventMeshMessage mqMsg = new EventMeshMessage();
-        mqMsg.setTopic(EventMeshTestCaseTopicSet.TOPIC_PRX_WQ2ClientUniCast);
+        mqMsg.setTopic(TOPIC_PRX_WQ2ClientUniCast);
         mqMsg.getProperties().put("REPLY_TO", "10.36.0.109@ProducerGroup-producerPool-9-access#V1_4_0#CI");
         mqMsg.getProperties().put("TTL", "30000");
         mqMsg.getProperties().put("PROPERTY_MESSAGE_REPLY_TO", "notnull");
@@ -108,7 +109,7 @@ private static EventMeshMessage generateAsyncEventMqMsg() {
 
     private static EventMeshMessage generateBroadcastMqMsg() {
         EventMeshMessage mqMsg = new EventMeshMessage();
-        mqMsg.setTopic(EventMeshTestCaseTopicSet.TOPIC_PRX_WQ2ClientBroadCast);
+        mqMsg.setTopic(TOPIC_PRX_WQ2ClientBroadCast);
         mqMsg.getProperties().put("REPLY_TO", "10.36.0.109@ProducerGroup-producerPool-9-access#V1_4_0#CI");
         mqMsg.getProperties().put("TTL", "30000");
         mqMsg.getProperties().put("PROPERTY_MESSAGE_REPLY_TO", "notnull");