Merge pull request #300 from liangyuanpeng/dev_refactor_package

[ISSUE #280]refactor runtime module package com.webank to org.apache close #280
apache · Apr 21, 2021 · 6f14791 · 6f14791
2 parents 337fbce + 43a2c32
commit 6f14791
Show file tree

Hide file tree

Showing 145 changed files with 704 additions and 704 deletions.
diff --git a/...in/controller/ClientManageController.java → ...in/controller/ClientManageController.java b/...in/controller/ClientManageController.java → ...in/controller/ClientManageController.java
@@ -15,15 +15,15 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.admin.controller;
-
-import com.webank.eventmesh.runtime.boot.EventMeshTCPServer;
-import com.webank.eventmesh.runtime.core.protocol.tcp.client.EventMeshTcp2Client;
-import com.webank.eventmesh.runtime.core.protocol.tcp.client.group.ClientGroupWrapper;
-import com.webank.eventmesh.runtime.core.protocol.tcp.client.group.ClientSessionGroupMapping;
-import com.webank.eventmesh.runtime.core.protocol.tcp.client.session.Session;
-import com.webank.eventmesh.runtime.constants.EventMeshConstants;
-import com.webank.eventmesh.common.protocol.tcp.UserAgent;
+package org.apache.eventmesh.runtime.admin.controller;
+
+import org.apache.eventmesh.runtime.boot.EventMeshTCPServer;
+import org.apache.eventmesh.runtime.core.protocol.tcp.client.EventMeshTcp2Client;
+import org.apache.eventmesh.runtime.core.protocol.tcp.client.group.ClientGroupWrapper;
+import org.apache.eventmesh.runtime.core.protocol.tcp.client.group.ClientSessionGroupMapping;
+import org.apache.eventmesh.runtime.core.protocol.tcp.client.session.Session;
+import org.apache.eventmesh.runtime.constants.EventMeshConstants;
+import org.apache.eventmesh.common.protocol.tcp.UserAgent;
 import com.sun.net.httpserver.HttpExchange;
 import com.sun.net.httpserver.HttpHandler;
 import com.sun.net.httpserver.HttpServer;

diff --git a/...esh/runtime/boot/AbrstractHTTPServer.java → ...esh/runtime/boot/AbrstractHTTPServer.java b/...esh/runtime/boot/AbrstractHTTPServer.java → ...esh/runtime/boot/AbrstractHTTPServer.java
@@ -15,24 +15,24 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.boot;
+package org.apache.eventmesh.runtime.boot;
 
 import com.google.common.base.Preconditions;
-import com.webank.eventmesh.runtime.core.protocol.http.async.AsyncContext;
-import com.webank.eventmesh.runtime.core.protocol.http.processor.inf.HttpRequestProcessor;
-import com.webank.eventmesh.runtime.util.EventMeshUtil;
-import com.webank.eventmesh.runtime.util.RemotingHelper;
-import com.webank.eventmesh.runtime.common.Pair;
-import com.webank.eventmesh.runtime.constants.EventMeshConstants;
-import com.webank.eventmesh.runtime.metrics.http.HTTPMetricsServer;
-import com.webank.eventmesh.common.ThreadPoolFactory;
-import com.webank.eventmesh.common.command.HttpCommand;
-import com.webank.eventmesh.common.protocol.http.body.Body;
-import com.webank.eventmesh.common.protocol.http.common.ProtocolKey;
-import com.webank.eventmesh.common.protocol.http.common.ProtocolVersion;
-import com.webank.eventmesh.common.protocol.http.common.EventMeshRetCode;
-import com.webank.eventmesh.common.protocol.http.common.RequestCode;
-import com.webank.eventmesh.common.protocol.http.header.Header;
+import org.apache.eventmesh.runtime.core.protocol.http.async.AsyncContext;
+import org.apache.eventmesh.runtime.core.protocol.http.processor.inf.HttpRequestProcessor;
+import org.apache.eventmesh.runtime.util.EventMeshUtil;
+import org.apache.eventmesh.runtime.util.RemotingHelper;
+import org.apache.eventmesh.runtime.common.Pair;
+import org.apache.eventmesh.runtime.constants.EventMeshConstants;
+import org.apache.eventmesh.runtime.metrics.http.HTTPMetricsServer;
+import org.apache.eventmesh.common.ThreadPoolFactory;
+import org.apache.eventmesh.common.command.HttpCommand;
+import org.apache.eventmesh.common.protocol.http.body.Body;
+import org.apache.eventmesh.common.protocol.http.common.ProtocolKey;
+import org.apache.eventmesh.common.protocol.http.common.ProtocolVersion;
+import org.apache.eventmesh.common.protocol.http.common.EventMeshRetCode;
+import org.apache.eventmesh.common.protocol.http.common.RequestCode;
+import org.apache.eventmesh.common.protocol.http.header.Header;
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.channel.*;
 import io.netty.channel.socket.SocketChannel;

diff --git a/.../runtime/boot/AbstractRemotingServer.java → .../runtime/boot/AbstractRemotingServer.java b/.../runtime/boot/AbstractRemotingServer.java → .../runtime/boot/AbstractRemotingServer.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.boot;
+package org.apache.eventmesh.runtime.boot;
 
-import com.webank.eventmesh.common.ThreadUtil;
+import org.apache.eventmesh.common.ThreadUtil;
 import io.netty.channel.EventLoopGroup;
 import io.netty.channel.nio.NioEventLoopGroup;
 import org.slf4j.Logger;

diff --git a/...esh/runtime/boot/EventMeshHTTPServer.java → ...esh/runtime/boot/EventMeshHTTPServer.java b/...esh/runtime/boot/EventMeshHTTPServer.java → ...esh/runtime/boot/EventMeshHTTPServer.java
@@ -15,21 +15,21 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.boot;
+package org.apache.eventmesh.runtime.boot;
 
 import com.google.common.eventbus.EventBus;
-import com.webank.eventmesh.runtime.core.consumergroup.ConsumerGroupConf;
-import com.webank.eventmesh.runtime.core.protocol.http.processor.*;
-import com.webank.eventmesh.runtime.core.protocol.http.processor.inf.Client;
-import com.webank.eventmesh.runtime.core.protocol.http.producer.ProducerManager;
-import com.webank.eventmesh.runtime.core.protocol.http.consumer.ConsumerManager;
-import com.webank.eventmesh.runtime.core.protocol.http.push.AbstractHTTPPushRequest;
-import com.webank.eventmesh.runtime.core.protocol.http.retry.HttpRetryer;
-import com.webank.eventmesh.runtime.common.ServiceState;
-import com.webank.eventmesh.runtime.configuration.EventMeshHTTPConfiguration;
-import com.webank.eventmesh.runtime.metrics.http.HTTPMetricsServer;
-import com.webank.eventmesh.common.ThreadPoolFactory;
-import com.webank.eventmesh.common.protocol.http.common.RequestCode;
+import org.apache.eventmesh.runtime.core.consumergroup.ConsumerGroupConf;
+import org.apache.eventmesh.runtime.core.protocol.http.processor.*;
+import org.apache.eventmesh.runtime.core.protocol.http.processor.inf.Client;
+import org.apache.eventmesh.runtime.core.protocol.http.producer.ProducerManager;
+import org.apache.eventmesh.runtime.core.protocol.http.consumer.ConsumerManager;
+import org.apache.eventmesh.runtime.core.protocol.http.push.AbstractHTTPPushRequest;
+import org.apache.eventmesh.runtime.core.protocol.http.retry.HttpRetryer;
+import org.apache.eventmesh.runtime.common.ServiceState;
+import org.apache.eventmesh.runtime.configuration.EventMeshHTTPConfiguration;
+import org.apache.eventmesh.runtime.metrics.http.HTTPMetricsServer;
+import org.apache.eventmesh.common.ThreadPoolFactory;
+import org.apache.eventmesh.common.protocol.http.common.RequestCode;
 
 import java.util.List;
 import java.util.concurrent.BlockingQueue;

diff --git a/...entmesh/runtime/boot/EventMeshServer.java → ...entmesh/runtime/boot/EventMeshServer.java b/...entmesh/runtime/boot/EventMeshServer.java → ...entmesh/runtime/boot/EventMeshServer.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.boot;
+package org.apache.eventmesh.runtime.boot;
 
-import com.webank.eventmesh.runtime.common.ServiceState;
-import com.webank.eventmesh.runtime.configuration.EventMeshTCPConfiguration;
-import com.webank.eventmesh.runtime.configuration.EventMeshHTTPConfiguration;
-import com.webank.eventmesh.runtime.constants.EventMeshConstants;
+import org.apache.eventmesh.runtime.common.ServiceState;
+import org.apache.eventmesh.runtime.configuration.EventMeshTCPConfiguration;
+import org.apache.eventmesh.runtime.configuration.EventMeshHTTPConfiguration;
+import org.apache.eventmesh.runtime.constants.EventMeshConstants;
 //import org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

diff --git a/...ntmesh/runtime/boot/EventMeshStartup.java → ...ntmesh/runtime/boot/EventMeshStartup.java b/...ntmesh/runtime/boot/EventMeshStartup.java → ...ntmesh/runtime/boot/EventMeshStartup.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.boot;
+package org.apache.eventmesh.runtime.boot;
 
-import com.webank.eventmesh.common.config.ConfigurationWraper;
-import com.webank.eventmesh.runtime.configuration.EventMeshTCPConfiguration;
-import com.webank.eventmesh.runtime.configuration.EventMeshHTTPConfiguration;
-import com.webank.eventmesh.runtime.constants.EventMeshConstants;
+import org.apache.eventmesh.common.config.ConfigurationWraper;
+import org.apache.eventmesh.runtime.configuration.EventMeshTCPConfiguration;
+import org.apache.eventmesh.runtime.configuration.EventMeshHTTPConfiguration;
+import org.apache.eventmesh.runtime.constants.EventMeshConstants;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

diff --git a/...mesh/runtime/boot/EventMeshTCPServer.java → ...mesh/runtime/boot/EventMeshTCPServer.java b/...mesh/runtime/boot/EventMeshTCPServer.java → ...mesh/runtime/boot/EventMeshTCPServer.java
@@ -15,20 +15,20 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.boot;
+package org.apache.eventmesh.runtime.boot;
 
 import com.google.common.util.concurrent.RateLimiter;
-import com.webank.eventmesh.runtime.core.protocol.tcp.client.EventMeshTcpConnectionHandler;
-import com.webank.eventmesh.runtime.core.protocol.tcp.client.EventMeshTcpExceptionHandler;
-import com.webank.eventmesh.runtime.core.protocol.tcp.client.EventMeshTcpMessageDispatcher;
-import com.webank.eventmesh.runtime.core.protocol.tcp.client.group.ClientSessionGroupMapping;
-import com.webank.eventmesh.runtime.core.protocol.tcp.client.session.push.retry.EventMeshTcpRetryer;
-import com.webank.eventmesh.runtime.util.EventMeshThreadFactoryImpl;
-import com.webank.eventmesh.runtime.admin.controller.ClientManageController;
-import com.webank.eventmesh.runtime.configuration.EventMeshTCPConfiguration;
-import com.webank.eventmesh.runtime.metrics.tcp.EventMeshTcpMonitor;
-import com.webank.eventmesh.common.ThreadPoolFactory;
-import com.webank.eventmesh.common.protocol.tcp.codec.Codec;
+import org.apache.eventmesh.runtime.core.protocol.tcp.client.EventMeshTcpConnectionHandler;
+import org.apache.eventmesh.runtime.core.protocol.tcp.client.EventMeshTcpExceptionHandler;
+import org.apache.eventmesh.runtime.core.protocol.tcp.client.EventMeshTcpMessageDispatcher;
+import org.apache.eventmesh.runtime.core.protocol.tcp.client.group.ClientSessionGroupMapping;
+import org.apache.eventmesh.runtime.core.protocol.tcp.client.session.push.retry.EventMeshTcpRetryer;
+import org.apache.eventmesh.runtime.util.EventMeshThreadFactoryImpl;
+import org.apache.eventmesh.runtime.admin.controller.ClientManageController;
+import org.apache.eventmesh.runtime.configuration.EventMeshTCPConfiguration;
+import org.apache.eventmesh.runtime.metrics.tcp.EventMeshTcpMonitor;
+import org.apache.eventmesh.common.ThreadPoolFactory;
+import org.apache.eventmesh.common.protocol.tcp.codec.Codec;
 import io.netty.bootstrap.ServerBootstrap;
 import io.netty.buffer.PooledByteBufAllocator;
 import io.netty.channel.*;

diff --git a/...tmesh/runtime/boot/SSLContextFactory.java → ...tmesh/runtime/boot/SSLContextFactory.java b/...tmesh/runtime/boot/SSLContextFactory.java → ...tmesh/runtime/boot/SSLContextFactory.java
@@ -1,6 +1,6 @@
-package com.webank.eventmesh.runtime.boot;
+package org.apache.eventmesh.runtime.boot;
 
-import com.webank.eventmesh.runtime.constants.EventMeshConstants;
+import org.apache.eventmesh.runtime.constants.EventMeshConstants;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

diff --git a/...webank/eventmesh/runtime/common/Pair.java → ...apache/eventmesh/runtime/common/Pair.java b/...webank/eventmesh/runtime/common/Pair.java → ...apache/eventmesh/runtime/common/Pair.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.common;
+package org.apache.eventmesh.runtime.common;
 
 public class Pair<T1, T2> {
     private T1 object1;

diff --git a/...ventmesh/runtime/common/ServiceState.java → ...ventmesh/runtime/common/ServiceState.java b/...ventmesh/runtime/common/ServiceState.java → ...ventmesh/runtime/common/ServiceState.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.common;
+package org.apache.eventmesh.runtime.common;
 
 public enum ServiceState {
 

diff --git a/...me/configuration/CommonConfiguration.java → ...me/configuration/CommonConfiguration.java b/...me/configuration/CommonConfiguration.java → ...me/configuration/CommonConfiguration.java
diff --git a/...me/configuration/ConfigurationWraper.java → ...me/configuration/ConfigurationWraper.java b/...me/configuration/ConfigurationWraper.java → ...me/configuration/ConfigurationWraper.java
@@ -17,7 +17,7 @@
 //
 //package com.webank.runtime.configuration;
 //
-//import com.webank.eventmesh.common.ThreadPoolFactory;
+//import org.apache.eventmesh.common.ThreadPoolFactory;
 //import org.apache.commons.lang3.StringUtils;
 //import org.slf4j.Logger;
 //import org.slf4j.LoggerFactory;

diff --git a/...iguration/EventMeshHTTPConfiguration.java → ...iguration/EventMeshHTTPConfiguration.java b/...iguration/EventMeshHTTPConfiguration.java → ...iguration/EventMeshHTTPConfiguration.java
@@ -15,12 +15,12 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.configuration;
+package org.apache.eventmesh.runtime.configuration;
 
 import com.google.common.base.Preconditions;
 import com.google.common.util.concurrent.RateLimiter;
-import com.webank.eventmesh.common.config.CommonConfiguration;
-import com.webank.eventmesh.common.config.ConfigurationWraper;
+import org.apache.eventmesh.common.config.CommonConfiguration;
+import org.apache.eventmesh.common.config.ConfigurationWraper;
 import org.apache.commons.lang3.StringUtils;
 
 public class EventMeshHTTPConfiguration extends CommonConfiguration {

diff --git a/...figuration/EventMeshTCPConfiguration.java → ...figuration/EventMeshTCPConfiguration.java b/...figuration/EventMeshTCPConfiguration.java → ...figuration/EventMeshTCPConfiguration.java
@@ -15,11 +15,11 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.configuration;
+package org.apache.eventmesh.runtime.configuration;
 
 import com.google.common.base.Preconditions;
-import com.webank.eventmesh.common.config.CommonConfiguration;
-import com.webank.eventmesh.common.config.ConfigurationWraper;
+import org.apache.eventmesh.common.config.CommonConfiguration;
+import org.apache.eventmesh.common.config.ConfigurationWraper;
 import org.apache.commons.lang3.StringUtils;
 
 public class EventMeshTCPConfiguration extends CommonConfiguration {

diff --git a/...sh/runtime/constants/DeFiBusConstant.java → ...sh/runtime/constants/DeFiBusConstant.java b/...sh/runtime/constants/DeFiBusConstant.java → ...sh/runtime/constants/DeFiBusConstant.java
@@ -1,4 +1,4 @@
-package com.webank.eventmesh.runtime.constants;
+package org.apache.eventmesh.runtime.constants;
 
 //TODO
 public class DeFiBusConstant {

diff --git a/...runtime/constants/EventMeshConstants.java → ...runtime/constants/EventMeshConstants.java b/...runtime/constants/EventMeshConstants.java → ...runtime/constants/EventMeshConstants.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.constants;
+package org.apache.eventmesh.runtime.constants;
 
 public class EventMeshConstants {
 

diff --git a/...h/runtime/constants/EventMeshVersion.java → ...h/runtime/constants/EventMeshVersion.java b/...h/runtime/constants/EventMeshVersion.java → ...h/runtime/constants/EventMeshVersion.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.constants;
+package org.apache.eventmesh.runtime.constants;
 
 public class EventMeshVersion {
 

diff --git a/...core/consumergroup/ConsumerGroupConf.java → ...core/consumergroup/ConsumerGroupConf.java b/...core/consumergroup/ConsumerGroupConf.java → ...core/consumergroup/ConsumerGroupConf.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.core.consumergroup;
+package org.apache.eventmesh.runtime.core.consumergroup;
 
 import com.google.common.collect.Maps;
 

diff --git a/...consumergroup/ConsumerGroupTopicConf.java → ...consumergroup/ConsumerGroupTopicConf.java b/...consumergroup/ConsumerGroupTopicConf.java → ...consumergroup/ConsumerGroupTopicConf.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.core.consumergroup;
+package org.apache.eventmesh.runtime.core.consumergroup;
 
 import com.google.common.collect.Maps;
 import com.google.common.collect.Sets;

diff --git a/...core/consumergroup/ProducerGroupConf.java → ...core/consumergroup/ProducerGroupConf.java b/...core/consumergroup/ProducerGroupConf.java → ...core/consumergroup/ProducerGroupConf.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.core.consumergroup;
+package org.apache.eventmesh.runtime.core.consumergroup;
 
 import java.util.Objects;
 

diff --git a/...ent/ConsumerGroupInstanceChangeEvent.java → ...ent/ConsumerGroupInstanceChangeEvent.java b/...ent/ConsumerGroupInstanceChangeEvent.java → ...ent/ConsumerGroupInstanceChangeEvent.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.core.consumergroup.event;
+package org.apache.eventmesh.runtime.core.consumergroup.event;
 
 public class ConsumerGroupInstanceChangeEvent {
 }
diff --git a/...rgroup/event/ConsumerGroupStateEvent.java → ...rgroup/event/ConsumerGroupStateEvent.java b/...rgroup/event/ConsumerGroupStateEvent.java → ...rgroup/event/ConsumerGroupStateEvent.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.core.consumergroup.event;
+package org.apache.eventmesh.runtime.core.consumergroup.event;
 
-import com.webank.eventmesh.runtime.core.consumergroup.ConsumerGroupConf;
+import org.apache.eventmesh.runtime.core.consumergroup.ConsumerGroupConf;
 
 public class ConsumerGroupStateEvent {
 

diff --git a/...nt/ConsumerGroupTopicConfChangeEvent.java → ...nt/ConsumerGroupTopicConfChangeEvent.java b/...nt/ConsumerGroupTopicConfChangeEvent.java → ...nt/ConsumerGroupTopicConfChangeEvent.java
@@ -15,9 +15,9 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.core.consumergroup.event;
+package org.apache.eventmesh.runtime.core.consumergroup.event;
 
-import com.webank.eventmesh.runtime.core.consumergroup.ConsumerGroupTopicConf;
+import org.apache.eventmesh.runtime.core.consumergroup.ConsumerGroupTopicConf;
 
 public class ConsumerGroupTopicConfChangeEvent {
 

diff --git a/...untime/core/plugin/MQConsumerWrapper.java → ...untime/core/plugin/MQConsumerWrapper.java b/...untime/core/plugin/MQConsumerWrapper.java → ...untime/core/plugin/MQConsumerWrapper.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.core.plugin;
+package org.apache.eventmesh.runtime.core.plugin;
 
-import com.webank.eventmesh.api.AbstractContext;
-import com.webank.eventmesh.api.consumer.MeshMQPushConsumer;
+import org.apache.eventmesh.api.AbstractContext;
+import org.apache.eventmesh.api.consumer.MeshMQPushConsumer;
 import io.openmessaging.api.AsyncMessageListener;
 import io.openmessaging.api.Message;
 import io.openmessaging.api.MessageListener;

diff --git a/...untime/core/plugin/MQProducerWrapper.java → ...untime/core/plugin/MQProducerWrapper.java b/...untime/core/plugin/MQProducerWrapper.java → ...untime/core/plugin/MQProducerWrapper.java
@@ -15,10 +15,10 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.core.plugin;
+package org.apache.eventmesh.runtime.core.plugin;
 
-import com.webank.eventmesh.api.RRCallback;
-import com.webank.eventmesh.api.producer.MeshMQProducer;
+import org.apache.eventmesh.api.RRCallback;
+import org.apache.eventmesh.api.producer.MeshMQProducer;
 import io.openmessaging.api.Message;
 import io.openmessaging.api.SendCallback;
 import org.slf4j.Logger;

diff --git a/...ntmesh/runtime/core/plugin/MQWrapper.java → ...ntmesh/runtime/core/plugin/MQWrapper.java b/...ntmesh/runtime/core/plugin/MQWrapper.java → ...ntmesh/runtime/core/plugin/MQWrapper.java
@@ -1,6 +1,6 @@
-package com.webank.eventmesh.runtime.core.plugin;
+package org.apache.eventmesh.runtime.core.plugin;
 
-import com.webank.eventmesh.runtime.constants.EventMeshConstants;
+import org.apache.eventmesh.runtime.constants.EventMeshConstants;
 import org.apache.commons.lang3.StringUtils;
 
 import java.util.concurrent.atomic.AtomicBoolean;

diff --git a/...ore/protocol/http/async/AsyncContext.java → ...ore/protocol/http/async/AsyncContext.java b/...ore/protocol/http/async/AsyncContext.java → ...ore/protocol/http/async/AsyncContext.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.core.protocol.http.async;
+package org.apache.eventmesh.runtime.core.protocol.http.async;
 
 import com.google.common.base.Preconditions;
 

diff --git a/.../protocol/http/async/CompleteHandler.java → .../protocol/http/async/CompleteHandler.java b/.../protocol/http/async/CompleteHandler.java → .../protocol/http/async/CompleteHandler.java
@@ -15,7 +15,7 @@
  * limitations under the License.
  */
 
-package com.webank.eventmesh.runtime.core.protocol.http.async;
+package org.apache.eventmesh.runtime.core.protocol.http.async;
 
 public interface CompleteHandler<T> {
     void onResponse(T t);