This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from d4e58ea22 Merge pull request #3337 from mxsm/eventmesh-3336
new 5808475fa rename modules name
new 7535ba197 rename eventmesh-storage-kafka packages
new a1da88e58 rename eventmesh-storage-knative packages
new 839be80a0 rename eventmesh-storage-pravega packages
new b2961deb4 rename eventmesh-storage-pulsar packages
new 34755f1aa rename eventmesh-storage-rabbitmq packages
new 0b6b5e780 rename eventmesh-storage-redis packages
new 66fab7fb0 rename eventmesh-storage-rocketmq packages
new 10d81d331 rename eventmesh-storage-standalone packages
new 72ad42eae rename ConnectorResourceService to StorgeResourceService
new 58884d107 rename ConnectorPluginFactory to StoragePluginFactory
new 3083719a0 rename config file
new 62c172b0e fix project can‘t start because of modify eventmesh-storage
module
new 5ea6b8025 fix test case code style
new 8329218b1 rename README to README.md
new 47833bb8f modify doc
new 1cbe15ed6 Merge pull request #3354 from mxsm/eventmesh-3353
The 3641 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:
build.gradle | 4 +--
docs/en/design-document/08-spi.md | 8 ++---
docs/zh/design-document/08-spi.md | 10 +++----
.../eventmesh-admin-rocketmq/build.gradle | 4 +--
.../common/config/CommonConfiguration.java | 3 ++
.../common/config/CommonConfigurationTest.java | 1 +
.../src/test/resources/configuration.properties | 1 +
eventmesh-connectors/{README => README.md} | 0
eventmesh-examples/build.gradle | 2 +-
eventmesh-runtime/build.gradle | 4 +--
eventmesh-runtime/conf/eventmesh.properties | 5 +++-
.../admin/controller/ClientManageController.java | 4 +--
.../eventmesh/runtime/boot/EventMeshServer.java | 10 +++----
.../runtime/connector/ConnectorResource.java | 14 ++++-----
.../runtime/core/plugin/MQAdminWrapper.java | 4 +--
.../runtime/core/plugin/MQConsumerWrapper.java | 4 +--
.../runtime/core/plugin/MQProducerWrapper.java | 4 +--
.../protocol/grpc/consumer/EventMeshConsumer.java | 4 +--
.../protocol/grpc/producer/EventMeshProducer.java | 3 +-
.../protocol/http/consumer/EventMeshConsumer.java | 6 ++--
.../protocol/http/producer/EventMeshProducer.java | 2 +-
.../tcp/client/group/ClientGroupWrapper.java | 9 ++----
.../StorageResource.java} | 32 ++++++++++----------
.../controller/ClientManageControllerTest.java | 1 +
.../runtime/boot/EventMeshServerTest.java | 1 +
.../EventMeshGrpcConfigurationTest.java | 3 +-
.../EventMeshHTTPConfigurationTest.java | 3 +-
.../EventMeshTCPConfigurationTest.java | 4 ++-
.../eventmesh/runtime/util/EventMeshUtilTest.java | 2 +-
.../src/test/resources/configuration.properties | 1 +
eventmesh-starter/build.gradle | 4 +--
...ventmesh.api.connector.ConnectorResourceService | 16 ----------
...ventmesh.api.connector.ConnectorResourceService | 16 ----------
...ventmesh.api.connector.ConnectorResourceService | 16 ----------
...ventmesh.api.connector.ConnectorResourceService | 16 ----------
...ventmesh.api.connector.ConnectorResourceService | 16 ----------
.../ConnectorResourceServiceRocketmqImpl.java | 33 ---------------------
...ventmesh.api.connector.ConnectorResourceService | 16 ----------
.../org.apache.eventmesh.api.consumer.Consumer | 16 ----------
.../org.apache.eventmesh.api.producer.Producer | 16 ----------
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 16 ----------
...ventmesh.api.connector.ConnectorResourceService | 16 ----------
.../org.apache.eventmesh.api.consumer.Consumer | 16 ----------
.../org.apache.eventmesh.api.producer.Producer | 16 ----------
.../build.gradle | 0
.../gradle.properties | 0
.../org/apache/eventmesh/api/AbstractContext.java | 0
.../apache/eventmesh/api/AsyncConsumeContext.java | 0
.../org/apache/eventmesh/api/EventListener.java | 0
.../org/apache/eventmesh/api/EventMeshAction.java | 0
.../api/EventMeshAsyncConsumeContext.java | 0
.../java/org/apache/eventmesh/api/LifeCycle.java | 0
.../apache/eventmesh/api/RequestReplyCallback.java | 0
.../org/apache/eventmesh/api/SendCallback.java | 0
.../java/org/apache/eventmesh/api/SendResult.java | 0
.../java/org/apache/eventmesh/api/admin/Admin.java | 0
.../eventmesh/api/admin/TopicProperties.java | 0
.../apache/eventmesh/api/consumer/Consumer.java | 0
.../api/exception/ConnectorRuntimeException.java | 0
.../api/exception/OnExceptionContext.java | 0
.../api/factory/StoragePluginFactory.java} | 4 +--
.../apache/eventmesh/api/producer/Producer.java | 0
.../api/storage/StorageResourceService.java} | 4 +--
.../build.gradle | 4 +--
.../gradle.properties | 0
.../eventmesh/storage}/kafka/common/Constants.java | 2 +-
.../storage}/kafka/common/EventMeshConstants.java | 2 +-
.../storage}/kafka/config/ClientConfiguration.java | 2 +-
.../storage}/kafka/consumer/ConsumerImpl.java | 4 +--
.../storage}/kafka/consumer/KafkaConsumerImpl.java | 4 +--
.../kafka/consumer/KafkaConsumerRunner.java | 4 +--
.../storage}/kafka/producer/KafkaProducerImpl.java | 4 +--
.../storage}/kafka/producer/ProducerImpl.java | 2 +-
.../storage/StorageResourceServiceKafkaImpl.java} | 6 ++--
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
...e.eventmesh.api.storage.StorageResourceService} | 2 +-
.../src/main/resources/kafka-client.properties | 0
.../kafka/config/ClientConfigurationTest.java | 12 ++++----
.../org.apache.io.openmessaging.producer.Producer | 2 +-
.../src/test/resources/kafka-client.properties | 0
.../build.gradle | 4 +--
.../gradle.properties | 0
.../knative/cloudevent/KnativeMessageFactory.java | 4 +--
.../impl/KnativeBinaryMessageReader.java | 2 +-
.../knative/cloudevent/impl/KnativeHeaders.java | 2 +-
.../cloudevent/impl/KnativeMessageWriter.java | 2 +-
.../knative/config/ClientConfiguration.java | 2 +-
.../storage}/knative/consumer/DefaultConsumer.java | 4 +--
.../knative/consumer/KnativeConsumerImpl.java | 4 +--
.../knative/consumer/PullConsumerImpl.java | 10 +++----
.../storage}/knative/domain/NonStandardKeys.java | 4 +--
.../patch/EventMeshConsumeConcurrentlyContext.java | 2 +-
.../patch/EventMeshConsumeConcurrentlyStatus.java | 2 +-
.../EventMeshMessageListenerConcurrently.java | 2 +-
.../knative/producer/AbstractProducer.java | 2 +-
.../knative/producer/KnativeProducerImpl.java | 4 +--
.../storage}/knative/producer/ProducerImpl.java | 8 ++---
.../StorageResourceServiceKnativeImpl.java} | 6 ++--
.../storage}/knative/utils/CloudEventUtils.java | 4 +--
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
...e.eventmesh.api.storage.StorageResourceService} | 2 +-
.../src/main/resources/knative-client.properties | 0
.../knative/config/ClientConfigurationTest.java | 12 ++++----
.../knative/consumer/KnativeConsumerImplTest.java | 6 ++--
.../knative/producer/KnativeProducerImplTest.java | 10 +++----
.../src/test/resources/knative-client.properties | 0
.../README.md | 0
.../build.gradle | 2 +-
.../gradle.properties | 0
.../pravega-connector.jpg | Bin
.../storage}/pravega/PravegaConsumerImpl.java | 8 ++---
.../storage}/pravega/PravegaProducerImpl.java | 8 ++---
.../PravegaStorageResourceServiceImpl.java} | 8 ++---
.../storage}/pravega/client/PravegaClient.java | 6 ++--
.../pravega/client/PravegaCloudEventWriter.java | 2 +-
.../storage}/pravega/client/PravegaEvent.java | 4 +--
.../storage}/pravega/client/SubscribeTask.java | 2 +-
.../pravega/config/PravegaConnectorConfig.java | 2 +-
.../exception/PravegaConnectorException.java | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
...e.eventmesh.api.storage.StorageResourceService} | 2 +-
.../main/resources/pravega-connector.properties | 0
.../storage}/pravega/client/PravegaClientTest.java | 4 +--
.../pravega/config/PravegaConnectorConfigTest.java | 12 ++++----
.../test/resources/pravega-connector.properties | 0
.../build.gradle | 4 +--
.../gradle.properties | 0
.../pulsar/client/PulsarClientWrapper.java | 6 ++--
.../pulsar/config/ClientConfiguration.java | 4 +--
.../pulsar/consumer/PulsarConsumerImpl.java | 4 +--
.../storage}/pulsar/producer/AbstractProducer.java | 2 +-
.../storage}/pulsar/producer/ProducerImpl.java | 8 ++---
.../pulsar/producer/PulsarProducerImpl.java | 4 +--
.../storage/StorageResourceServicePulsarImpl.java} | 6 ++--
.../storage}/pulsar/utils/CloudEventUtils.java | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
...e.eventmesh.api.storage.StorageResourceService} | 2 +-
.../src/main/resources/pulsar-client.properties | 0
.../pulsar/config/ClientConfigurationTest.java | 12 ++++----
.../src/test/resources/pulsar-client.properties | 0
.../build.gradle | 4 +--
.../gradle.properties | 0
.../storage}/rabbitmq/client/RabbitmqClient.java | 2 +-
.../rabbitmq/client/RabbitmqConnectionFactory.java | 2 +-
.../rabbitmq/cloudevent/RabbitmqCloudEvent.java | 6 ++--
.../cloudevent/RabbitmqCloudEventWriter.java | 2 +-
.../rabbitmq/config/ConfigurationHolder.java | 2 +-
.../rabbitmq/consumer/RabbitmqConsumer.java | 8 ++---
.../rabbitmq/consumer/RabbitmqConsumerHandler.java | 6 ++--
.../exception/RabbitmqaConnectorException.java | 2 +-
.../rabbitmq/producer/RabbitmqProducer.java | 14 ++++-----
.../storage/RabbitmqStorageResourceService.java} | 6 ++--
.../storage}/rabbitmq/utils/ByteArrayUtils.java | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
...e.eventmesh.api.storage.StorageResourceService} | 2 +-
.../src/main/resources/rabbitmq-client.properties | 0
.../rabbitmq/RabbitmqMockConnectionFactory.java | 4 +--
.../storage}/rabbitmq/RabbitmqServer.java | 12 ++++----
.../cloudevent/RabbitmqCloudEventTest.java | 2 +-
.../rabbitmq/config/ConfigurationHolderTest.java | 12 ++++----
.../rabbitmq/consumer/RabbitmqConsumerTest.java | 4 +--
.../rabbitmq/producer/RabbitmqProducerTest.java | 4 +--
.../src/test/resources/rabbitmq-client.properties | 0
.../build.gradle | 2 +-
.../gradle.properties | 0
.../storage}/redis/client/RedissonClient.java | 6 ++--
.../storage}/redis/cloudevent/CloudEventCodec.java | 2 +-
.../storage}/redis/config/RedisProperties.java | 2 +-
.../storage}/redis/consumer/RedisConsumer.java | 4 +--
.../storage}/redis/producer/RedisProducer.java | 4 +--
.../storage/RedisStorageResourceService.java} | 6 ++--
.../org.apache.eventmesh.api.consumer.Consumer} | 4 +--
.../org.apache.eventmesh.api.producer.Producer} | 4 +--
...e.eventmesh.api.storage.StorageResourceService} | 2 +-
.../src/main/resources/redis-client.properties | 0
.../storage}/redis/AbstractRedisServer.java | 2 +-
.../storage}/redis/client/RedissonClientTest.java | 6 ++--
.../storage}/redis/config/RedisPropertiesTest.java | 4 +--
.../storage}/redis/consumer/RedisConsumerTest.java | 6 ++--
.../storage}/redis/producer/RedisProducerTest.java | 4 +--
.../eventmesh/storage/redis/storage}/UnitTest.java | 10 +++----
.../src/test/resources/redis-client.properties | 0
.../build.gradle | 4 +--
.../gradle.properties | 0
.../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 | 22 +++++++-------
.../rocketmq/consumer/RocketMQConsumerImpl.java | 4 +--
.../storage}/rocketmq/domain/NonStandardKeys.java | 2 +-
.../exception/RMQMessageFormatException.java | 2 +-
.../rocketmq/exception/RMQTimeoutException.java | 2 +-
.../patch/EventMeshConsumeConcurrentlyContext.java | 2 +-
.../patch/EventMeshConsumeConcurrentlyStatus.java | 2 +-
.../EventMeshMessageListenerConcurrently.java | 2 +-
.../rocketmq/producer/AbstractProducer.java | 12 ++++----
.../storage}/rocketmq/producer/ProducerImpl.java | 6 ++--
.../rocketmq/producer/RocketMQProducerImpl.java | 6 ++--
.../StorageResourceServiceRocketmqImpl.java} | 6 ++--
.../storage}/rocketmq/utils/BeanUtils.java | 2 +-
.../storage}/rocketmq/utils/CloudEventUtils.java | 2 +-
.../eventmesh/storage}/rocketmq/utils/OMSUtil.java | 2 +-
.../ConsumeMessageConcurrentlyService.java | 2 +-
.../org.apache.eventmesh.api.admin.Admin} | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
...e.eventmesh.api.storage.StorageResourceService} | 2 +-
.../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 | 4 +--
.../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
.../build.gradle | 2 +-
.../gradle.properties | 0
.../storage}/standalone/admin/StandaloneAdmin.java | 8 ++---
.../standalone/admin/StandaloneAdminAdaptor.java | 2 +-
.../storage}/standalone/broker/MessageQueue.java | 4 +--
.../standalone/broker/StandaloneBroker.java | 8 ++---
.../standalone/broker/model/MessageEntity.java | 2 +-
.../standalone/broker/model/TopicMetadata.java | 2 +-
.../broker/task/HistoryMessageClearTask.java | 8 ++---
.../standalone/broker/task/SubScribeTask.java | 4 +--
.../standalone/consumer/StandaloneConsumer.java | 8 ++---
.../consumer/StandaloneConsumerAdaptor.java | 2 +-
.../standalone/producer/StandaloneProducer.java | 6 ++--
.../producer/StandaloneProducerAdaptor.java | 2 +-
.../StandaloneStorageResourceService.java} | 6 ++--
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
...e.eventmesh.api.storage.StorageResourceService} | 2 +-
.../standalone/broker/StandaloneBrokerTest.java | 6 ++--
.../eventmesh-webhook-receive/build.gradle | 2 +-
.../webhook/receive/WebHookMQProducer.java | 4 +--
settings.gradle | 20 ++++++-------
251 files changed, 434 insertions(+), 656 deletions(-)
rename eventmesh-connectors/{README => README.md} (100%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{connector/ConnectorResource.java
=> storage/StorageResource.java} (64%)
delete mode 100644
eventmesh-storage/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-storage/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-storage/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-storage/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-storage/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-storage/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/connector/ConnectorResourceServiceRocketmqImpl.java
delete mode 100644
eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-storage/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
delete mode 100644
eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-storage/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/build.gradle (100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/gradle.properties (100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/AbstractContext.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/EventListener.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/LifeCycle.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/SendCallback.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/SendResult.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/admin/Admin.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/consumer/Consumer.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/exception/ConnectorRuntimeException.java
(100%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
(100%)
rename
eventmesh-storage/{eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/factory/ConnectorPluginFactory.java
=>
eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/factory/StoragePluginFactory.java}
(94%)
rename eventmesh-storage/{eventmesh-connector-api =>
eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/producer/Producer.java
(100%)
rename
eventmesh-storage/{eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java
=>
eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/storage/StorageResourceService.java}
(93%)
rename eventmesh-storage/{eventmesh-connector-kafka =>
eventmesh-storage-kafka}/build.gradle (92%)
rename eventmesh-storage/{eventmesh-connector-kafka =>
eventmesh-storage-kafka}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage}/kafka/common/Constants.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage}/kafka/common/EventMeshConstants.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage}/kafka/config/ClientConfiguration.java
(98%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage}/kafka/consumer/ConsumerImpl.java
(98%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage}/kafka/consumer/KafkaConsumerImpl.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage}/kafka/consumer/KafkaConsumerRunner.java
(98%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage}/kafka/producer/KafkaProducerImpl.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage}/kafka/producer/ProducerImpl.java
(98%)
copy
eventmesh-storage/{eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/connector/ConnectorResourceServiceKafkaImpl.java
=>
eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/storage/StorageResourceServiceKafkaImpl.java}
(81%)
rename eventmesh-storage/{eventmesh-connector-pravega =>
eventmesh-storage-kafka}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(92%)
rename eventmesh-storage/{eventmesh-connector-pravega =>
eventmesh-storage-kafka}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(92%)
copy
eventmesh-storage/{eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
=>
eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService}
(90%)
rename eventmesh-storage/{eventmesh-connector-kafka =>
eventmesh-storage-kafka}/src/main/resources/kafka-client.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-kafka/src/test/java/org/apache/eventmesh/storage}/kafka/config/ClientConfigurationTest.java
(85%)
rename eventmesh-storage/{eventmesh-connector-kafka =>
eventmesh-storage-kafka}/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
(93%)
rename eventmesh-storage/{eventmesh-connector-kafka =>
eventmesh-storage-kafka}/src/test/resources/kafka-client.properties (100%)
rename eventmesh-storage/{eventmesh-connector-knative =>
eventmesh-storage-knative}/build.gradle (89%)
rename eventmesh-storage/{eventmesh-connector-knative =>
eventmesh-storage-knative}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/cloudevent/KnativeMessageFactory.java
(91%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/cloudevent/impl/KnativeBinaryMessageReader.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/cloudevent/impl/KnativeHeaders.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/cloudevent/impl/KnativeMessageWriter.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/config/ClientConfiguration.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/consumer/DefaultConsumer.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/consumer/KnativeConsumerImpl.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/consumer/PullConsumerImpl.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/domain/NonStandardKeys.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/patch/EventMeshConsumeConcurrentlyContext.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/patch/EventMeshConsumeConcurrentlyStatus.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/patch/EventMeshMessageListenerConcurrently.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/producer/AbstractProducer.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/producer/KnativeProducerImpl.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/producer/ProducerImpl.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/connector/ConnectorResourceServicePulsarImpl.java
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/storage/StorageResourceServiceKnativeImpl.java}
(81%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage}/knative/utils/CloudEventUtils.java
(89%)
rename eventmesh-storage/{eventmesh-connector-rabbitmq =>
eventmesh-storage-knative}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(91%)
rename eventmesh-storage/{eventmesh-connector-rabbitmq =>
eventmesh-storage-knative}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(91%)
copy
eventmesh-storage/{eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
=>
eventmesh-storage-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService}
(89%)
rename eventmesh-storage/{eventmesh-connector-knative =>
eventmesh-storage-knative}/src/main/resources/knative-client.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/test/java/org/apache/eventmesh/storage}/knative/config/ClientConfigurationTest.java
(77%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/test/java/org/apache/eventmesh/storage}/knative/consumer/KnativeConsumerImplTest.java
(87%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-knative/src/test/java/org/apache/eventmesh/storage}/knative/producer/KnativeProducerImplTest.java
(85%)
rename eventmesh-storage/{eventmesh-connector-knative =>
eventmesh-storage-knative}/src/test/resources/knative-client.properties (100%)
rename eventmesh-storage/{eventmesh-connector-pravega =>
eventmesh-storage-pravega}/README.md (100%)
rename eventmesh-storage/{eventmesh-connector-pravega =>
eventmesh-storage-pravega}/build.gradle (94%)
rename eventmesh-storage/{eventmesh-connector-pravega =>
eventmesh-storage-pravega}/gradle.properties (100%)
rename eventmesh-storage/{eventmesh-connector-pravega =>
eventmesh-storage-pravega}/pravega-connector.jpg (100%)
rename
eventmesh-storage/{eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage}/pravega/PravegaConsumerImpl.java
(92%)
rename
eventmesh-storage/{eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage}/pravega/PravegaProducerImpl.java
(93%)
rename
eventmesh-storage/{eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConnectorResourceServiceImpl.java
=>
eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java}
(79%)
rename
eventmesh-storage/{eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage}/pravega/client/PravegaClient.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage}/pravega/client/PravegaCloudEventWriter.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage}/pravega/client/PravegaEvent.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage}/pravega/client/SubscribeTask.java
(98%)
rename
eventmesh-storage/{eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage}/pravega/config/PravegaConnectorConfig.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage}/pravega/exception/PravegaConnectorException.java
(95%)
rename eventmesh-storage/{eventmesh-connector-redis =>
eventmesh-storage-pravega}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(92%)
rename eventmesh-storage/{eventmesh-connector-redis =>
eventmesh-storage-pravega}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(92%)
copy
eventmesh-storage/{eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
=>
eventmesh-storage-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService}
(90%)
rename eventmesh-storage/{eventmesh-connector-pravega =>
eventmesh-storage-pravega}/src/main/resources/pravega-connector.properties
(100%)
rename
eventmesh-storage/{eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pravega/src/test/java/org/apache/eventmesh/storage}/pravega/client/PravegaClientTest.java
(98%)
rename
eventmesh-storage/{eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pravega/src/test/java/org/apache/eventmesh/storage}/pravega/config/PravegaConnectorConfigTest.java
(82%)
rename eventmesh-storage/{eventmesh-connector-pravega =>
eventmesh-storage-pravega}/src/test/resources/pravega-connector.properties
(100%)
rename eventmesh-storage/{eventmesh-connector-pulsar =>
eventmesh-storage-pulsar}/build.gradle (91%)
copy eventmesh-storage/{eventmesh-connector-pulsar =>
eventmesh-storage-pulsar}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage}/pulsar/client/PulsarClientWrapper.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage}/pulsar/config/ClientConfiguration.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage}/pulsar/consumer/PulsarConsumerImpl.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage}/pulsar/producer/AbstractProducer.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage}/pulsar/producer/ProducerImpl.java
(91%)
rename
eventmesh-storage/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage}/pulsar/producer/PulsarProducerImpl.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java
=>
eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/storage/StorageResourceServicePulsarImpl.java}
(81%)
rename
eventmesh-storage/{eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage}/pulsar/utils/CloudEventUtils.java
(95%)
copy eventmesh-storage/{eventmesh-connector-kafka =>
eventmesh-storage-pulsar}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(91%)
copy eventmesh-storage/{eventmesh-connector-kafka =>
eventmesh-storage-pulsar}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(91%)
copy
eventmesh-storage/{eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
=>
eventmesh-storage-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService}
(90%)
rename eventmesh-storage/{eventmesh-connector-pulsar =>
eventmesh-storage-pulsar}/src/main/resources/pulsar-client.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-pulsar/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-pulsar/src/test/java/org/apache/eventmesh/storage}/pulsar/config/ClientConfigurationTest.java
(75%)
rename eventmesh-storage/{eventmesh-connector-pulsar =>
eventmesh-storage-pulsar}/src/test/resources/pulsar-client.properties (100%)
rename eventmesh-storage/{eventmesh-connector-rabbitmq =>
eventmesh-storage-rabbitmq}/build.gradle (91%)
copy eventmesh-storage/{eventmesh-connector-rabbitmq =>
eventmesh-storage-rabbitmq}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage}/rabbitmq/client/RabbitmqClient.java
(98%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage}/rabbitmq/client/RabbitmqConnectionFactory.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage}/rabbitmq/cloudevent/RabbitmqCloudEvent.java
(93%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage}/rabbitmq/cloudevent/RabbitmqCloudEventWriter.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage}/rabbitmq/config/ConfigurationHolder.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage}/rabbitmq/consumer/RabbitmqConsumer.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage}/rabbitmq/consumer/RabbitmqConsumerHandler.java
(93%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage}/rabbitmq/exception/RabbitmqaConnectorException.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage}/rabbitmq/producer/RabbitmqProducer.java
(91%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/connector/RedisConnectorResourceService.java
=>
eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/storage/RabbitmqStorageResourceService.java}
(82%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage}/rabbitmq/utils/ByteArrayUtils.java
(96%)
rename eventmesh-storage/{eventmesh-connector-pulsar =>
eventmesh-storage-rabbitmq}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(91%)
rename eventmesh-storage/{eventmesh-connector-pulsar =>
eventmesh-storage-rabbitmq}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(91%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
=>
eventmesh-storage-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService}
(90%)
rename eventmesh-storage/{eventmesh-connector-rabbitmq =>
eventmesh-storage-rabbitmq}/src/main/resources/rabbitmq-client.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage}/rabbitmq/RabbitmqMockConnectionFactory.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage}/rabbitmq/RabbitmqServer.java
(78%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage}/rabbitmq/cloudevent/RabbitmqCloudEventTest.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage}/rabbitmq/config/ConfigurationHolderTest.java
(82%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage}/rabbitmq/consumer/RabbitmqConsumerTest.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage}/rabbitmq/producer/RabbitmqProducerTest.java
(96%)
rename eventmesh-storage/{eventmesh-connector-rabbitmq =>
eventmesh-storage-rabbitmq}/src/test/resources/rabbitmq-client.properties (100%)
rename eventmesh-storage/{eventmesh-connector-redis =>
eventmesh-storage-redis}/build.gradle (95%)
rename eventmesh-storage/{eventmesh-connector-redis =>
eventmesh-storage-redis}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage}/redis/client/RedissonClient.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage}/redis/cloudevent/CloudEventCodec.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage}/redis/config/RedisProperties.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage}/redis/consumer/RedisConsumer.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage}/redis/producer/RedisProducer.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/connector/RabbitmqConnectorResourceService.java
=>
eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/storage/RedisStorageResourceService.java}
(81%)
rename eventmesh-storage/{eventmesh-connector-pulsar/gradle.properties =>
eventmesh-storage-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer}
(92%)
rename eventmesh-storage/{eventmesh-connector-rabbitmq/gradle.properties =>
eventmesh-storage-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer}
(92%)
copy
eventmesh-storage/{eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
=>
eventmesh-storage-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService}
(91%)
rename eventmesh-storage/{eventmesh-connector-redis =>
eventmesh-storage-redis}/src/main/resources/redis-client.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage}/redis/AbstractRedisServer.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage}/redis/client/RedissonClientTest.java
(89%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage}/redis/config/RedisPropertiesTest.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage}/redis/consumer/RedisConsumerTest.java
(93%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage}/redis/producer/RedisProducerTest.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/connector
=>
eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage/redis/storage}/UnitTest.java
(90%)
rename eventmesh-storage/{eventmesh-connector-redis =>
eventmesh-storage-redis}/src/test/resources/redis-client.properties (100%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-rocketmq}/build.gradle (93%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-rocketmq}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/admin/RocketMQAdmin.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/admin/RocketMQAdminAdaptor.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/admin/command/Command.java
(93%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/cloudevent/RocketMQMessageFactory.java
(88%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/cloudevent/impl/RocketMQHeaders.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/cloudevent/impl/RocketMQMessageWriter.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/common/EventMeshConstants.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/config/ClientConfig.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/config/ClientConfiguration.java
(98%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/consumer/PushConsumerImpl.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/consumer/RocketMQConsumerImpl.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/domain/NonStandardKeys.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/exception/RMQMessageFormatException.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/exception/RMQTimeoutException.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/patch/EventMeshMessageListenerConcurrently.java
(98%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/producer/AbstractProducer.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/producer/ProducerImpl.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/producer/RocketMQProducerImpl.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/resource/StandaloneConnectorResourceService.java
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/storage/StorageResourceServiceRocketmqImpl.java}
(81%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/utils/BeanUtils.java
(99%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/utils/CloudEventUtils.java
(99%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage}/rocketmq/utils/OMSUtil.java
(95%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-rocketmq}/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
(99%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
=>
eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin}
(91%)
rename eventmesh-storage/{eventmesh-connector-knative =>
eventmesh-storage-rocketmq}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(91%)
copy eventmesh-storage/{eventmesh-connector-knative =>
eventmesh-storage-rocketmq}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(91%)
copy
eventmesh-storage/{eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
=>
eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService}
(89%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-rocketmq}/src/main/resources/rocketmq-client.properties (100%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-rocketmq}/src/test/java/org/apache/eventmesh/producer/DefaultProducerImplTest.java
(100%)
rename
eventmesh-storage/{eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage}/rocketmq/config/ClientConfigurationTest.java
(83%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-rocketmq}/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
(95%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-rocketmq}/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
(97%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-rocketmq}/src/test/java/org/apache/rocketmq/promise/DefaultPromiseTest.java
(100%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-rocketmq}/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
(95%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-rocketmq}/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
(92%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-rocketmq}/src/test/resources/rocketmq-client.properties (100%)
rename eventmesh-storage/{eventmesh-connector-standalone =>
eventmesh-storage-standalone}/build.gradle (92%)
rename eventmesh-storage/{eventmesh-connector-standalone =>
eventmesh-storage-standalone}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/admin/StandaloneAdmin.java
(93%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/admin/StandaloneAdminAdaptor.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/broker/MessageQueue.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/broker/StandaloneBroker.java
(94%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/broker/model/MessageEntity.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/broker/model/TopicMetadata.java
(96%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/broker/task/HistoryMessageClearTask.java
(89%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/broker/task/SubScribeTask.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/consumer/StandaloneConsumer.java
(93%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/consumer/StandaloneConsumerAdaptor.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/producer/StandaloneProducer.java
(95%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage}/standalone/producer/StandaloneProducerAdaptor.java
(97%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/connector/ConnectorResourceServiceKafkaImpl.java
=>
eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/resource/StandaloneStorageResourceService.java}
(81%)
rename eventmesh-storage/{eventmesh-connector-rocketmq =>
eventmesh-storage-standalone}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(90%)
copy eventmesh-storage/{eventmesh-connector-kafka =>
eventmesh-storage-standalone}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(90%)
rename eventmesh-storage/{eventmesh-connector-knative =>
eventmesh-storage-standalone}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(90%)
rename
eventmesh-storage/{eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
=>
eventmesh-storage-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService}
(89%)
rename
eventmesh-storage/{eventmesh-connector-standalone/src/test/java/org/apache/eventmesh/connector
=>
eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage}/standalone/broker/StandaloneBrokerTest.java
(94%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
