This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from c808ac76c Merge pull request #3365 from xwm1992/add-storage-standalone
new a715d6468 [ISSUE 3361] Add eventmesh-storage-rocketmq module
new 2aebd8867 update settings.gradle
new d56cba1aa update meta-inf file
new a5b56134c Merge pull request #3368 from xwm1992/add-storage-rocketmq
The 3661 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../eventmesh-storage-rocketmq}/build.gradle | 4 +--
.../eventmesh-storage-rocketmq}/gradle.properties | 2 +-
.../storage}/rocketmq/admin/RocketMQAdmin.java | 4 +--
.../rocketmq/admin/RocketMQAdminAdaptor.java | 2 +-
.../storage}/rocketmq/admin/command/Command.java | 4 +--
.../cloudevent/RocketMQMessageFactory.java | 8 ++---
.../impl/RocketMQBinaryMessageReader.java | 2 +-
.../rocketmq/cloudevent/impl/RocketMQHeaders.java | 2 +-
.../cloudevent/impl/RocketMQMessageWriter.java | 2 +-
.../rocketmq/common/EventMeshConstants.java | 2 +-
.../storage}/rocketmq/config/ClientConfig.java | 4 +--
.../rocketmq/config/ClientConfiguration.java | 2 +-
.../rocketmq/consumer/PushConsumerImpl.java | 38 +++++++++++-----------
.../rocketmq/consumer/RocketMQConsumerImpl.java | 4 +--
.../storage}/rocketmq/domain/NonStandardKeys.java | 2 +-
.../exception/RMQMessageFormatException.java | 6 ++--
.../rocketmq/exception/RMQTimeoutException.java | 6 ++--
.../patch/EventMeshConsumeConcurrentlyContext.java | 2 +-
.../patch/EventMeshConsumeConcurrentlyStatus.java | 2 +-
.../EventMeshMessageListenerConcurrently.java | 2 +-
.../rocketmq/producer/AbstractProducer.java | 34 +++++++++----------
.../storage}/rocketmq/producer/ProducerImpl.java | 14 ++++----
.../rocketmq/producer/RocketMQProducerImpl.java | 6 ++--
.../StorageResourceServiceRocketmqImpl.java} | 4 +--
.../storage}/rocketmq/utils/BeanUtils.java | 2 +-
.../storage}/rocketmq/utils/CloudEventUtils.java | 2 +-
.../eventmesh/storage}/rocketmq/utils/OMSUtil.java | 2 +-
.../ConsumeMessageConcurrentlyService.java | 2 +-
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 6 +---
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
...he.eventmesh.api.storage.StorageResourceService | 6 +---
.../src/main/resources/rocketmq-client.properties | 0
.../producer/DefaultProducerImplTest.java | 0
.../rocketmq/config/ClientConfigurationTest.java | 12 +++----
.../rocketmq/consumer/PushConsumerImplTest.java | 4 +--
.../apache/rocketmq/producer/ProducerImplTest.java | 8 ++---
.../rocketmq/promise/DefaultPromiseTest.java | 0
.../org/apache/rocketmq/utils/BeanUtilsTest.java | 6 ++--
.../org.apache.io.openmessaging.producer.Producer | 2 +-
.../src/test/resources/rocketmq-client.properties | 0
settings.gradle | 1 +
42 files changed, 104 insertions(+), 111 deletions(-)
copy {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage/eventmesh-storage-rocketmq}/build.gradle (93%)
copy {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage/eventmesh-storage-rocketmq}/gradle.properties (95%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/admin/RocketMQAdmin.java
(97%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/admin/RocketMQAdminAdaptor.java
(97%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/admin/command/Command.java
(93%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/cloudevent/RocketMQMessageFactory.java
(88%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
(96%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/cloudevent/impl/RocketMQHeaders.java
(95%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/cloudevent/impl/RocketMQMessageWriter.java
(97%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/common/EventMeshConstants.java
(94%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/config/ClientConfig.java
(97%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/config/ClientConfiguration.java
(98%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/consumer/PushConsumerImpl.java
(88%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/consumer/RocketMQConsumerImpl.java
(96%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/domain/NonStandardKeys.java
(95%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/exception/RMQMessageFormatException.java
(83%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/exception/RMQTimeoutException.java
(83%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
(96%)
copy {eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime =>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq}/patch/EventMeshConsumeConcurrentlyStatus.java
(95%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/patch/EventMeshMessageListenerConcurrently.java
(98%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/producer/AbstractProducer.java
(83%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/producer/ProducerImpl.java
(93%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/producer/RocketMQProducerImpl.java
(94%)
copy
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/resource/StandaloneStorageResourceService.java
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/storage/StorageResourceServiceRocketmqImpl.java}
(87%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/utils/BeanUtils.java
(99%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/utils/CloudEventUtils.java
(99%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/utils/OMSUtil.java
(95%)
copy {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage/eventmesh-storage-rocketmq}/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
(99%)
copy eventmesh-connector-plugin/eventmesh-connector-kafka/gradle.properties =>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(91%)
copy {eventmesh-connector-plugin/eventmesh-connector-knative =>
eventmesh-storage/eventmesh-storage-rocketmq}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(91%)
copy {eventmesh-connector-plugin/eventmesh-connector-knative =>
eventmesh-storage/eventmesh-storage-rocketmq}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(91%)
copy eventmesh-connector-plugin/eventmesh-connector-kafka/gradle.properties =>
eventmesh-storage/eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
(89%)
copy {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage/eventmesh-storage-rocketmq}/src/main/resources/rocketmq-client.properties
(100%)
copy {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage/eventmesh-storage-rocketmq}/src/test/java/org/apache/eventmesh/producer/DefaultProducerImplTest.java
(100%)
copy
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage}/rocketmq/config/ClientConfigurationTest.java
(83%)
copy {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage/eventmesh-storage-rocketmq}/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
(95%)
copy {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage/eventmesh-storage-rocketmq}/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
(94%)
copy {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage/eventmesh-storage-rocketmq}/src/test/java/org/apache/rocketmq/promise/DefaultPromiseTest.java
(100%)
copy {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage/eventmesh-storage-rocketmq}/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
(95%)
copy {eventmesh-connector-plugin/eventmesh-connector-kafka =>
eventmesh-storage/eventmesh-storage-rocketmq}/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
(93%)
copy {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage/eventmesh-storage-rocketmq}/src/test/resources/rocketmq-client.properties
(100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
