You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by bi...@apache.org on 2021/04/21 09:46:45 UTC
[incubator-eventmesh] branch develop updated: Refactor
'eventmesh-connector-rocketmq' package name to org.apache
This is an automated email from the ASF dual-hosted git repository.
bingyam pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/develop by this push:
new af6c352 Refactor 'eventmesh-connector-rocketmq' package name to org.apache
new d463f8a Merge pull request #288 from sunxi92/fix
af6c352 is described below
commit af6c352747482b4038f24db983ddd323a2e3a6a0
Author: sunxi <su...@163.com>
AuthorDate: Mon Apr 19 20:33:39 2021 +0800
Refactor 'eventmesh-connector-rocketmq' package name to org.apache
---
.../connector/rocketmq/MessagingAccessPointImpl.java | 6 +++---
.../eventmesh/connector/rocketmq/common/Constants.java | 2 +-
.../connector/rocketmq/common/EventMeshConstants.java | 2 +-
.../connector/rocketmq/config/ClientConfig.java | 4 ++--
.../connector/rocketmq/config/ClientConfiguration.java | 2 +-
.../connector/rocketmq/config/ConfigurationWraper.java | 2 +-
.../connector/rocketmq/consumer/PushConsumerImpl.java | 18 +++++++++---------
.../rocketmq/consumer/RocketMQConsumerImpl.java | 14 +++++++-------
.../connector/rocketmq/domain/ConsumeRequest.java | 2 +-
.../connector/rocketmq/domain/NonStandardKeys.java | 2 +-
.../connector/rocketmq/domain/RocketMQConstants.java | 2 +-
.../patch/EventMeshConsumeConcurrentlyContext.java | 2 +-
.../patch/EventMeshConsumeConcurrentlyStatus.java | 2 +-
.../patch/EventMeshMessageListenerConcurrently.java | 2 +-
.../rocketmq/producer/AbstractOMSProducer.java | 8 ++++----
.../connector/rocketmq/producer/ProducerImpl.java | 4 ++--
.../rocketmq/producer/RocketMQProducerImpl.java | 8 ++++----
.../connector/rocketmq/promise/DefaultPromise.java | 2 +-
.../connector/rocketmq/promise/FutureState.java | 2 +-
.../eventmesh/connector/rocketmq/utils/BeanUtils.java | 2 +-
.../eventmesh/connector/rocketmq/utils/OMSUtil.java | 2 +-
.../consumer/ConsumeMessageConcurrentlyService.java | 2 +-
...om.webank.eventmesh.api.consumer.MeshMQPushConsumer | 1 -
.../com.webank.eventmesh.api.producer.MeshMQProducer | 1 -
...rg.apache.eventmesh.api.consumer.MeshMQPushConsumer | 1 +
.../org.apache.eventmesh.api.producer.MeshMQProducer | 1 +
.../rocketmq/consumer/PushConsumerImplTest.java | 6 +++---
.../apache}/rocketmq/producer/ProducerImplTest.java | 4 ++--
.../apache}/rocketmq/promise/DefaultPromiseTest.java | 0
.../{ => org/apache}/rocketmq/utils/BeanUtilsTest.java | 8 ++++----
.../services/io.openmessaging.MessagingAccessPoint | 1 -
.../services/io.openmessaging.producer.Producer | 1 -
.../org.apache.io.openmessaging.MessagingAccessPoint | 1 +
.../org.apache.io.openmessaging.producer.Producer | 1 +
34 files changed, 59 insertions(+), 59 deletions(-)
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/MessagingAccessPointImpl.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/MessagingAccessPointImpl.java
similarity index 93%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/MessagingAccessPointImpl.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/MessagingAccessPointImpl.java
index 79d6a5f..9c3348e 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/MessagingAccessPointImpl.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/MessagingAccessPointImpl.java
@@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq;
+package org.apache.eventmesh.connector.rocketmq;
-import com.webank.eventmesh.connector.rocketmq.producer.ProducerImpl;
-import com.webank.eventmesh.connector.rocketmq.consumer.PushConsumerImpl;
+import org.apache.eventmesh.connector.rocketmq.producer.ProducerImpl;
+import org.apache.eventmesh.connector.rocketmq.consumer.PushConsumerImpl;
import io.openmessaging.api.Consumer;
import io.openmessaging.api.MessagingAccessPoint;
import io.openmessaging.api.Producer;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/common/Constants.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java
similarity index 94%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/common/Constants.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java
index 969359d..1fe247f 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/common/Constants.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java
@@ -1,4 +1,4 @@
-package com.webank.eventmesh.connector.rocketmq.common;
+package org.apache.eventmesh.connector.rocketmq.common;
public class Constants {
public static final String BROADCAST_PREFIX = "broadcast-";
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/common/EventMeshConstants.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/EventMeshConstants.java
similarity index 98%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/common/EventMeshConstants.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/EventMeshConstants.java
index f3a1267..c6501e3 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/common/EventMeshConstants.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/EventMeshConstants.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.common;
+package org.apache.eventmesh.connector.rocketmq.common;
public class EventMeshConstants {
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/config/ClientConfig.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfig.java
similarity index 97%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/config/ClientConfig.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfig.java
index 9a0ebac..d4e53fd 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/config/ClientConfig.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfig.java
@@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.config;
+package org.apache.eventmesh.connector.rocketmq.config;
-import com.webank.eventmesh.connector.rocketmq.domain.NonStandardKeys;
+import org.apache.eventmesh.connector.rocketmq.domain.NonStandardKeys;
import io.openmessaging.api.OMSBuiltinKeys;
public class ClientConfig implements OMSBuiltinKeys, NonStandardKeys {
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/config/ClientConfiguration.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
similarity index 99%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/config/ClientConfiguration.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
index 9277678..83328bf 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/config/ClientConfiguration.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.config;
+package org.apache.eventmesh.connector.rocketmq.config;
import com.google.common.base.Preconditions;
import org.apache.commons.lang3.StringUtils;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/config/ConfigurationWraper.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ConfigurationWraper.java
similarity index 97%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/config/ConfigurationWraper.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ConfigurationWraper.java
index 72ebf6d..065178e 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/config/ConfigurationWraper.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ConfigurationWraper.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.config;
+package org.apache.eventmesh.connector.rocketmq.config;
import com.webank.eventmesh.common.ThreadPoolFactory;
import org.apache.commons.lang3.StringUtils;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
similarity index 95%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
index 274a6a9..3c776c4 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
@@ -14,17 +14,17 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.consumer;
+package org.apache.eventmesh.connector.rocketmq.consumer;
import com.webank.eventmesh.common.Constants;
-import com.webank.eventmesh.connector.rocketmq.common.EventMeshConstants;
-import com.webank.eventmesh.connector.rocketmq.domain.NonStandardKeys;
-import com.webank.eventmesh.connector.rocketmq.patch.EventMeshConsumeConcurrentlyContext;
-import com.webank.eventmesh.connector.rocketmq.patch.EventMeshConsumeConcurrentlyStatus;
-import com.webank.eventmesh.connector.rocketmq.patch.EventMeshMessageListenerConcurrently;
-import com.webank.eventmesh.connector.rocketmq.utils.BeanUtils;
-import com.webank.eventmesh.connector.rocketmq.utils.OMSUtil;
-import com.webank.eventmesh.connector.rocketmq.config.ClientConfig;
+import org.apache.eventmesh.connector.rocketmq.common.EventMeshConstants;
+import org.apache.eventmesh.connector.rocketmq.domain.NonStandardKeys;
+import org.apache.eventmesh.connector.rocketmq.patch.EventMeshConsumeConcurrentlyContext;
+import org.apache.eventmesh.connector.rocketmq.patch.EventMeshConsumeConcurrentlyStatus;
+import org.apache.eventmesh.connector.rocketmq.patch.EventMeshMessageListenerConcurrently;
+import org.apache.eventmesh.connector.rocketmq.utils.BeanUtils;
+import org.apache.eventmesh.connector.rocketmq.utils.OMSUtil;
+import org.apache.eventmesh.connector.rocketmq.config.ClientConfig;
import com.webank.eventmesh.api.AbstractContext;
import io.openmessaging.api.*;
import io.openmessaging.api.exception.OMSRuntimeException;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
similarity index 93%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
index a39d045..76c7989 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
@@ -15,16 +15,16 @@
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.consumer;
+package org.apache.eventmesh.connector.rocketmq.consumer;
import com.webank.eventmesh.api.AbstractContext;
import com.webank.eventmesh.api.consumer.MeshMQPushConsumer;
-import com.webank.eventmesh.connector.rocketmq.common.Constants;
-import com.webank.eventmesh.connector.rocketmq.common.EventMeshConstants;
-import com.webank.eventmesh.connector.rocketmq.config.ClientConfiguration;
-import com.webank.eventmesh.connector.rocketmq.config.ConfigurationWraper;
-import com.webank.eventmesh.connector.rocketmq.patch.EventMeshConsumeConcurrentlyContext;
-import com.webank.eventmesh.connector.rocketmq.utils.OMSUtil;
+import org.apache.eventmesh.connector.rocketmq.common.Constants;
+import org.apache.eventmesh.connector.rocketmq.common.EventMeshConstants;
+import org.apache.eventmesh.connector.rocketmq.config.ClientConfiguration;
+import org.apache.eventmesh.connector.rocketmq.config.ConfigurationWraper;
+import org.apache.eventmesh.connector.rocketmq.patch.EventMeshConsumeConcurrentlyContext;
+import org.apache.eventmesh.connector.rocketmq.utils.OMSUtil;
import io.openmessaging.api.*;
import org.apache.rocketmq.client.impl.consumer.ConsumeMessageConcurrentlyService;
import org.apache.rocketmq.client.impl.consumer.ConsumeMessageService;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/domain/ConsumeRequest.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/ConsumeRequest.java
similarity index 97%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/domain/ConsumeRequest.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/ConsumeRequest.java
index 7aefcda..a95accf 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/domain/ConsumeRequest.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/ConsumeRequest.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.domain;
+package org.apache.eventmesh.connector.rocketmq.domain;
import org.apache.rocketmq.client.impl.consumer.ProcessQueue;
import org.apache.rocketmq.common.message.MessageExt;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/domain/NonStandardKeys.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
similarity index 96%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
index 453c1ec..091ad86 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.domain;
+package org.apache.eventmesh.connector.rocketmq.domain;
public interface NonStandardKeys {
String CONSUMER_GROUP = "rmq.consumer.group";
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/domain/RocketMQConstants.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/RocketMQConstants.java
similarity index 94%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/domain/RocketMQConstants.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/RocketMQConstants.java
index 181f89b..60be685 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/domain/RocketMQConstants.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/RocketMQConstants.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.domain;
+package org.apache.eventmesh.connector.rocketmq.domain;
public interface RocketMQConstants {
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
similarity index 96%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
index f0af34a..39e8e06 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.patch;
+package org.apache.eventmesh.connector.rocketmq.patch;
import com.webank.eventmesh.api.AbstractContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
similarity index 95%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
index 2b505b0..468b14f 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.patch;
+package org.apache.eventmesh.connector.rocketmq.patch;
public enum EventMeshConsumeConcurrentlyStatus {
/**
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
similarity index 98%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
index 854fa04..9e4fee4 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.patch;
+package org.apache.eventmesh.connector.rocketmq.patch;
import org.apache.commons.collections4.CollectionUtils;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/producer/AbstractOMSProducer.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/AbstractOMSProducer.java
similarity index 96%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/producer/AbstractOMSProducer.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/AbstractOMSProducer.java
index b47587f..df20c3c 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/producer/AbstractOMSProducer.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/AbstractOMSProducer.java
@@ -14,11 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.producer;
+package org.apache.eventmesh.connector.rocketmq.producer;
-import com.webank.eventmesh.connector.rocketmq.utils.BeanUtils;
-import com.webank.eventmesh.connector.rocketmq.utils.OMSUtil;
-import com.webank.eventmesh.connector.rocketmq.config.ClientConfig;
+import org.apache.eventmesh.connector.rocketmq.utils.BeanUtils;
+import org.apache.eventmesh.connector.rocketmq.utils.OMSUtil;
+import org.apache.eventmesh.connector.rocketmq.config.ClientConfig;
import io.openmessaging.api.exception.OMSRuntimeException;
import io.openmessaging.api.exception.OMSMessageFormatException;
import io.openmessaging.api.exception.OMSTimeOutException;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/producer/ProducerImpl.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
similarity index 97%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/producer/ProducerImpl.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
index 89591df..39a924a 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/producer/ProducerImpl.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
@@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.producer;
+package org.apache.eventmesh.connector.rocketmq.producer;
-import com.webank.eventmesh.connector.rocketmq.utils.OMSUtil;
+import org.apache.eventmesh.connector.rocketmq.utils.OMSUtil;
import io.openmessaging.api.*;
import io.openmessaging.api.exception.OMSRuntimeException;
import org.apache.rocketmq.common.message.MessageClientIDSetter;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
similarity index 95%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
index 0618545..f37fb8a 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
@@ -15,13 +15,13 @@
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.producer;
+package org.apache.eventmesh.connector.rocketmq.producer;
import com.webank.eventmesh.api.RRCallback;
import com.webank.eventmesh.api.producer.MeshMQProducer;
-import com.webank.eventmesh.connector.rocketmq.common.EventMeshConstants;
-import com.webank.eventmesh.connector.rocketmq.config.ClientConfiguration;
-import com.webank.eventmesh.connector.rocketmq.config.ConfigurationWraper;
+import org.apache.eventmesh.connector.rocketmq.common.EventMeshConstants;
+import org.apache.eventmesh.connector.rocketmq.config.ClientConfiguration;
+import org.apache.eventmesh.connector.rocketmq.config.ConfigurationWraper;
import io.openmessaging.api.*;
import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/promise/DefaultPromise.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/DefaultPromise.java
similarity index 99%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/promise/DefaultPromise.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/DefaultPromise.java
index 8469db4..acd9c62 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/promise/DefaultPromise.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/DefaultPromise.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.promise;
+package org.apache.eventmesh.connector.rocketmq.promise;
import io.openmessaging.api.Future;
import io.openmessaging.api.FutureListener;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/promise/FutureState.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/FutureState.java
similarity index 95%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/promise/FutureState.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/FutureState.java
index 9903953..1f364a8 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/promise/FutureState.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/FutureState.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.promise;
+package org.apache.eventmesh.connector.rocketmq.promise;
public enum FutureState {
/**
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/utils/BeanUtils.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/BeanUtils.java
similarity index 99%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/utils/BeanUtils.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/BeanUtils.java
index e55c336..67c3349 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/utils/BeanUtils.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/BeanUtils.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.utils;
+package org.apache.eventmesh.connector.rocketmq.utils;
import org.apache.commons.lang3.StringUtils;
import org.apache.rocketmq.client.log.ClientLogger;
diff --git a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/utils/OMSUtil.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/OMSUtil.java
similarity index 99%
rename from eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/utils/OMSUtil.java
rename to eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/OMSUtil.java
index d087acc..3f2503b 100644
--- a/eventmesh-connector-rocketmq/src/main/java/com/webank/eventmesh/connector/rocketmq/utils/OMSUtil.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/OMSUtil.java
@@ -14,7 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package com.webank.eventmesh.connector.rocketmq.utils;
+package org.apache.eventmesh.connector.rocketmq.utils;
import com.webank.eventmesh.common.Constants;
import io.openmessaging.api.Message;
diff --git a/eventmesh-connector-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java b/eventmesh-connector-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
index b2d116d..89e98db 100644
--- a/eventmesh-connector-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
+++ b/eventmesh-connector-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
@@ -16,7 +16,7 @@
*/
package org.apache.rocketmq.client.impl.consumer;
-import com.webank.eventmesh.connector.rocketmq.patch.EventMeshConsumeConcurrentlyContext;
+import org.apache.eventmesh.connector.rocketmq.patch.EventMeshConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
diff --git a/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/com.webank.eventmesh.api.consumer.MeshMQPushConsumer b/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/com.webank.eventmesh.api.consumer.MeshMQPushConsumer
deleted file mode 100644
index 8e4788c..0000000
--- a/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/com.webank.eventmesh.api.consumer.MeshMQPushConsumer
+++ /dev/null
@@ -1 +0,0 @@
-com.webank.eventmesh.connector.rocketmq.consumer.RocketMQConsumerImpl
\ No newline at end of file
diff --git a/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/com.webank.eventmesh.api.producer.MeshMQProducer b/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/com.webank.eventmesh.api.producer.MeshMQProducer
deleted file mode 100644
index 6fcd066..0000000
--- a/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/com.webank.eventmesh.api.producer.MeshMQProducer
+++ /dev/null
@@ -1 +0,0 @@
-com.webank.eventmesh.connector.rocketmq.producer.RocketMQProducerImpl
\ No newline at end of file
diff --git a/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.consumer.MeshMQPushConsumer b/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.consumer.MeshMQPushConsumer
new file mode 100644
index 0000000..bce30c2
--- /dev/null
+++ b/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.consumer.MeshMQPushConsumer
@@ -0,0 +1 @@
+org.apache.eventmesh.connector.rocketmq.consumer.RocketMQConsumerImpl
\ No newline at end of file
diff --git a/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer b/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
new file mode 100644
index 0000000..f6c9d02
--- /dev/null
+++ b/eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
@@ -0,0 +1 @@
+org.apache.eventmesh.connector.rocketmq.producer.RocketMQProducerImpl
\ No newline at end of file
diff --git a/eventmesh-connector-rocketmq/src/test/java/rocketmq/consumer/PushConsumerImplTest.java b/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
similarity index 95%
rename from eventmesh-connector-rocketmq/src/test/java/rocketmq/consumer/PushConsumerImplTest.java
rename to eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
index 630cdad..3ec8841 100644
--- a/eventmesh-connector-rocketmq/src/test/java/rocketmq/consumer/PushConsumerImplTest.java
+++ b/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
@@ -14,10 +14,10 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package rocketmq.consumer;
+package org.apache.rocketmq.consumer;
-import com.webank.eventmesh.connector.rocketmq.consumer.PushConsumerImpl;
-import com.webank.eventmesh.connector.rocketmq.domain.NonStandardKeys;
+import org.apache.eventmesh.connector.rocketmq.consumer.PushConsumerImpl;
+import org.apache.eventmesh.connector.rocketmq.domain.NonStandardKeys;
import io.openmessaging.api.*;
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
import org.apache.rocketmq.client.consumer.listener.MessageListenerConcurrently;
diff --git a/eventmesh-connector-rocketmq/src/test/java/rocketmq/producer/ProducerImplTest.java b/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
similarity index 97%
rename from eventmesh-connector-rocketmq/src/test/java/rocketmq/producer/ProducerImplTest.java
rename to eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
index b053213..e5dfaeb 100644
--- a/eventmesh-connector-rocketmq/src/test/java/rocketmq/producer/ProducerImplTest.java
+++ b/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
@@ -14,9 +14,9 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package rocketmq.producer;
+package org.apache.rocketmq.producer;
-import com.webank.eventmesh.connector.rocketmq.producer.AbstractOMSProducer;
+import org.apache.eventmesh.connector.rocketmq.producer.AbstractOMSProducer;
import io.openmessaging.api.OMS;
import io.openmessaging.api.MessagingAccessPoint;
import io.openmessaging.api.Producer;
diff --git a/eventmesh-connector-rocketmq/src/test/java/rocketmq/promise/DefaultPromiseTest.java b/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/promise/DefaultPromiseTest.java
similarity index 100%
rename from eventmesh-connector-rocketmq/src/test/java/rocketmq/promise/DefaultPromiseTest.java
rename to eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/promise/DefaultPromiseTest.java
diff --git a/eventmesh-connector-rocketmq/src/test/java/rocketmq/utils/BeanUtilsTest.java b/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
similarity index 94%
rename from eventmesh-connector-rocketmq/src/test/java/rocketmq/utils/BeanUtilsTest.java
rename to eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
index b5a221e..5cb3a87 100644
--- a/eventmesh-connector-rocketmq/src/test/java/rocketmq/utils/BeanUtilsTest.java
+++ b/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
@@ -14,11 +14,11 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
-package rocketmq.utils;
+package org.apache.rocketmq.utils;
-import com.webank.eventmesh.connector.rocketmq.config.ClientConfig;
-import com.webank.eventmesh.connector.rocketmq.domain.NonStandardKeys;
-import com.webank.eventmesh.connector.rocketmq.utils.BeanUtils;
+import org.apache.eventmesh.connector.rocketmq.config.ClientConfig;
+import org.apache.eventmesh.connector.rocketmq.domain.NonStandardKeys;
+import org.apache.eventmesh.connector.rocketmq.utils.BeanUtils;
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
diff --git a/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/io.openmessaging.MessagingAccessPoint b/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/io.openmessaging.MessagingAccessPoint
deleted file mode 100644
index 9174f1a..0000000
--- a/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/io.openmessaging.MessagingAccessPoint
+++ /dev/null
@@ -1 +0,0 @@
-com.webank.eventmesh.connector.rocketmq.MessagingAccessPointImpl
\ No newline at end of file
diff --git a/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/io.openmessaging.producer.Producer b/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/io.openmessaging.producer.Producer
deleted file mode 100644
index 7cfe963..0000000
--- a/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/io.openmessaging.producer.Producer
+++ /dev/null
@@ -1 +0,0 @@
-com.webank.eventmesh.connector.rocketmq.producer.ProducerImpl
\ No newline at end of file
diff --git a/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.MessagingAccessPoint b/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.MessagingAccessPoint
new file mode 100644
index 0000000..7347e69
--- /dev/null
+++ b/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.MessagingAccessPoint
@@ -0,0 +1 @@
+org.apache.eventmesh.connector.rocketmq.MessagingAccessPointImpl
\ No newline at end of file
diff --git a/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer b/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
new file mode 100644
index 0000000..5ea8a18
--- /dev/null
+++ b/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
@@ -0,0 +1 @@
+org.apache.eventmesh.connector.rocketmq.producer.ProducerImpl
\ No newline at end of file
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org