This is an automated email from the ASF dual-hosted git repository.
wqliang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from 1cbe15ed6 Merge pull request #3354 from mxsm/eventmesh-3353
add df11c3fab Revert "[ISSUE #3353]Tidy up the eventmesh-storage module"
new eeaff3c3d Merge pull request #3355 from
apache/revert-3354-eventmesh-3353
The 1 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.md => README} | 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 ++-
.../eventmesh/runtime/storage/StorageResource.java | 78 ---------------------
.../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 +-
.../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
.../api/connector/ConnectorResourceService.java} | 4 +-
.../apache/eventmesh/api/consumer/Consumer.java | 0
.../api/exception/ConnectorRuntimeException.java | 0
.../api/exception/OnExceptionContext.java | 0
.../api/factory/ConnectorPluginFactory.java} | 4 +-
.../apache/eventmesh/api/producer/Producer.java | 0
.../build.gradle | 4 +-
.../gradle.properties | 0
.../connector}/kafka/common/Constants.java | 2 +-
.../kafka/common/EventMeshConstants.java | 2 +-
.../kafka/config/ClientConfiguration.java | 2 +-
.../ConnectorResourceServiceKafkaImpl.java} | 6 +-
.../connector}/kafka/consumer/ConsumerImpl.java | 4 +-
.../kafka/consumer/KafkaConsumerImpl.java | 4 +-
.../kafka/consumer/KafkaConsumerRunner.java | 4 +-
.../kafka/producer/KafkaProducerImpl.java | 4 +-
.../connector}/kafka/producer/ProducerImpl.java | 2 +-
...entmesh.api.connector.ConnectorResourceService} | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 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 +-
.../ConnectorResourceServiceKnativeImpl.java} | 6 +-
.../knative/consumer/DefaultConsumer.java | 4 +-
.../knative/consumer/KnativeConsumerImpl.java | 4 +-
.../knative/consumer/PullConsumerImpl.java | 10 +--
.../connector}/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 +-
.../connector}/knative/producer/ProducerImpl.java | 8 +--
.../connector}/knative/utils/CloudEventUtils.java | 4 +-
...entmesh.api.connector.ConnectorResourceService} | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 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
.../PravegaConnectorResourceServiceImpl.java} | 8 +--
.../connector}/pravega/PravegaConsumerImpl.java | 8 +--
.../connector}/pravega/PravegaProducerImpl.java | 8 +--
.../connector}/pravega/client/PravegaClient.java | 6 +-
.../pravega/client/PravegaCloudEventWriter.java | 2 +-
.../connector}/pravega/client/PravegaEvent.java | 4 +-
.../connector}/pravega/client/SubscribeTask.java | 2 +-
.../pravega/config/PravegaConnectorConfig.java | 2 +-
.../exception/PravegaConnectorException.java | 2 +-
...entmesh.api.connector.ConnectorResourceService} | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
.../main/resources/pravega-connector.properties | 0
.../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 +-
.../ConnectorResourceServicePulsarImpl.java} | 6 +-
.../pulsar/consumer/PulsarConsumerImpl.java | 4 +-
.../pulsar/producer/AbstractProducer.java | 2 +-
.../connector}/pulsar/producer/ProducerImpl.java | 8 +--
.../pulsar/producer/PulsarProducerImpl.java | 4 +-
.../connector}/pulsar/utils/CloudEventUtils.java | 2 +-
...entmesh.api.connector.ConnectorResourceService} | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 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
.../connector}/rabbitmq/client/RabbitmqClient.java | 2 +-
.../rabbitmq/client/RabbitmqConnectionFactory.java | 2 +-
.../rabbitmq/cloudevent/RabbitmqCloudEvent.java | 6 +-
.../cloudevent/RabbitmqCloudEventWriter.java | 2 +-
.../rabbitmq/config/ConfigurationHolder.java | 2 +-
.../RabbitmqConnectorResourceService.java} | 6 +-
.../rabbitmq/consumer/RabbitmqConsumer.java | 8 +--
.../rabbitmq/consumer/RabbitmqConsumerHandler.java | 6 +-
.../exception/RabbitmqaConnectorException.java | 2 +-
.../rabbitmq/producer/RabbitmqProducer.java | 14 ++--
.../connector}/rabbitmq/utils/ByteArrayUtils.java | 2 +-
...entmesh.api.connector.ConnectorResourceService} | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
.../src/main/resources/rabbitmq-client.properties | 0
.../rabbitmq/RabbitmqMockConnectionFactory.java | 4 +-
.../connector}/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
.../connector}/redis/client/RedissonClient.java | 6 +-
.../redis/cloudevent/CloudEventCodec.java | 2 +-
.../connector}/redis/config/RedisProperties.java | 2 +-
.../connector/RedisConnectorResourceService.java} | 6 +-
.../connector}/redis/consumer/RedisConsumer.java | 4 +-
.../connector}/redis/producer/RedisProducer.java | 4 +-
...entmesh.api.connector.ConnectorResourceService} | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
.../src/main/resources/redis-client.properties | 0
.../connector}/redis/AbstractRedisServer.java | 2 +-
.../redis/client/RedissonClientTest.java | 6 +-
.../redis/config/RedisPropertiesTest.java | 4 +-
.../connector/redis/connector}/UnitTest.java | 10 +--
.../redis/consumer/RedisConsumerTest.java | 6 +-
.../redis/producer/RedisProducerTest.java | 4 +-
.../src/test/resources/redis-client.properties | 0
.../build.gradle | 4 +-
.../gradle.properties | 0
.../connector}/rocketmq/admin/RocketMQAdmin.java | 4 +-
.../rocketmq/admin/RocketMQAdminAdaptor.java | 2 +-
.../connector}/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 +-
.../connector}/rocketmq/config/ClientConfig.java | 4 +-
.../rocketmq/config/ClientConfiguration.java | 2 +-
.../ConnectorResourceServiceRocketmqImpl.java} | 6 +-
.../rocketmq/consumer/PushConsumerImpl.java | 22 +++---
.../rocketmq/consumer/RocketMQConsumerImpl.java | 4 +-
.../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 ++--
.../connector}/rocketmq/producer/ProducerImpl.java | 6 +-
.../rocketmq/producer/RocketMQProducerImpl.java | 6 +-
.../connector}/rocketmq/utils/BeanUtils.java | 2 +-
.../connector}/rocketmq/utils/CloudEventUtils.java | 2 +-
.../connector}/rocketmq/utils/OMSUtil.java | 2 +-
.../ConsumeMessageConcurrentlyService.java | 2 +-
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 2 +-
...entmesh.api.connector.ConnectorResourceService} | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
.../src/main/resources/rocketmq-client.properties | 0
.../rocketmq/config/ClientConfigurationTest.java | 12 ++--
.../producer/DefaultProducerImplTest.java | 0
.../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
.../standalone/admin/StandaloneAdmin.java | 8 +--
.../standalone/admin/StandaloneAdminAdaptor.java | 2 +-
.../connector}/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 +-
.../StandaloneConnectorResourceService.java} | 6 +-
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 2 +-
...entmesh.api.connector.ConnectorResourceService} | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
.../standalone/broker/StandaloneBrokerTest.java | 6 +-
...he.eventmesh.api.storage.StorageResourceService | 16 -----
...he.eventmesh.api.storage.StorageResourceService | 16 -----
...he.eventmesh.api.storage.StorageResourceService | 16 -----
.../org.apache.eventmesh.api.consumer.Consumer | 16 -----
.../org.apache.eventmesh.api.producer.Producer | 16 -----
...he.eventmesh.api.storage.StorageResourceService | 16 -----
...he.eventmesh.api.storage.StorageResourceService | 16 -----
.../org.apache.eventmesh.api.consumer.Consumer | 16 -----
.../org.apache.eventmesh.api.producer.Producer | 16 -----
...he.eventmesh.api.storage.StorageResourceService | 16 -----
.../resource/StandaloneStorageResourceService.java | 33 ---------
.../org.apache.eventmesh.api.consumer.Consumer | 16 -----
.../org.apache.eventmesh.api.producer.Producer | 16 -----
...he.eventmesh.api.storage.StorageResourceService | 16 -----
.../eventmesh-webhook-receive/build.gradle | 2 +-
.../webhook/receive/WebHookMQProducer.java | 4 +-
settings.gradle | 20 +++---
252 files changed, 410 insertions(+), 738 deletions(-)
rename eventmesh-connectors/{README.md => README} (100%)
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/storage/StorageResource.java
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/build.gradle (100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/gradle.properties (100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/AbstractContext.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/EventListener.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/LifeCycle.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/SendCallback.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/SendResult.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/admin/Admin.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
(100%)
rename
eventmesh-storage/{eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/storage/StorageResourceService.java
=>
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java}
(93%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/consumer/Consumer.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/exception/ConnectorRuntimeException.java
(100%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
(100%)
rename
eventmesh-storage/{eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/factory/StoragePluginFactory.java
=>
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/factory/ConnectorPluginFactory.java}
(94%)
rename eventmesh-storage/{eventmesh-storage-api =>
eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/producer/Producer.java
(100%)
rename eventmesh-storage/{eventmesh-storage-kafka =>
eventmesh-connector-kafka}/build.gradle (92%)
rename eventmesh-storage/{eventmesh-storage-kafka =>
eventmesh-connector-kafka}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector}/kafka/common/Constants.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector}/kafka/common/EventMeshConstants.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector}/kafka/config/ClientConfiguration.java
(98%)
copy
eventmesh-storage/{eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/storage/StorageResourceServiceKafkaImpl.java
=>
eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/connector/ConnectorResourceServiceKafkaImpl.java}
(81%)
rename
eventmesh-storage/{eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector}/kafka/consumer/ConsumerImpl.java
(98%)
rename
eventmesh-storage/{eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector}/kafka/consumer/KafkaConsumerImpl.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector}/kafka/consumer/KafkaConsumerRunner.java
(98%)
rename
eventmesh-storage/{eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector}/kafka/producer/KafkaProducerImpl.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector}/kafka/producer/ProducerImpl.java
(98%)
copy
eventmesh-storage/{eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
=>
eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService}
(90%)
copy eventmesh-storage/{eventmesh-storage-kafka =>
eventmesh-connector-kafka}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(91%)
rename eventmesh-storage/{eventmesh-storage-kafka =>
eventmesh-connector-kafka}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(91%)
rename eventmesh-storage/{eventmesh-storage-kafka =>
eventmesh-connector-kafka}/src/main/resources/kafka-client.properties (100%)
rename
eventmesh-storage/{eventmesh-storage-kafka/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-kafka/src/test/java/org/apache/eventmesh/connector}/kafka/config/ClientConfigurationTest.java
(85%)
rename eventmesh-storage/{eventmesh-storage-kafka =>
eventmesh-connector-kafka}/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
(93%)
rename eventmesh-storage/{eventmesh-storage-kafka =>
eventmesh-connector-kafka}/src/test/resources/kafka-client.properties (100%)
rename eventmesh-storage/{eventmesh-storage-knative =>
eventmesh-connector-knative}/build.gradle (89%)
rename eventmesh-storage/{eventmesh-storage-knative =>
eventmesh-connector-knative}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/cloudevent/KnativeMessageFactory.java
(91%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/cloudevent/impl/KnativeBinaryMessageReader.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/cloudevent/impl/KnativeHeaders.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/cloudevent/impl/KnativeMessageWriter.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/config/ClientConfiguration.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage/knative/storage/StorageResourceServiceKnativeImpl.java
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java}
(81%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/consumer/DefaultConsumer.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/consumer/KnativeConsumerImpl.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/consumer/PullConsumerImpl.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/domain/NonStandardKeys.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/patch/EventMeshConsumeConcurrentlyContext.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/patch/EventMeshConsumeConcurrentlyStatus.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/patch/EventMeshMessageListenerConcurrently.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/producer/AbstractProducer.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/producer/KnativeProducerImpl.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/producer/ProducerImpl.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector}/knative/utils/CloudEventUtils.java
(89%)
copy
eventmesh-storage/{eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
=>
eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService}
(89%)
copy eventmesh-storage/{eventmesh-storage-kafka =>
eventmesh-connector-knative}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(91%)
copy eventmesh-storage/{eventmesh-storage-knative =>
eventmesh-connector-knative}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(91%)
rename eventmesh-storage/{eventmesh-storage-knative =>
eventmesh-connector-knative}/src/main/resources/knative-client.properties (100%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector}/knative/config/ClientConfigurationTest.java
(77%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector}/knative/consumer/KnativeConsumerImplTest.java
(87%)
rename
eventmesh-storage/{eventmesh-storage-knative/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector}/knative/producer/KnativeProducerImplTest.java
(85%)
rename eventmesh-storage/{eventmesh-storage-knative =>
eventmesh-connector-knative}/src/test/resources/knative-client.properties (100%)
rename eventmesh-storage/{eventmesh-storage-pravega =>
eventmesh-connector-pravega}/README.md (100%)
rename eventmesh-storage/{eventmesh-storage-pravega =>
eventmesh-connector-pravega}/build.gradle (94%)
rename eventmesh-storage/{eventmesh-storage-pravega =>
eventmesh-connector-pravega}/gradle.properties (100%)
rename eventmesh-storage/{eventmesh-storage-pravega =>
eventmesh-connector-pravega}/pravega-connector.jpg (100%)
rename
eventmesh-storage/{eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java
=>
eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConnectorResourceServiceImpl.java}
(79%)
rename
eventmesh-storage/{eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector}/pravega/PravegaConsumerImpl.java
(92%)
rename
eventmesh-storage/{eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector}/pravega/PravegaProducerImpl.java
(93%)
rename
eventmesh-storage/{eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector}/pravega/client/PravegaClient.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector}/pravega/client/PravegaCloudEventWriter.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector}/pravega/client/PravegaEvent.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector}/pravega/client/SubscribeTask.java
(98%)
rename
eventmesh-storage/{eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector}/pravega/config/PravegaConnectorConfig.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector}/pravega/exception/PravegaConnectorException.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
=>
eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService}
(90%)
rename eventmesh-storage/{eventmesh-storage-pravega =>
eventmesh-connector-pravega}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(92%)
rename eventmesh-storage/{eventmesh-storage-pravega =>
eventmesh-connector-pravega}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(92%)
rename eventmesh-storage/{eventmesh-storage-pravega =>
eventmesh-connector-pravega}/src/main/resources/pravega-connector.properties
(100%)
rename
eventmesh-storage/{eventmesh-storage-pravega/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector}/pravega/client/PravegaClientTest.java
(98%)
rename
eventmesh-storage/{eventmesh-storage-pravega/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector}/pravega/config/PravegaConnectorConfigTest.java
(82%)
rename eventmesh-storage/{eventmesh-storage-pravega =>
eventmesh-connector-pravega}/src/test/resources/pravega-connector.properties
(100%)
rename eventmesh-storage/{eventmesh-storage-pulsar =>
eventmesh-connector-pulsar}/build.gradle (91%)
rename eventmesh-storage/{eventmesh-storage-pulsar =>
eventmesh-connector-pulsar}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector}/pulsar/client/PulsarClientWrapper.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector}/pulsar/config/ClientConfiguration.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/storage/StorageResourceServiceRocketmqImpl.java
=>
eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/connector/ConnectorResourceServicePulsarImpl.java}
(81%)
rename
eventmesh-storage/{eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector}/pulsar/consumer/PulsarConsumerImpl.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector}/pulsar/producer/AbstractProducer.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector}/pulsar/producer/ProducerImpl.java
(91%)
rename
eventmesh-storage/{eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector}/pulsar/producer/PulsarProducerImpl.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector}/pulsar/utils/CloudEventUtils.java
(95%)
copy
eventmesh-storage/{eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
=>
eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService}
(89%)
rename eventmesh-storage/{eventmesh-storage-pulsar =>
eventmesh-connector-pulsar}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(91%)
rename eventmesh-storage/{eventmesh-storage-pulsar =>
eventmesh-connector-pulsar}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(91%)
rename eventmesh-storage/{eventmesh-storage-pulsar =>
eventmesh-connector-pulsar}/src/main/resources/pulsar-client.properties (100%)
rename
eventmesh-storage/{eventmesh-storage-pulsar/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-pulsar/src/test/java/org/apache/eventmesh/connector}/pulsar/config/ClientConfigurationTest.java
(75%)
rename eventmesh-storage/{eventmesh-storage-pulsar =>
eventmesh-connector-pulsar}/src/test/resources/pulsar-client.properties (100%)
rename eventmesh-storage/{eventmesh-storage-rabbitmq =>
eventmesh-connector-rabbitmq}/build.gradle (91%)
rename eventmesh-storage/{eventmesh-storage-rabbitmq =>
eventmesh-connector-rabbitmq}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/client/RabbitmqClient.java
(98%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/client/RabbitmqConnectionFactory.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/cloudevent/RabbitmqCloudEvent.java
(93%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/cloudevent/RabbitmqCloudEventWriter.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/config/ConfigurationHolder.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/storage/RedisStorageResourceService.java
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/connector/RabbitmqConnectorResourceService.java}
(81%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/consumer/RabbitmqConsumer.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/consumer/RabbitmqConsumerHandler.java
(93%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/exception/RabbitmqaConnectorException.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/producer/RabbitmqProducer.java
(91%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector}/rabbitmq/utils/ByteArrayUtils.java
(96%)
copy
eventmesh-storage/{eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
=>
eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService}
(89%)
rename eventmesh-storage/{eventmesh-storage-knative =>
eventmesh-connector-rabbitmq}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(91%)
copy eventmesh-storage/{eventmesh-storage-knative =>
eventmesh-connector-rabbitmq}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(91%)
rename eventmesh-storage/{eventmesh-storage-rabbitmq =>
eventmesh-connector-rabbitmq}/src/main/resources/rabbitmq-client.properties
(100%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector}/rabbitmq/RabbitmqMockConnectionFactory.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector}/rabbitmq/RabbitmqServer.java
(78%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector}/rabbitmq/cloudevent/RabbitmqCloudEventTest.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector}/rabbitmq/config/ConfigurationHolderTest.java
(82%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector}/rabbitmq/consumer/RabbitmqConsumerTest.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector}/rabbitmq/producer/RabbitmqProducerTest.java
(96%)
rename eventmesh-storage/{eventmesh-storage-rabbitmq =>
eventmesh-connector-rabbitmq}/src/test/resources/rabbitmq-client.properties
(100%)
rename eventmesh-storage/{eventmesh-storage-redis =>
eventmesh-connector-redis}/build.gradle (95%)
rename eventmesh-storage/{eventmesh-storage-redis =>
eventmesh-connector-redis}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector}/redis/client/RedissonClient.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector}/redis/cloudevent/CloudEventCodec.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector}/redis/config/RedisProperties.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/storage/RabbitmqStorageResourceService.java
=>
eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/connector/RedisConnectorResourceService.java}
(82%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector}/redis/consumer/RedisConsumer.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector}/redis/producer/RedisProducer.java
(97%)
copy
eventmesh-storage/{eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
=>
eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService}
(90%)
rename eventmesh-storage/{eventmesh-storage-redis =>
eventmesh-connector-redis}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(92%)
rename eventmesh-storage/{eventmesh-storage-redis =>
eventmesh-connector-redis}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(92%)
rename eventmesh-storage/{eventmesh-storage-redis =>
eventmesh-connector-redis}/src/main/resources/redis-client.properties (100%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector}/redis/AbstractRedisServer.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector}/redis/client/RedissonClientTest.java
(89%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector}/redis/config/RedisPropertiesTest.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage/redis/storage
=>
eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/connector}/UnitTest.java
(90%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector}/redis/consumer/RedisConsumerTest.java
(93%)
rename
eventmesh-storage/{eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector}/redis/producer/RedisProducerTest.java
(96%)
rename eventmesh-storage/{eventmesh-storage-redis =>
eventmesh-connector-redis}/src/test/resources/redis-client.properties (100%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/build.gradle (93%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/admin/RocketMQAdmin.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/admin/RocketMQAdminAdaptor.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/admin/command/Command.java
(93%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/cloudevent/RocketMQMessageFactory.java
(88%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/cloudevent/impl/RocketMQHeaders.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/cloudevent/impl/RocketMQMessageWriter.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/common/EventMeshConstants.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/config/ClientConfig.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/config/ClientConfiguration.java
(98%)
rename
eventmesh-storage/{eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/storage/StorageResourceServiceKafkaImpl.java
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/connector/ConnectorResourceServiceRocketmqImpl.java}
(81%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/consumer/PushConsumerImpl.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/consumer/RocketMQConsumerImpl.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/domain/NonStandardKeys.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/exception/RMQMessageFormatException.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/exception/RMQTimeoutException.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/patch/EventMeshMessageListenerConcurrently.java
(98%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/producer/AbstractProducer.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/producer/ProducerImpl.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/producer/RocketMQProducerImpl.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/utils/BeanUtils.java
(99%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/utils/CloudEventUtils.java
(99%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector}/rocketmq/utils/OMSUtil.java
(95%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
(99%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(91%)
copy
eventmesh-storage/{eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
=>
eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService}
(89%)
copy eventmesh-storage/{eventmesh-storage-kafka =>
eventmesh-connector-rocketmq}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(90%)
copy eventmesh-storage/{eventmesh-storage-knative =>
eventmesh-connector-rocketmq}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(90%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/src/main/resources/rocketmq-client.properties
(100%)
rename
eventmesh-storage/{eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector}/rocketmq/config/ClientConfigurationTest.java
(83%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/src/test/java/org/apache/eventmesh/producer/DefaultProducerImplTest.java
(100%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
(95%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
(97%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/src/test/java/org/apache/rocketmq/promise/DefaultPromiseTest.java
(100%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
(95%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
(92%)
rename eventmesh-storage/{eventmesh-storage-rocketmq =>
eventmesh-connector-rocketmq}/src/test/resources/rocketmq-client.properties
(100%)
rename eventmesh-storage/{eventmesh-storage-standalone =>
eventmesh-connector-standalone}/build.gradle (92%)
rename eventmesh-storage/{eventmesh-storage-standalone =>
eventmesh-connector-standalone}/gradle.properties (100%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/admin/StandaloneAdmin.java
(93%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/admin/StandaloneAdminAdaptor.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/broker/MessageQueue.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/broker/StandaloneBroker.java
(94%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/broker/model/MessageEntity.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/broker/model/TopicMetadata.java
(96%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/broker/task/HistoryMessageClearTask.java
(89%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/broker/task/SubScribeTask.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/consumer/StandaloneConsumer.java
(93%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/consumer/StandaloneConsumerAdaptor.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/producer/StandaloneProducer.java
(95%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector}/standalone/producer/StandaloneProducerAdaptor.java
(97%)
rename
eventmesh-storage/{eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/storage/StorageResourceServicePulsarImpl.java
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/resource/StandaloneConnectorResourceService.java}
(81%)
rename eventmesh-storage/{eventmesh-storage-standalone =>
eventmesh-connector-standalone}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(90%)
copy
eventmesh-storage/{eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
=>
eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService}
(89%)
rename eventmesh-storage/{eventmesh-storage-kafka =>
eventmesh-connector-standalone}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(89%)
rename eventmesh-storage/{eventmesh-storage-knative =>
eventmesh-connector-standalone}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(89%)
rename
eventmesh-storage/{eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage
=>
eventmesh-connector-standalone/src/test/java/org/apache/eventmesh/connector}/standalone/broker/StandaloneBrokerTest.java
(94%)
delete mode 100644
eventmesh-storage/eventmesh-storage-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
delete mode 100644
eventmesh-storage/eventmesh-storage-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
delete mode 100644
eventmesh-storage/eventmesh-storage-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
delete mode 100644
eventmesh-storage/eventmesh-storage-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-storage/eventmesh-storage-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-storage/eventmesh-storage-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
delete mode 100644
eventmesh-storage/eventmesh-storage-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
delete mode 100644
eventmesh-storage/eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-storage/eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-storage/eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
delete mode 100644
eventmesh-storage/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/resource/StandaloneStorageResourceService.java
delete mode 100644
eventmesh-storage/eventmesh-storage-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-storage/eventmesh-storage-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-storage/eventmesh-storage-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
