Skip to content

Commit f77b49f

Browse files
keranbingaakeranbingaa
authored
Merge pull request #299 from surilli/develop
[ISSUE #283]Refactor 'eventmesh-test' package name to org.apache close #283
2 parents d463f8a + c33d157 commit f77b49f

24 files changed

+118
-118
lines changed

‎eventmesh-test/bin/http_pub.sh

+4-4
Original file line numberDiff line numberDiff line change
@@ -43,13 +43,13 @@ function get_pid {
4343
else
4444
if [[ $OS =~ Msys ]]; then
4545
# 在Msys上存在可能无法kill识别出的进程的BUG
46-
ppid=`jps -v | grep -i "com.webank.eventmesh.http.demo.AsyncPublishInstance" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
46+
ppid=`jps -v | grep -i "org.apache.eventmesh.http.demo.AsyncPublishInstance" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
4747
elif [[ $OS =~ Darwin ]]; then
4848
# 已知问题：grep java 可能无法精确识别java进程
49-
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.http.demo.AsyncPublishInstance" | grep -Ev "^root" |awk -F ' ' {'print $2'})
49+
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "org.apache.eventmesh.http.demo.AsyncPublishInstance" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5050
else
5151
#在Linux服务器上要求尽可能精确识别进程
52-
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $EVENTMESH_HOME | grep -i "com.webank.eventmesh.http.demo.AsyncPublishInstance" | grep -Ev "^root" |awk -F ' ' {'print $2'})
52+
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $EVENTMESH_HOME | grep -i "org.apache.eventmesh.http.demo.AsyncPublishInstance" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5353
fi
5454
fi
5555
echo "$ppid";
@@ -124,7 +124,7 @@ make_logs_dir
124124
echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_http_pub.out
125125

126126

127-
DEMO_MAIN=com.webank.eventmesh.http.demo.AsyncPublishInstance
127+
DEMO_MAIN=org.apache.eventmesh.http.demo.AsyncPublishInstance
128128
if [ $DOCKER ]
129129
then
130130
$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_http_pub.out

‎eventmesh-test/bin/http_sub.sh

+4-4
Original file line numberDiff line numberDiff line change
@@ -43,13 +43,13 @@ function get_pid {
4343
else
4444
if [[ $OS =~ Msys ]]; then
4545
# 在Msys上存在可能无法kill识别出的进程的BUG
46-
ppid=`jps -v | grep -i "com.webank.eventmesh.http.demo.sub.SpringBootDemoApplication" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
46+
ppid=`jps -v | grep -i "org.apache.eventmesh.http.demo.sub.SpringBootDemoApplication" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
4747
elif [[ $OS =~ Darwin ]]; then
4848
# 已知问题：grep java 可能无法精确识别java进程
49-
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.http.demo.sub.SpringBootDemoApplication" | grep -Ev "^root" |awk -F ' ' {'print $2'})
49+
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "org.apache.eventmesh.http.demo.sub.SpringBootDemoApplication" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5050
else
5151
#在Linux服务器上要求尽可能精确识别进程
52-
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $EVENTMESH_HOME | grep -i "com.webank.eventmesh.http.demo.sub.SpringBootDemoApplication" | grep -Ev "^root" |awk -F ' ' {'print $2'})
52+
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $EVENTMESH_HOME | grep -i "org.apache.eventmesh.http.demo.sub.SpringBootDemoApplication" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5353
fi
5454
fi
5555
echo "$ppid";
@@ -124,7 +124,7 @@ make_logs_dir
124124
echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_http_sub.out
125125

126126

127-
DEMO_MAIN=com.webank.eventmesh.http.demo.sub.SpringBootDemoApplication
127+
DEMO_MAIN=org.apache.eventmesh.http.demo.sub.SpringBootDemoApplication
128128
if [ $DOCKER ]
129129
then
130130
$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_http_sub.out

‎eventmesh-test/bin/tcp_pub.sh

+4-4
Original file line numberDiff line numberDiff line change
@@ -43,13 +43,13 @@ function get_pid {
4343
else
4444
if [[ $OS =~ Msys ]]; then
4545
# 在Msys上存在可能无法kill识别出的进程的BUG
46-
ppid=`jps -v | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublish" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
46+
ppid=`jps -v | grep -i "org.apache.eventmesh.tcp.demo.AsyncPublish" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
4747
elif [[ $OS =~ Darwin ]]; then
4848
# 已知问题：grep java 可能无法精确识别java进程
49-
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublish" | grep -Ev "^root" |awk -F ' ' {'print $2'})
49+
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "org.apache.eventmesh.tcp.demo.AsyncPublish" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5050
else
5151
#在Linux服务器上要求尽可能精确识别进程
52-
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $EVENTMESH_HOME | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublish" | grep -Ev "^root" |awk -F ' ' {'print $2'})
52+
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $EVENTMESH_HOME | grep -i "org.apache.eventmesh.tcp.demo.AsyncPublish" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5353
fi
5454
fi
5555
echo "ppid";
@@ -124,7 +124,7 @@ make_logs_dir
124124
echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_tcp_pub.out
125125

126126

127-
DEMO_MAIN=com.webank.eventmesh.tcp.demo.AsyncPublish
127+
DEMO_MAIN=org.apache.eventmesh.tcp.demo.AsyncPublish
128128
if [ $DOCKER ]
129129
then
130130
$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_tcp_pub.out

‎eventmesh-test/bin/tcp_pub_broadcast.sh

+4-4
Original file line numberDiff line numberDiff line change
@@ -43,13 +43,13 @@ function get_pid {
4343
else
4444
if [[ $OS =~ Msys ]]; then
4545
# 在Msys上存在可能无法kill识别出的进程的BUG
46-
ppid=`jps -v | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublishBroadcast" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
46+
ppid=`jps -v | grep -i "org.apache.eventmesh.tcp.demo.AsyncPublishBroadcast" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
4747
elif [[ $OS =~ Darwin ]]; then
4848
# 已知问题：grep java 可能无法精确识别java进程
49-
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublishBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
49+
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "org.apache.eventmesh.tcp.demo.AsyncPublishBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5050
else
5151
#在Linux服务器上要求尽可能精确识别进程
52-
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $DEMO_HOME | grep -i "com.webank.eventmesh.tcp.demo.AsyncPublishBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
52+
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $DEMO_HOME | grep -i "org.apache.eventmesh.tcp.demo.AsyncPublishBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5353
fi
5454
fi
5555
echo "$ppid";
@@ -124,7 +124,7 @@ make_logs_dir
124124
echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_tcp_pub_broadcast.out
125125

126126

127-
DEMO_MAIN=com.webank.eventmesh.tcp.demo.AsyncPublishBroadcast
127+
DEMO_MAIN=org.apache.eventmesh.tcp.demo.AsyncPublishBroadcast
128128
if [ $DOCKER ]
129129
then
130130
$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_tcp_pub_broadcast.out

‎eventmesh-test/bin/tcp_sub.sh

+4-4
Original file line numberDiff line numberDiff line change
@@ -43,13 +43,13 @@ function get_pid {
4343
else
4444
if [[ $OS =~ Msys ]]; then
4545
# 在Msys上存在可能无法kill识别出的进程的BUG
46-
ppid=`jps -v | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribe" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
46+
ppid=`jps -v | grep -i "org.apache.eventmesh.tcp.demo.AsyncSubscribe" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
4747
elif [[ $OS =~ Darwin ]]; then
4848
# 已知问题：grep java 可能无法精确识别java进程
49-
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribe" | grep -Ev "^root" |awk -F ' ' {'print $2'})
49+
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "org.apache.eventmesh.tcp.demo.AsyncSubscribe" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5050
else
5151
#在Linux服务器上要求尽可能精确识别进程
52-
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $DEMO_HOME | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribe" | grep -Ev "^root" |awk -F ' ' {'print $2'})
52+
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $DEMO_HOME | grep -i "org.apache.eventmesh.tcp.demo.AsyncSubscribe" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5353
fi
5454
fi
5555
echo "$ppid";
@@ -124,7 +124,7 @@ make_logs_dir
124124
echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_tcp_sub.out
125125

126126

127-
DEMO_MAIN=com.webank.eventmesh.tcp.demo.AsyncSubscribe
127+
DEMO_MAIN=org.apache.eventmesh.tcp.demo.AsyncSubscribe
128128
if [ $DOCKER ]
129129
then
130130
$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_tcp_sub.out

‎eventmesh-test/bin/tcp_sub_broadcast.sh

+4-4
Original file line numberDiff line numberDiff line change
@@ -43,13 +43,13 @@ function get_pid {
4343
else
4444
if [[ $OS =~ Msys ]]; then
4545
# 在Msys上存在可能无法kill识别出的进程的BUG
46-
ppid=`jps -v | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribeBroadcast" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
46+
ppid=`jps -v | grep -i "org.apache.eventmesh.tcp.demo.AsyncSubscribeBroadcast" | grep java | grep -v grep | awk -F ' ' {'print $1'}`
4747
elif [[ $OS =~ Darwin ]]; then
4848
# 已知问题：grep java 可能无法精确识别java进程
49-
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribeBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
49+
ppid=$(/bin/ps -o user,pid,command | grep "java" | grep -i "org.apache.eventmesh.tcp.demo.AsyncSubscribeBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5050
else
5151
#在Linux服务器上要求尽可能精确识别进程
52-
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $EVENTMESH_HOME | grep -i "com.webank.eventmesh.tcp.demo.AsyncSubscribeBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
52+
ppid=$(ps -C java -o user,pid,command --cols 99999 | grep -w $EVENTMESH_HOME | grep -i "org.apache.eventmesh.tcp.demo.AsyncSubscribeBroadcast" | grep -Ev "^root" |awk -F ' ' {'print $2'})
5353
fi
5454
fi
5555
echo "$ppid";
@@ -124,7 +124,7 @@ make_logs_dir
124124
echo "using jdk[$JAVA]" >> ${DEMO_LOG_HOME}/demo_tcp_sub_broadcast.out
125125

126126

127-
DEMO_MAIN=com.webank.eventmesh.tcp.demo.AsyncSubscribeBroadcast
127+
DEMO_MAIN=org.apache.eventmesh.tcp.demo.AsyncSubscribeBroadcast
128128
if [ $DOCKER ]
129129
then
130130
$JAVA $JAVA_OPT -classpath ${DEMO_HOME}/conf:${DEMO_HOME}/apps/*:${DEMO_HOME}/lib/* $DEMO_MAIN >> ${DEMO_LOG_HOME}/demo_tcp_sub_broadcast.out

‎eventmesh-test/build.gradle

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ apply plugin: "maven"
1717
apply plugin: "eclipse"
1818
apply plugin: "idea"
1919

20-
group 'com.webank.eventmesh'
20+
group 'org.apache.eventmesh'
2121
version '1.2.0-SNAPSHOT'
2222

2323
sourceCompatibility = 1.8

‎eventmesh-test/conf/log4j2.xml

+1-1
Original file line numberDiff line numberDiff line change
@@ -28,7 +28,7 @@
2828
<AppenderRef ref="console"/>
2929
</AsyncRoot>
3030

31-
<AsyncLogger name="com.webank.eventmesh" level="debug" additivity="false" includeLocation="true">
31+
<AsyncLogger name="org.apache.eventmesh" level="debug" additivity="false" includeLocation="true">
3232
<AppenderRef ref="console"/>
3333
</AsyncLogger>
3434
</Loggers>

‎eventmesh-test/gradle.properties

+1-1
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
# limitations under the License.
1616
#
1717

18-
group=com.webank.eventmesh
18+
group=org.apache.eventmesh
1919
version=1.2.0-SNAPSHOT
2020
mavenUserName=
2121
mavenPassword=

‎eventmesh-test/src/main/java/com/webank/eventmesh/http/demo/AsyncPublishInstance.java ‎eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/AsyncPublishInstance.java

+8-8
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
1-
package com.webank.eventmesh.http.demo;
2-
import com.webank.eventmesh.client.http.conf.LiteClientConfig;
3-
import com.webank.eventmesh.client.http.producer.LiteProducer;
4-
import com.webank.eventmesh.common.Constants;
5-
import com.webank.eventmesh.common.IPUtil;
6-
import com.webank.eventmesh.common.LiteMessage;
7-
import com.webank.eventmesh.common.ThreadUtil;
8-
import com.webank.eventmesh.util.Utils;
1+
package org.apache.eventmesh.http.demo;
2+
import org.apache.eventmesh.client.http.conf.LiteClientConfig;
3+
import org.apache.eventmesh.client.http.producer.LiteProducer;
4+
import org.apache.eventmesh.common.Constants;
5+
import org.apache.eventmesh.common.IPUtil;
6+
import org.apache.eventmesh.common.LiteMessage;
7+
import org.apache.eventmesh.common.ThreadUtil;
8+
import org.apache.eventmesh.util.Utils;
99
import org.apache.commons.lang3.RandomStringUtils;
1010
import org.apache.commons.lang3.StringUtils;
1111
import org.slf4j.Logger;

‎eventmesh-test/src/main/java/com/webank/eventmesh/http/demo/AsyncSyncRequestInstance.java ‎eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/AsyncSyncRequestInstance.java

+8-8
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
1-
package com.webank.eventmesh.http.demo;
2-
import com.webank.eventmesh.client.http.conf.LiteClientConfig;
3-
import com.webank.eventmesh.client.http.producer.LiteProducer;
4-
import com.webank.eventmesh.client.http.producer.RRCallback;
5-
import com.webank.eventmesh.common.IPUtil;
6-
import com.webank.eventmesh.common.LiteMessage;
7-
import com.webank.eventmesh.common.ThreadUtil;
8-
import com.webank.eventmesh.util.Utils;
1+
package org.apache.eventmesh.http.demo;
2+
import org.apache.eventmesh.client.http.conf.LiteClientConfig;
3+
import org.apache.eventmesh.client.http.producer.LiteProducer;
4+
import org.apache.eventmesh.client.http.producer.RRCallback;
5+
import org.apache.eventmesh.common.IPUtil;
6+
import org.apache.eventmesh.common.LiteMessage;
7+
import org.apache.eventmesh.common.ThreadUtil;
8+
import org.apache.eventmesh.util.Utils;
99
import org.apache.commons.lang3.RandomStringUtils;
1010
import org.apache.commons.lang3.StringUtils;
1111
import org.slf4j.Logger;

‎eventmesh-test/src/main/java/com/webank/eventmesh/http/demo/SyncRequestInstance.java ‎eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/SyncRequestInstance.java

+6-6
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
1-
package com.webank.eventmesh.http.demo;
2-
import com.webank.eventmesh.client.http.conf.LiteClientConfig;
3-
import com.webank.eventmesh.client.http.producer.LiteProducer;
4-
import com.webank.eventmesh.common.IPUtil;
5-
import com.webank.eventmesh.common.LiteMessage;
6-
import com.webank.eventmesh.common.ThreadUtil;
1+
package org.apache.eventmesh.http.demo;
2+
import org.apache.eventmesh.client.http.conf.LiteClientConfig;
3+
import org.apache.eventmesh.client.http.producer.LiteProducer;
4+
import org.apache.eventmesh.common.IPUtil;
5+
import org.apache.eventmesh.common.LiteMessage;
6+
import org.apache.eventmesh.common.ThreadUtil;
77
import org.apache.commons.lang3.RandomStringUtils;
88
import org.apache.commons.lang3.StringUtils;
99
import org.slf4j.Logger;

‎eventmesh-test/src/main/java/com/webank/eventmesh/http/demo/sub/SpringBootDemoApplication.java ‎eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/sub/SpringBootDemoApplication.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.webank.eventmesh.http.demo.sub;
1+
package org.apache.eventmesh.http.demo.sub;
22

33
import org.springframework.boot.SpringApplication;
44
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;

‎eventmesh-test/src/main/java/com/webank/eventmesh/http/demo/sub/controller/SubController.java ‎eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/sub/controller/SubController.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.webank.eventmesh.http.demo.sub.controller;
1+
package org.apache.eventmesh.http.demo.sub.controller;
22

33
import com.alibaba.fastjson.JSONObject;
44
import org.slf4j.Logger;

‎eventmesh-test/src/main/java/com/webank/eventmesh/http/demo/sub/service/SubService.java ‎eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/sub/service/SubService.java

+7-7
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,11 @@
1-
package com.webank.eventmesh.http.demo.sub.service;
1+
package org.apache.eventmesh.http.demo.sub.service;
22

3-
import com.webank.eventmesh.client.http.conf.LiteClientConfig;
4-
import com.webank.eventmesh.client.http.consumer.LiteConsumer;
5-
import com.webank.eventmesh.common.IPUtil;
6-
import com.webank.eventmesh.common.EventMeshException;
7-
import com.webank.eventmesh.common.ThreadUtil;
8-
import com.webank.eventmesh.util.Utils;
3+
import org.apache.eventmesh.client.http.conf.LiteClientConfig;
4+
import org.apache.eventmesh.client.http.consumer.LiteConsumer;
5+
import org.apache.eventmesh.common.IPUtil;
6+
import org.apache.eventmesh.common.EventMeshException;
7+
import org.apache.eventmesh.common.ThreadUtil;
8+
import org.apache.eventmesh.util.Utils;
99
import org.apache.commons.lang3.StringUtils;
1010
import org.slf4j.Logger;
1111
import org.slf4j.LoggerFactory;

‎eventmesh-test/src/main/java/com/webank/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java ‎eventmesh-test/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,4 @@
1-
package com.webank.eventmesh.tcp.common;
1+
package org.apache.eventmesh.tcp.common;
22

33
/**
44
* Testcase set

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

+5-5
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
1-
package com.webank.eventmesh.tcp.common;
1+
package org.apache.eventmesh.tcp.common;
22

3-
import com.webank.eventmesh.common.protocol.tcp.Package;
4-
import com.webank.eventmesh.common.protocol.tcp.*;
3+
import org.apache.eventmesh.common.protocol.tcp.Package;
4+
import org.apache.eventmesh.common.protocol.tcp.*;
55

66
import java.util.concurrent.ThreadLocalRandom;
77

8-
import static com.webank.eventmesh.tcp.common.EventMeshTestCaseTopicSet.*;
9-
import static com.webank.eventmesh.common.protocol.tcp.Command.RESPONSE_TO_SERVER;
8+
import static org.apache.eventmesh.tcp.common.EventMeshTestCaseTopicSet.*;
9+
import static org.apache.eventmesh.common.protocol.tcp.Command.RESPONSE_TO_SERVER;
1010

1111
public class EventMeshTestUtils {
1212
private static final int seqLength = 10;

‎eventmesh-test/src/main/java/com/webank/eventmesh/tcp/demo/AsyncPublish.java ‎eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo/AsyncPublish.java

+9-9
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
1-
package com.webank.eventmesh.tcp.demo;
2-
3-
import com.webank.eventmesh.client.tcp.EventMeshClient;
4-
import com.webank.eventmesh.client.tcp.common.EventMeshCommon;
5-
import com.webank.eventmesh.client.tcp.impl.DefaultEventMeshClient;
6-
import com.webank.eventmesh.common.protocol.tcp.Package;
7-
import com.webank.eventmesh.common.protocol.tcp.UserAgent;
8-
import com.webank.eventmesh.tcp.common.EventMeshTestUtils;
9-
import com.webank.eventmesh.util.Utils;
1+
package org.apache.eventmesh.tcp.demo;
2+
3+
import org.apache.eventmesh.client.tcp.EventMeshClient;
4+
import org.apache.eventmesh.client.tcp.common.EventMeshCommon;
5+
import org.apache.eventmesh.client.tcp.impl.DefaultEventMeshClient;
6+
import org.apache.eventmesh.common.protocol.tcp.Package;
7+
import org.apache.eventmesh.common.protocol.tcp.UserAgent;
8+
import org.apache.eventmesh.tcp.common.EventMeshTestUtils;
9+
import org.apache.eventmesh.util.Utils;
1010
import org.slf4j.Logger;
1111
import org.slf4j.LoggerFactory;
1212

‎eventmesh-test/src/main/java/com/webank/eventmesh/tcp/demo/AsyncPublishBroadcast.java ‎eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo/AsyncPublishBroadcast.java

+9-9
Original file line numberDiff line numberDiff line change
@@ -1,12 +1,12 @@
1-
package com.webank.eventmesh.tcp.demo;
2-
3-
import com.webank.eventmesh.client.tcp.EventMeshClient;
4-
import com.webank.eventmesh.client.tcp.common.EventMeshCommon;
5-
import com.webank.eventmesh.client.tcp.impl.DefaultEventMeshClient;
6-
import com.webank.eventmesh.common.protocol.tcp.Package;
7-
import com.webank.eventmesh.common.protocol.tcp.UserAgent;
8-
import com.webank.eventmesh.tcp.common.EventMeshTestUtils;
9-
import com.webank.eventmesh.util.Utils;
1+
package org.apache.eventmesh.tcp.demo;
2+
3+
import org.apache.eventmesh.client.tcp.EventMeshClient;
4+
import org.apache.eventmesh.client.tcp.common.EventMeshCommon;
5+
import org.apache.eventmesh.client.tcp.impl.DefaultEventMeshClient;
6+
import org.apache.eventmesh.common.protocol.tcp.Package;
7+
import org.apache.eventmesh.common.protocol.tcp.UserAgent;
8+
import org.apache.eventmesh.tcp.common.EventMeshTestUtils;
9+
import org.apache.eventmesh.util.Utils;
1010
import org.slf4j.Logger;
1111
import org.slf4j.LoggerFactory;
1212

‎eventmesh-test/src/main/java/com/webank/eventmesh/tcp/demo/AsyncSubscribe.java ‎eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo/AsyncSubscribe.java

+10-10
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
1-
package com.webank.eventmesh.tcp.demo;
2-
3-
import com.webank.eventmesh.client.tcp.EventMeshClient;
4-
import com.webank.eventmesh.client.tcp.common.ReceiveMsgHook;
5-
import com.webank.eventmesh.client.tcp.impl.DefaultEventMeshClient;
6-
import com.webank.eventmesh.common.protocol.tcp.EventMeshMessage;
7-
import com.webank.eventmesh.common.protocol.tcp.Package;
8-
import com.webank.eventmesh.common.protocol.tcp.UserAgent;
9-
import com.webank.eventmesh.tcp.common.EventMeshTestUtils;
10-
import com.webank.eventmesh.util.Utils;
1+
package org.apache.eventmesh.tcp.demo;
2+
3+
import org.apache.eventmesh.client.tcp.EventMeshClient;
4+
import org.apache.eventmesh.client.tcp.common.ReceiveMsgHook;
5+
import org.apache.eventmesh.client.tcp.impl.DefaultEventMeshClient;
6+
import org.apache.eventmesh.common.protocol.tcp.EventMeshMessage;
7+
import org.apache.eventmesh.common.protocol.tcp.Package;
8+
import org.apache.eventmesh.common.protocol.tcp.UserAgent;
9+
import org.apache.eventmesh.tcp.common.EventMeshTestUtils;
10+
import org.apache.eventmesh.util.Utils;
1111
import io.netty.channel.ChannelHandlerContext;
1212
import org.slf4j.Logger;
1313
import org.slf4j.LoggerFactory;

‎eventmesh-test/src/main/java/com/webank/eventmesh/tcp/demo/AsyncSubscribeBroadcast.java ‎eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo/AsyncSubscribeBroadcast.java

+10-10
Original file line numberDiff line numberDiff line change
@@ -1,13 +1,13 @@
1-
package com.webank.eventmesh.tcp.demo;
2-
3-
import com.webank.eventmesh.client.tcp.EventMeshClient;
4-
import com.webank.eventmesh.client.tcp.common.ReceiveMsgHook;
5-
import com.webank.eventmesh.client.tcp.impl.DefaultEventMeshClient;
6-
import com.webank.eventmesh.common.protocol.tcp.EventMeshMessage;
7-
import com.webank.eventmesh.common.protocol.tcp.Package;
8-
import com.webank.eventmesh.common.protocol.tcp.UserAgent;
9-
import com.webank.eventmesh.tcp.common.EventMeshTestUtils;
10-
import com.webank.eventmesh.util.Utils;
1+
package org.apache.eventmesh.tcp.demo;
2+
3+
import org.apache.eventmesh.client.tcp.EventMeshClient;
4+
import org.apache.eventmesh.client.tcp.common.ReceiveMsgHook;
5+
import org.apache.eventmesh.client.tcp.impl.DefaultEventMeshClient;
6+
import org.apache.eventmesh.common.protocol.tcp.EventMeshMessage;
7+
import org.apache.eventmesh.common.protocol.tcp.Package;
8+
import org.apache.eventmesh.common.protocol.tcp.UserAgent;
9+
import org.apache.eventmesh.tcp.common.EventMeshTestUtils;
10+
import org.apache.eventmesh.util.Utils;
1111
import io.netty.channel.ChannelHandlerContext;
1212
import org.slf4j.Logger;
1313
import org.slf4j.LoggerFactory;

0 commit comments

Comments
 (0)