Skip to content

Commit 7e5d4f4

Browse files
keranbingaakeranbingaa
committed
issue #277:refactor eventmesh-common package with org.apache
1 parent 85df3e9 commit 7e5d4f4

File tree

75 files changed

+210
-210
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

75 files changed

+210
-210
lines changed

‎eventmesh-common/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
defibus_version=1.0.1
2121
jdk=1.7

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/Constants.java

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

18-
package com.webank.eventmesh.common;
18+
package org.apache.eventmesh.common;
1919

2020
public class Constants {
2121

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/EventMeshException.java

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

18-
package com.webank.eventmesh.common;
18+
package org.apache.eventmesh.common;
1919

2020
public class EventMeshException extends Exception {
2121

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/IPUtil.java

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

18-
package com.webank.eventmesh.common;
18+
package org.apache.eventmesh.common;
1919

2020
import io.netty.channel.Channel;
2121

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/LiteMessage.java

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

18-
package com.webank.eventmesh.common;
18+
package org.apache.eventmesh.common;
1919

2020
import org.apache.commons.lang3.time.DateFormatUtils;
2121

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/ThreadPoolFactory.java

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

18-
package com.webank.eventmesh.common;
18+
package org.apache.eventmesh.common;
1919

2020
import java.util.concurrent.BlockingQueue;
2121
import java.util.concurrent.Executors;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/ThreadUtil.java

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

18-
package com.webank.eventmesh.common;
18+
package org.apache.eventmesh.common;
1919

2020
import java.util.concurrent.ThreadLocalRandom;
2121

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/command/HttpCommand.java

+6-6
Original file line numberDiff line numberDiff line change
@@ -15,13 +15,13 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.command;
18+
package org.apache.eventmesh.common.command;
1919

20-
import com.webank.eventmesh.common.Constants;
21-
import com.webank.eventmesh.common.protocol.http.body.BaseResponseBody;
22-
import com.webank.eventmesh.common.protocol.http.body.Body;
23-
import com.webank.eventmesh.common.protocol.http.header.BaseResponseHeader;
24-
import com.webank.eventmesh.common.protocol.http.header.Header;
20+
import org.apache.eventmesh.common.Constants;
21+
import org.apache.eventmesh.common.protocol.http.body.BaseResponseBody;
22+
import org.apache.eventmesh.common.protocol.http.body.Body;
23+
import org.apache.eventmesh.common.protocol.http.header.BaseResponseHeader;
24+
import org.apache.eventmesh.common.protocol.http.header.Header;
2525
import com.alibaba.fastjson.JSON;
2626
import io.netty.buffer.Unpooled;
2727
import io.netty.handler.codec.http.DefaultFullHttpResponse;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/config/CommonConfiguration.java

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

18-
package com.webank.eventmesh.common.config;
18+
package org.apache.eventmesh.common.config;
1919

2020
import com.google.common.base.Preconditions;
2121
import org.apache.commons.lang3.StringUtils;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/config/ConfigurationWraper.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.config;
18+
package org.apache.eventmesh.common.config;
1919

20-
import com.webank.eventmesh.common.ThreadPoolFactory;
20+
import org.apache.eventmesh.common.ThreadPoolFactory;
2121
import org.apache.commons.lang3.StringUtils;
2222
import org.slf4j.Logger;
2323
import org.slf4j.LoggerFactory;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/BaseRequestBody.java

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

18-
package com.webank.eventmesh.common.protocol.http.body;
18+
package org.apache.eventmesh.common.protocol.http.body;
1919

2020
import java.util.HashMap;
2121
import java.util.Map;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/BaseResponseBody.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,10 +15,10 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body;
18+
package org.apache.eventmesh.common.protocol.http.body;
1919

2020

21-
import com.webank.eventmesh.common.protocol.http.common.ProtocolKey;
21+
import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
2222

2323
import java.util.HashMap;
2424
import java.util.Map;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/Body.java

+8-8
Original file line numberDiff line numberDiff line change
@@ -15,16 +15,16 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body;
18+
package org.apache.eventmesh.common.protocol.http.body;
1919

2020

21-
import com.webank.eventmesh.common.protocol.http.body.client.*;
22-
import com.webank.eventmesh.common.protocol.http.common.RequestCode;
23-
import com.webank.eventmesh.common.protocol.http.body.message.PushMessageRequestBody;
24-
import com.webank.eventmesh.common.protocol.http.body.message.ReplyMessageRequestBody;
25-
import com.webank.eventmesh.common.protocol.http.body.message.SendMessageBatchRequestBody;
26-
import com.webank.eventmesh.common.protocol.http.body.message.SendMessageBatchV2RequestBody;
27-
import com.webank.eventmesh.common.protocol.http.body.message.SendMessageRequestBody;
21+
import org.apache.eventmesh.common.protocol.http.body.client.*;
22+
import org.apache.eventmesh.common.protocol.http.common.RequestCode;
23+
import org.apache.eventmesh.common.protocol.http.body.message.PushMessageRequestBody;
24+
import org.apache.eventmesh.common.protocol.http.body.message.ReplyMessageRequestBody;
25+
import org.apache.eventmesh.common.protocol.http.body.message.SendMessageBatchRequestBody;
26+
import org.apache.eventmesh.common.protocol.http.body.message.SendMessageBatchV2RequestBody;
27+
import org.apache.eventmesh.common.protocol.http.body.message.SendMessageRequestBody;
2828

2929
import java.util.Map;
3030

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/client/HeartbeatRequestBody.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.client;
18+
package org.apache.eventmesh.common.protocol.http.body.client;
1919

20-
import com.webank.eventmesh.common.protocol.http.body.Body;
20+
import org.apache.eventmesh.common.protocol.http.body.Body;
2121
import com.alibaba.fastjson.JSON;
2222
import com.alibaba.fastjson.JSONArray;
2323
import org.apache.commons.collections4.MapUtils;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/client/HeartbeatResponseBody.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.client;
18+
package org.apache.eventmesh.common.protocol.http.body.client;
1919

20-
import com.webank.eventmesh.common.protocol.http.common.ProtocolKey;
21-
import com.webank.eventmesh.common.Constants;
22-
import com.webank.eventmesh.common.protocol.http.body.Body;
20+
import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
21+
import org.apache.eventmesh.common.Constants;
22+
import org.apache.eventmesh.common.protocol.http.body.Body;
2323
import org.apache.commons.lang3.time.DateFormatUtils;
2424

2525
import java.util.HashMap;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/client/RegRequestBody.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.client;
18+
package org.apache.eventmesh.common.protocol.http.body.client;
1919

20-
import com.webank.eventmesh.common.protocol.http.body.Body;
20+
import org.apache.eventmesh.common.protocol.http.body.Body;
2121
import com.alibaba.fastjson.JSON;
2222
import com.alibaba.fastjson.JSONArray;
2323
import org.apache.commons.collections4.MapUtils;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/client/RegResponseBody.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.client;
18+
package org.apache.eventmesh.common.protocol.http.body.client;
1919

20-
import com.webank.eventmesh.common.protocol.http.common.ProtocolKey;
21-
import com.webank.eventmesh.common.Constants;
22-
import com.webank.eventmesh.common.protocol.http.body.Body;
20+
import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
21+
import org.apache.eventmesh.common.Constants;
22+
import org.apache.eventmesh.common.protocol.http.body.Body;
2323
import org.apache.commons.lang3.time.DateFormatUtils;
2424

2525
import java.util.HashMap;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/client/SubscribeRequestBody.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.client;
18+
package org.apache.eventmesh.common.protocol.http.body.client;
1919

2020
import com.alibaba.fastjson.JSON;
2121
import com.alibaba.fastjson.JSONArray;
22-
import com.webank.eventmesh.common.protocol.http.body.Body;
22+
import org.apache.eventmesh.common.protocol.http.body.Body;
2323
import org.apache.commons.collections4.MapUtils;
2424

2525
import java.util.HashMap;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/client/SubscribeResponseBody.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.client;
18+
package org.apache.eventmesh.common.protocol.http.body.client;
1919

20-
import com.webank.eventmesh.common.Constants;
21-
import com.webank.eventmesh.common.protocol.http.body.Body;
22-
import com.webank.eventmesh.common.protocol.http.common.ProtocolKey;
20+
import org.apache.eventmesh.common.Constants;
21+
import org.apache.eventmesh.common.protocol.http.body.Body;
22+
import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
2323
import org.apache.commons.lang3.time.DateFormatUtils;
2424

2525
import java.util.HashMap;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/client/UnRegRequestBody.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.client;
18+
package org.apache.eventmesh.common.protocol.http.body.client;
1919

20-
import com.webank.eventmesh.common.protocol.http.body.Body;
20+
import org.apache.eventmesh.common.protocol.http.body.Body;
2121
import com.alibaba.fastjson.JSON;
2222
import com.alibaba.fastjson.JSONArray;
2323
import org.apache.commons.collections4.MapUtils;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/client/UnRegResponseBody.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.client;
18+
package org.apache.eventmesh.common.protocol.http.body.client;
1919

20-
import com.webank.eventmesh.common.protocol.http.common.ProtocolKey;
21-
import com.webank.eventmesh.common.Constants;
22-
import com.webank.eventmesh.common.protocol.http.body.Body;
20+
import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
21+
import org.apache.eventmesh.common.Constants;
22+
import org.apache.eventmesh.common.protocol.http.body.Body;
2323
import org.apache.commons.lang3.time.DateFormatUtils;
2424

2525
import java.util.HashMap;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/client/UnSubscribeRequestBody.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.client;
18+
package org.apache.eventmesh.common.protocol.http.body.client;
1919

2020
import com.alibaba.fastjson.JSON;
2121
import com.alibaba.fastjson.JSONArray;
22-
import com.webank.eventmesh.common.protocol.http.body.Body;
22+
import org.apache.eventmesh.common.protocol.http.body.Body;
2323
import org.apache.commons.collections4.MapUtils;
2424

2525
import java.util.HashMap;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/client/UnSubscribeResponseBody.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.client;
18+
package org.apache.eventmesh.common.protocol.http.body.client;
1919

20-
import com.webank.eventmesh.common.Constants;
21-
import com.webank.eventmesh.common.protocol.http.body.Body;
22-
import com.webank.eventmesh.common.protocol.http.common.ProtocolKey;
20+
import org.apache.eventmesh.common.Constants;
21+
import org.apache.eventmesh.common.protocol.http.body.Body;
22+
import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
2323
import org.apache.commons.lang3.time.DateFormatUtils;
2424

2525
import java.util.HashMap;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/message/PushMessageRequestBody.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.message;
18+
package org.apache.eventmesh.common.protocol.http.body.message;
1919

20-
import com.webank.eventmesh.common.protocol.http.body.Body;
20+
import org.apache.eventmesh.common.protocol.http.body.Body;
2121
import com.alibaba.fastjson.JSON;
2222
import com.alibaba.fastjson.JSONObject;
2323
import org.apache.commons.collections4.MapUtils;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/message/PushMessageResponseBody.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.message;
18+
package org.apache.eventmesh.common.protocol.http.body.message;
1919

20-
import com.webank.eventmesh.common.Constants;
21-
import com.webank.eventmesh.common.protocol.http.body.Body;
22-
import com.webank.eventmesh.common.protocol.http.common.ProtocolKey;
20+
import org.apache.eventmesh.common.Constants;
21+
import org.apache.eventmesh.common.protocol.http.body.Body;
22+
import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
2323
import org.apache.commons.lang3.time.DateFormatUtils;
2424

2525
import java.util.HashMap;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/message/ReplyMessageRequestBody.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.message;
18+
package org.apache.eventmesh.common.protocol.http.body.message;
1919

20-
import com.webank.eventmesh.common.protocol.http.body.Body;
20+
import org.apache.eventmesh.common.protocol.http.body.Body;
2121
import com.alibaba.fastjson.JSON;
2222
import com.alibaba.fastjson.JSONObject;
2323
import org.apache.commons.collections4.MapUtils;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/message/ReplyMessageResponseBody.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.message;
18+
package org.apache.eventmesh.common.protocol.http.body.message;
1919

20-
import com.webank.eventmesh.common.protocol.http.common.ProtocolKey;
21-
import com.webank.eventmesh.common.Constants;
22-
import com.webank.eventmesh.common.protocol.http.body.Body;
20+
import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
21+
import org.apache.eventmesh.common.Constants;
22+
import org.apache.eventmesh.common.protocol.http.body.Body;
2323
import org.apache.commons.lang3.time.DateFormatUtils;
2424

2525
import java.util.HashMap;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/message/SendMessageBatchRequestBody.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.message;
18+
package org.apache.eventmesh.common.protocol.http.body.message;
1919

20-
import com.webank.eventmesh.common.protocol.http.body.Body;
20+
import org.apache.eventmesh.common.protocol.http.body.Body;
2121
import com.alibaba.fastjson.JSON;
2222
import com.alibaba.fastjson.JSONArray;
2323
import org.apache.commons.collections4.MapUtils;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/message/SendMessageBatchResponseBody.java

+4-4
Original file line numberDiff line numberDiff line change
@@ -15,11 +15,11 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.message;
18+
package org.apache.eventmesh.common.protocol.http.body.message;
1919

20-
import com.webank.eventmesh.common.Constants;
21-
import com.webank.eventmesh.common.protocol.http.body.Body;
22-
import com.webank.eventmesh.common.protocol.http.common.ProtocolKey;
20+
import org.apache.eventmesh.common.Constants;
21+
import org.apache.eventmesh.common.protocol.http.body.Body;
22+
import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
2323
import org.apache.commons.lang3.time.DateFormatUtils;
2424

2525
import java.util.HashMap;

‎eventmesh-common/src/main/java/com/webank/eventmesh/common/protocol/http/body/message/SendMessageBatchV2RequestBody.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -15,9 +15,9 @@
1515
* limitations under the License.
1616
*/
1717

18-
package com.webank.eventmesh.common.protocol.http.body.message;
18+
package org.apache.eventmesh.common.protocol.http.body.message;
1919

20-
import com.webank.eventmesh.common.protocol.http.body.Body;
20+
import org.apache.eventmesh.common.protocol.http.body.Body;
2121
import org.apache.commons.collections4.MapUtils;
2222

2323
import java.util.HashMap;

0 commit comments

Comments
 (0)