This is an automated email from the ASF dual-hosted git repository.
chenguangsheng pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/eventmesh.git
from 35926a1c8 Merge pull request #3532 from sanskar-thakur/fix-3007
new e05fb570d [ISSUE #3536] remove connector module
new 6d73ed71b Merge branch 'master' of
https://github.com/apache/incubator-eventmesh into remove-connector
new a0b49799f Merge pull request #3537 from xwm1992/remove-connector
The 3883 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../eventmesh-admin-rocketmq/build.gradle | 4 +-
.../java/org/apache/eventmesh/api/admin/Admin.java | 70 ---
.../api/connector/ConnectorResourceService.java | 42 --
.../apache/eventmesh/api/consumer/Consumer.java | 46 --
.../api/exception/ConnectorRuntimeException.java | 38 --
.../api/exception/OnExceptionContext.java | 39 --
.../api/factory/ConnectorPluginFactory.java | 65 ---
.../apache/eventmesh/api/producer/Producer.java | 49 ---
.../eventmesh-connector-kafka/build.gradle | 47 --
.../eventmesh-connector-kafka/gradle.properties | 20 -
.../connector/kafka/common/Constants.java | 23 -
.../connector/kafka/common/EventMeshConstants.java | 27 --
.../kafka/config/ClientConfiguration.java | 98 -----
.../ConnectorResourceServiceKafkaImpl.java | 33 --
.../connector/kafka/consumer/ConsumerImpl.java | 148 -------
.../kafka/consumer/KafkaConsumerImpl.java | 97 ----
.../kafka/consumer/KafkaConsumerRunner.java | 119 -----
.../kafka/producer/KafkaProducerImpl.java | 104 -----
.../connector/kafka/producer/ProducerImpl.java | 132 ------
...ventmesh.api.connector.ConnectorResourceService | 16 -
.../org.apache.eventmesh.api.consumer.Consumer | 16 -
.../org.apache.eventmesh.api.producer.Producer | 16 -
.../kafka/config/ClientConfigurationTest.java | 70 ---
.../eventmesh-connector-knative/build.gradle | 40 --
.../eventmesh-connector-knative/gradle.properties | 18 -
.../knative/cloudevent/KnativeMessageFactory.java | 47 --
.../impl/KnativeBinaryMessageReader.java | 57 ---
.../knative/cloudevent/impl/KnativeHeaders.java | 31 --
.../cloudevent/impl/KnativeMessageWriter.java | 80 ----
.../knative/config/ClientConfiguration.java | 51 ---
.../ConnectorResourceServiceKnativeImpl.java | 33 --
.../knative/consumer/DefaultConsumer.java | 71 ---
.../knative/consumer/KnativeConsumerImpl.java | 102 -----
.../knative/consumer/PullConsumerImpl.java | 176 --------
.../connector/knative/domain/NonStandardKeys.java | 27 --
.../patch/EventMeshConsumeConcurrentlyContext.java | 31 --
.../patch/EventMeshConsumeConcurrentlyStatus.java | 33 --
.../EventMeshMessageListenerConcurrently.java | 25 --
.../knative/producer/AbstractProducer.java | 67 ---
.../knative/producer/KnativeProducerImpl.java | 101 -----
.../connector/knative/producer/ProducerImpl.java | 128 ------
.../connector/knative/utils/CloudEventUtils.java | 33 --
...ventmesh.api.connector.ConnectorResourceService | 16 -
.../org.apache.eventmesh.api.consumer.Consumer | 16 -
.../org.apache.eventmesh.api.producer.Producer | 16 -
.../src/main/resources/knative-client.properties | 18 -
.../knative/config/ClientConfigurationTest.java | 51 ---
.../knative/consumer/KnativeConsumerImplTest.java | 48 --
.../knative/producer/KnativeProducerImplTest.java | 66 ---
.../src/test/resources/knative-client.properties | 18 -
.../eventmesh-connector-pravega/README.md | 19 -
.../eventmesh-connector-pravega/build.gradle | 39 --
.../eventmesh-connector-pravega/gradle.properties | 20 -
.../pravega-connector.jpg | Bin 143684 -> 0 bytes
.../PravegaConnectorResourceServiceImpl.java | 37 --
.../connector/pravega/PravegaConsumerImpl.java | 109 -----
.../connector/pravega/PravegaProducerImpl.java | 121 -----
.../connector/pravega/client/PravegaClient.java | 233 ----------
.../pravega/client/PravegaCloudEventWriter.java | 70 ---
.../connector/pravega/client/PravegaEvent.java | 77 ----
.../connector/pravega/client/SubscribeTask.java | 89 ----
.../pravega/config/PravegaConnectorConfig.java | 67 ---
.../exception/PravegaConnectorException.java | 31 --
...ventmesh.api.connector.ConnectorResourceService | 16 -
.../org.apache.eventmesh.api.consumer.Consumer | 16 -
.../org.apache.eventmesh.api.producer.Producer | 16 -
.../main/resources/pravega-connector.properties | 26 --
.../pravega/client/PravegaClientTest.java | 188 --------
.../pravega/config/PravegaConnectorConfigTest.java | 60 ---
.../test/resources/pravega-connector.properties | 26 --
.../eventmesh-connector-pulsar/build.gradle | 45 --
.../eventmesh-connector-pulsar/gradle.properties | 18 -
.../pulsar/client/PulsarClientWrapper.java | 120 -----
.../pulsar/config/ClientConfiguration.java | 46 --
.../ConnectorResourceServicePulsarImpl.java | 33 --
.../connector/pulsar/constant/PulsarConstant.java | 23 -
.../pulsar/consumer/PulsarConsumerImpl.java | 208 ---------
.../pulsar/producer/AbstractProducer.java | 55 ---
.../connector/pulsar/producer/ProducerImpl.java | 83 ----
.../pulsar/producer/PulsarProducerImpl.java | 99 -----
.../connector/pulsar/utils/CloudEventUtils.java | 32 --
...ventmesh.api.connector.ConnectorResourceService | 16 -
.../org.apache.eventmesh.api.consumer.Consumer | 16 -
.../org.apache.eventmesh.api.producer.Producer | 16 -
.../pulsar/config/ClientConfigurationTest.java | 50 ---
.../eventmesh-connector-rabbitmq/build.gradle | 48 --
.../eventmesh-connector-rabbitmq/gradle.properties | 18 -
.../connector/rabbitmq/client/RabbitmqClient.java | 148 -------
.../rabbitmq/client/RabbitmqConnectionFactory.java | 40 --
.../rabbitmq/cloudevent/RabbitmqCloudEvent.java | 81 ----
.../cloudevent/RabbitmqCloudEventWriter.java | 68 ---
.../rabbitmq/config/ConfigurationHolder.java | 60 ---
.../RabbitmqConnectorResourceService.java | 33 --
.../rabbitmq/consumer/RabbitmqConsumer.java | 143 ------
.../rabbitmq/consumer/RabbitmqConsumerHandler.java | 83 ----
.../exception/RabbitmqaConnectorException.java | 31 --
.../rabbitmq/producer/RabbitmqProducer.java | 167 -------
.../connector/rabbitmq/utils/ByteArrayUtils.java | 42 --
...ventmesh.api.connector.ConnectorResourceService | 16 -
.../org.apache.eventmesh.api.consumer.Consumer | 16 -
.../org.apache.eventmesh.api.producer.Producer | 16 -
.../rabbitmq/RabbitmqMockConnectionFactory.java | 59 ---
.../connector/rabbitmq/RabbitmqServer.java | 55 ---
.../cloudevent/RabbitmqCloudEventTest.java | 70 ---
.../rabbitmq/config/ConfigurationHolderTest.java | 62 ---
.../rabbitmq/consumer/RabbitmqConsumerTest.java | 93 ----
.../rabbitmq/producer/RabbitmqProducerTest.java | 93 ----
.../eventmesh-connector-redis/build.gradle | 56 ---
.../eventmesh-connector-redis/gradle.properties | 18 -
.../connector/redis/client/RedissonClient.java | 114 -----
.../redis/cloudevent/CloudEventCodec.java | 60 ---
.../connector/redis/config/RedisProperties.java | 66 ---
.../connector/RedisConnectorResourceService.java | 33 --
.../connector/redis/consumer/RedisConsumer.java | 131 ------
.../connector/redis/producer/RedisProducer.java | 139 ------
...ventmesh.api.connector.ConnectorResourceService | 16 -
.../org.apache.eventmesh.api.consumer.Consumer | 16 -
.../org.apache.eventmesh.api.producer.Producer | 16 -
.../connector/redis/AbstractRedisServer.java | 41 --
.../connector/redis/client/RedissonClientTest.java | 31 --
.../redis/config/RedisPropertiesTest.java | 47 --
.../connector/redis/connector/UnitTest.java | 110 -----
.../redis/consumer/RedisConsumerTest.java | 91 ----
.../redis/producer/RedisProducerTest.java | 110 -----
.../eventmesh-connector-rocketmq/build.gradle | 59 ---
.../eventmesh-connector-rocketmq/gradle.properties | 18 -
.../connector/rocketmq/admin/RocketMQAdmin.java | 173 --------
.../rocketmq/admin/RocketMQAdminAdaptor.java | 86 ----
.../connector/rocketmq/admin/command/Command.java | 57 ---
.../cloudevent/RocketMQMessageFactory.java | 78 ----
.../impl/RocketMQBinaryMessageReader.java | 66 ---
.../rocketmq/cloudevent/impl/RocketMQHeaders.java | 39 --
.../cloudevent/impl/RocketMQMessageWriter.java | 99 -----
.../rocketmq/common/EventMeshConstants.java | 27 --
.../connector/rocketmq/config/ClientConfig.java | 205 ---------
.../rocketmq/config/ClientConfiguration.java | 98 -----
.../ConnectorResourceServiceRocketmqImpl.java | 33 --
.../rocketmq/consumer/PushConsumerImpl.java | 313 -------------
.../rocketmq/consumer/RocketMQConsumerImpl.java | 116 -----
.../connector/rocketmq/domain/NonStandardKeys.java | 30 --
.../exception/RMQMessageFormatException.java | 35 --
.../rocketmq/exception/RMQTimeoutException.java | 35 --
.../patch/EventMeshConsumeConcurrentlyContext.java | 47 --
.../patch/EventMeshConsumeConcurrentlyStatus.java | 33 --
.../EventMeshMessageListenerConcurrently.java | 70 ---
.../rocketmq/producer/AbstractProducer.java | 163 -------
.../connector/rocketmq/producer/ProducerImpl.java | 208 ---------
.../rocketmq/producer/RocketMQProducerImpl.java | 123 ------
.../connector/rocketmq/utils/BeanUtils.java | 149 -------
.../connector/rocketmq/utils/CloudEventUtils.java | 153 -------
.../connector/rocketmq/utils/OMSUtil.java | 32 --
.../ConsumeMessageConcurrentlyService.java | 486 ---------------------
.../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 -
.../rocketmq/config/ClientConfigurationTest.java | 63 ---
.../producer/DefaultProducerImplTest.java | 56 ---
.../rocketmq/consumer/PushConsumerImplTest.java | 92 ----
.../apache/rocketmq/producer/ProducerImplTest.java | 139 ------
.../org/apache/rocketmq/utils/BeanUtilsTest.java | 115 -----
.../org.apache.io.openmessaging.producer.Producer | 20 -
.../eventmesh-connector-standalone/build.gradle | 24 -
.../gradle.properties | 17 -
.../standalone/admin/StandaloneAdmin.java | 121 -----
.../standalone/admin/StandaloneAdminAdaptor.java | 86 ----
.../connector/standalone/broker/MessageQueue.java | 228 ----------
.../standalone/broker/StandaloneBroker.java | 163 -------
.../standalone/broker/model/MessageEntity.java | 72 ---
.../standalone/broker/model/TopicMetadata.java | 63 ---
.../broker/task/HistoryMessageClearTask.java | 69 ---
.../standalone/broker/task/SubScribeTask.java | 118 -----
.../standalone/consumer/StandaloneConsumer.java | 125 ------
.../consumer/StandaloneConsumerAdaptor.java | 80 ----
.../standalone/producer/StandaloneProducer.java | 140 ------
.../producer/StandaloneProducerAdaptor.java | 90 ----
.../StandaloneConnectorResourceService.java | 33 --
.../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 -
.../standalone/broker/StandaloneBrokerTest.java | 73 ----
eventmesh-examples/build.gradle | 2 +-
eventmesh-runtime/build.gradle | 5 +-
.../http/processor/SendAsyncMessageProcessor.java | 44 +-
.../http/processor/SendSyncMessageProcessor.java | 9 +-
eventmesh-starter/build.gradle | 1 -
.../build.gradle | 0
.../eventmesh-storage-api}/build.gradle | 0
.../eventmesh-storage-api}/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/OnExceptionContext.java | 0
.../StorageConnectorRuntimeException.java | 0
.../api/factory/StoragePluginFactory.java | 0
.../apache/eventmesh/api/producer/Producer.java | 0
.../api/storage/StorageResourceService.java | 0
.../eventmesh-storage-kafka/build.gradle | 4 +-
.../eventmesh-storage-kafka/gradle.properties | 0
.../eventmesh/storage/kafka/common/Constants.java | 0
.../storage/kafka/common/EventMeshConstants.java | 0
.../storage/kafka/config/ClientConfiguration.java | 0
.../storage/kafka/consumer/ConsumerImpl.java | 0
.../storage/kafka/consumer/KafkaConsumerImpl.java | 0
.../kafka/consumer/KafkaConsumerRunner.java | 0
.../storage/kafka/producer/KafkaProducerImpl.java | 0
.../storage/kafka/producer/ProducerImpl.java | 0
.../storage/StorageResourceServiceKafkaImpl.java | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
...he.eventmesh.api.storage.StorageResourceService | 0
.../src/main/resources/kafka-client.properties | 0
.../kafka/config/ClientConfigurationTest.java | 0
.../org.apache.io.openmessaging.producer.Producer | 0
.../src/test/resources/kafka-client.properties | 0
.../eventmesh-storage-mongodb/build.gradle | 4 +-
.../eventmesh-storage-mongodb/gradle.properties | 0
.../mongodb/client/MongodbClientManager.java | 0
.../storage/mongodb/config/ConfigKey.java | 0
.../mongodb/config/ConfigurationHolder.java | 0
.../storage/mongodb/constant/MongodbConstants.java | 0
.../storage/mongodb/consumer/MongodbConsumer.java | 0
.../consumer/MongodbReplicaSetConsumer.java | 0
.../consumer/MongodbStandaloneConsumer.java | 0
.../mongodb/exception/MongodbStorageException.java | 0
.../storage/mongodb/producer/MongodbProducer.java | 0
.../producer/MongodbReplicaSetProducer.java | 0
.../producer/MongodbStandaloneProducer.java | 0
.../storage/MongodbStorageResourceService.java | 0
.../mongodb/utils/MongodbCloudEventUtil.java | 0
.../storage/mongodb/utils/MongodbSequenceUtil.java | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
...he.eventmesh.api.storage.StorageResourceService | 0
.../src/main/resources/mongodb-client.properties | 0
.../storage/mongodb/MongodbConnectorTest.java | 0
.../eventmesh/storage/mongodb/MongodbServer.java | 0
.../storage/mongodb/MongodbServerTest.java | 0
.../src/test/resources/mongodb-client.properties | 0
.../eventmesh-storage-pravega/README.md | 0
.../eventmesh-storage-pravega/build.gradle | 2 +-
.../eventmesh-storage-pravega/gradle.properties | 0
.../eventmesh-storage-pravega/pravega-storage.jpg | Bin
.../storage/pravega/PravegaConsumerImpl.java | 0
.../storage/pravega/PravegaProducerImpl.java | 0
.../pravega/PravegaStorageResourceServiceImpl.java | 0
.../storage/pravega/client/PravegaClient.java | 0
.../pravega/client/PravegaCloudEventWriter.java | 0
.../storage/pravega/client/PravegaEvent.java | 0
.../storage/pravega/client/SubscribeTask.java | 0
.../pravega/config/PravegaStorageConfig.java | 0
.../pravega/exception/PravegaStorageException.java | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
...he.eventmesh.api.storage.StorageResourceService | 0
.../src/main/resources/pravega-storage.properties | 0
.../storage/pravega/client/PravegaClientTest.java | 0
.../pravega/config/PravegaStorageConfigTest.java | 0
.../src/test/resources/pravega-storage.properties | 0
.../eventmesh-storage-pulsar/build.gradle | 4 +-
.../eventmesh-storage-pulsar/gradle.properties | 0
.../storage/pulsar/client/PulsarClientWrapper.java | 0
.../storage/pulsar/config/ClientConfiguration.java | 0
.../storage/pulsar/constant/PulsarConstant.java | 0
.../pulsar/consumer/PulsarConsumerImpl.java | 0
.../storage/pulsar/producer/AbstractProducer.java | 0
.../storage/pulsar/producer/ProducerImpl.java | 0
.../pulsar/producer/PulsarProducerImpl.java | 0
.../storage/StorageResourceServicePulsarImpl.java | 0
.../storage/pulsar/utils/CloudEventUtils.java | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
...he.eventmesh.api.storage.StorageResourceService | 0
.../src/main/resources/pulsar-client.properties | 0
.../pulsar/config/ClientConfigurationTest.java | 0
.../src/test/resources/pulsar-client.properties | 0
.../eventmesh-storage-rabbitmq/build.gradle | 4 +-
.../eventmesh-storage-rabbitmq/gradle.properties | 0
.../storage/rabbitmq/client/RabbitmqClient.java | 0
.../rabbitmq/client/RabbitmqConnectionFactory.java | 0
.../rabbitmq/cloudevent/RabbitmqCloudEvent.java | 0
.../cloudevent/RabbitmqCloudEventWriter.java | 0
.../rabbitmq/config/ConfigurationHolder.java | 0
.../rabbitmq/consumer/RabbitmqConsumer.java | 0
.../rabbitmq/consumer/RabbitmqConsumerHandler.java | 0
.../exception/RabbitmqStorageException.java | 0
.../rabbitmq/producer/RabbitmqProducer.java | 0
.../storage/RabbitmqStorageResourceService.java | 0
.../storage/rabbitmq/utils/ByteArrayUtils.java | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
...he.eventmesh.api.storage.StorageResourceService | 0
.../src/main/resources/rabbitmq-client.properties | 0
.../rabbitmq/RabbitmqMockConnectionFactory.java | 0
.../eventmesh/storage/rabbitmq/RabbitmqServer.java | 0
.../cloudevent/RabbitmqCloudEventTest.java | 0
.../rabbitmq/config/ConfigurationHolderTest.java | 0
.../rabbitmq/consumer/RabbitmqConsumerTest.java | 0
.../rabbitmq/producer/RabbitmqProducerTest.java | 0
.../src/test/resources/rabbitmq-client.properties | 0
.../eventmesh-storage-redis/build.gradle | 2 +-
.../eventmesh-storage-redis/gradle.properties | 0
.../storage/redis/client/RedissonClient.java | 0
.../storage/redis/cloudevent/CloudEventCodec.java | 0
.../storage/redis/config/RedisProperties.java | 0
.../storage/redis/consumer/RedisConsumer.java | 0
.../storage/redis/producer/RedisProducer.java | 0
.../redis/storage/RedisStorageResourceService.java | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
...he.eventmesh.api.storage.StorageResourceService | 0
.../src/main/resources/redis-client.properties | 0
.../storage/redis/AbstractRedisServer.java | 0
.../storage/redis/client/RedissonClientTest.java | 0
.../storage/redis/config/RedisPropertiesTest.java | 0
.../storage/redis/connector/UnitTest.java | 0
.../storage/redis/consumer/RedisConsumerTest.java | 0
.../storage/redis/producer/RedisProducerTest.java | 0
.../src/test/resources/redis-client.properties | 0
.../eventmesh-storage-rocketmq/build.gradle | 4 +-
.../eventmesh-storage-rocketmq/gradle.properties | 0
.../storage/rocketmq/admin/RocketMQAdmin.java | 0
.../rocketmq/admin/RocketMQAdminAdaptor.java | 0
.../storage/rocketmq/admin/command/Command.java | 0
.../cloudevent/RocketMQMessageFactory.java | 0
.../impl/RocketMQBinaryMessageReader.java | 0
.../rocketmq/cloudevent/impl/RocketMQHeaders.java | 0
.../cloudevent/impl/RocketMQMessageWriter.java | 0
.../rocketmq/common/EventMeshConstants.java | 0
.../storage/rocketmq/config/ClientConfig.java | 0
.../rocketmq/config/ClientConfiguration.java | 0
.../rocketmq/consumer/PushConsumerImpl.java | 0
.../rocketmq/consumer/RocketMQConsumerImpl.java | 0
.../storage/rocketmq/domain/NonStandardKeys.java | 0
.../exception/RMQMessageFormatException.java | 0
.../rocketmq/exception/RMQTimeoutException.java | 0
.../patch/EventMeshConsumeConcurrentlyContext.java | 0
.../patch/EventMeshConsumeConcurrentlyStatus.java | 0
.../EventMeshMessageListenerConcurrently.java | 0
.../rocketmq/producer/AbstractProducer.java | 0
.../storage/rocketmq/producer/ProducerImpl.java | 0
.../rocketmq/producer/RocketMQProducerImpl.java | 0
.../StorageResourceServiceRocketmqImpl.java | 0
.../storage/rocketmq/utils/BeanUtils.java | 0
.../storage/rocketmq/utils/CloudEventUtils.java | 0
.../eventmesh/storage/rocketmq/utils/OMSUtil.java | 0
.../ConsumeMessageConcurrentlyService.java | 0
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
...he.eventmesh.api.storage.StorageResourceService | 0
.../src/main/resources/rocketmq-client.properties | 0
.../rocketmq/config/ClientConfigurationTest.java | 0
.../rocketmq/consumer/PushConsumerImplTest.java | 0
.../rocketmq/producer/DefaultProducerImplTest.java | 0
.../rocketmq/producer/ProducerImplTest.java | 0
.../rocketmq/promise/DefaultPromiseTest.java | 0
.../storage/rocketmq/utils/BeanUtilsTest.java | 0
.../org.apache.io.openmessaging.producer.Producer | 0
.../src/test/resources/rocketmq-client.properties | 0
.../eventmesh-storage-standalone/build.gradle | 2 +-
.../eventmesh-storage-standalone/gradle.properties | 0
.../storage/standalone/admin/StandaloneAdmin.java | 0
.../standalone/admin/StandaloneAdminAdaptor.java | 0
.../storage/standalone/broker/MessageQueue.java | 0
.../standalone/broker/StandaloneBroker.java | 0
.../standalone/broker/model/MessageEntity.java | 0
.../standalone/broker/model/TopicMetadata.java | 0
.../broker/task/HistoryMessageClear.java | 0
.../broker/task/HistoryMessageClearTask.java | 0
.../storage/standalone/broker/task/Subscribe.java | 0
.../standalone/broker/task/SubscribeTask.java | 0
.../standalone/consumer/StandaloneConsumer.java | 0
.../consumer/StandaloneConsumerAdaptor.java | 0
.../standalone/producer/StandaloneProducer.java | 0
.../producer/StandaloneProducerAdaptor.java | 0
.../resource/StandaloneStorageResourceService.java | 0
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
...he.eventmesh.api.storage.StorageResourceService | 0
.../eventmesh/storage/standalone/TestUtils.java | 0
.../standalone/admin/StandaloneAdminTest.java | 0
.../standalone/broker/MessageQueueTest.java | 0
.../standalone/broker/StandaloneBrokerTest.java | 0
.../broker/task/HistoryMessageClearTest.java | 0
.../standalone/broker/task/SubscribeTest.java | 0
.../consumer/StandaloneConsumerTest.java | 0
.../producer/StandaloneProducerTest.java | 0
.../gradle.properties | 0
eventmesh-storage/build.gradle | 16 -
.../eventmesh-storage-api/build.gradle | 33 --
.../eventmesh-storage-api/gradle.properties | 16 -
.../org/apache/eventmesh/api/AbstractContext.java | 25 --
.../apache/eventmesh/api/AsyncConsumeContext.java | 25 --
.../org/apache/eventmesh/api/EventListener.java | 36 --
.../org/apache/eventmesh/api/EventMeshAction.java | 26 --
.../api/EventMeshAsyncConsumeContext.java | 35 --
.../java/org/apache/eventmesh/api/LifeCycle.java | 35 --
.../apache/eventmesh/api/RequestReplyCallback.java | 30 --
.../org/apache/eventmesh/api/SendCallback.java | 33 --
.../java/org/apache/eventmesh/api/SendResult.java | 46 --
.../eventmesh/api/admin/TopicProperties.java | 39 --
.../src/main/resources/kafka-client.properties | 135 ------
.../org.apache.io.openmessaging.producer.Producer | 20 -
.../src/test/resources/kafka-client.properties | 48 --
.../src/main/resources/pulsar-client.properties | 18 -
.../src/test/resources/pulsar-client.properties | 20 -
.../src/main/resources/rabbitmq-client.properties | 31 --
.../src/test/resources/rabbitmq-client.properties | 31 --
.../src/main/resources/redis-client.properties | 17 -
.../src/test/resources/redis-client.properties | 21 -
.../src/main/resources/rocketmq-client.properties | 21 -
.../rocketmq/promise/DefaultPromiseTest.java | 121 -----
.../src/test/resources/rocketmq-client.properties | 33 --
eventmesh-storage/gradle.properties | 16 -
.../eventmesh-webhook-receive/build.gradle | 2 +-
settings.gradle | 27 +-
428 files changed, 57 insertions(+), 13508 deletions(-)
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/Admin.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/Consumer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/ConnectorRuntimeException.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/factory/ConnectorPluginFactory.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/build.gradle
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/gradle.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/Constants.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/EventMeshConstants.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/config/ClientConfiguration.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/connector/ConnectorResourceServiceKafkaImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/ConsumerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerRunner.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-kafka/src/test/java/org/apache/eventmesh/connector/kafka/config/ClientConfigurationTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/build.gradle
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/gradle.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/KnativeMessageFactory.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeBinaryMessageReader.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeHeaders.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeMessageWriter.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/ClientConfiguration.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/DefaultConsumer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/PullConsumerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/domain/NonStandardKeys.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyContext.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyStatus.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshMessageListenerConcurrently.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/AbstractProducer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/ProducerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/utils/CloudEventUtils.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/main/resources/knative-client.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/config/ClientConfigurationTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImplTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImplTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-knative/src/test/resources/knative-client.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/README.md
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/build.gradle
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/gradle.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/pravega-connector.jpg
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConnectorResourceServiceImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConsumerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaProducerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaClient.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaCloudEventWriter.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaEvent.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/SubscribeTask.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfig.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/exception/PravegaConnectorException.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/main/resources/pravega-connector.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/client/PravegaClientTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfigTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pravega/src/test/resources/pravega-connector.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/build.gradle
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/gradle.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/client/PulsarClientWrapper.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ClientConfiguration.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/connector/ConnectorResourceServicePulsarImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/constant/PulsarConstant.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/consumer/PulsarConsumerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/AbstractProducer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/ProducerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/PulsarProducerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/utils/CloudEventUtils.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-pulsar/src/test/java/org/apache/eventmesh/connector/pulsar/config/ClientConfigurationTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/build.gradle
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/gradle.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqClient.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqConnectionFactory.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEvent.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventWriter.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolder.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/connector/RabbitmqConnectorResourceService.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerHandler.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/exception/RabbitmqaConnectorException.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/utils/ByteArrayUtils.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqMockConnectionFactory.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqServer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolderTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducerTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/build.gradle
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/gradle.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/client/RedissonClient.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/cloudevent/CloudEventCodec.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/RedisProperties.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/connector/RedisConnectorResourceService.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/producer/RedisProducer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/AbstractRedisServer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/client/RedissonClientTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/config/RedisPropertiesTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/connector/UnitTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumerTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/producer/RedisProducerTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/build.gradle
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/gradle.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdmin.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdminAdaptor.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/command/Command.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/RocketMQMessageFactory.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQHeaders.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQMessageWriter.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/EventMeshConstants.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfig.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/connector/ConnectorResourceServiceRocketmqImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQMessageFormatException.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQTimeoutException.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/AbstractProducer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/BeanUtils.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/OMSUtil.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfigurationTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/producer/DefaultProducerImplTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/build.gradle
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/gradle.properties
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdmin.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdminAdaptor.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/MessageQueue.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBroker.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/MessageEntity.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/TopicMetadata.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/HistoryMessageClearTask.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/SubScribeTask.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumerAdaptor.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducer.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducerAdaptor.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/resource/StandaloneConnectorResourceService.java
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
delete mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/test/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBrokerTest.java
rename {eventmesh-connector-plugin => eventmesh-storage-plugin}/build.gradle
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/build.gradle (100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/gradle.properties (100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/AbstractContext.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/EventListener.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/LifeCycle.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/SendCallback.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/SendResult.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/admin/Admin.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-storage-plugin/eventmesh-storage-api}/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/consumer/Consumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/exception/StorageConnectorRuntimeException.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/factory/StoragePluginFactory.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/storage/StorageResourceService.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/build.gradle (92%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/common/Constants.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/common/EventMeshConstants.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/config/ClientConfiguration.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/consumer/ConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/consumer/KafkaConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/consumer/KafkaConsumerRunner.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/producer/KafkaProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/producer/ProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/java/org/apache/eventmesh/storage/kafka/storage/StorageResourceServiceKafkaImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-kafka =>
eventmesh-storage-plugin/eventmesh-storage-kafka}/src/main/resources/kafka-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-kafka/src/test/java/org/apache/eventmesh/storage/kafka/config/ClientConfigurationTest.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-kafka =>
eventmesh-storage-plugin/eventmesh-storage-kafka}/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-kafka =>
eventmesh-storage-plugin/eventmesh-storage-kafka}/src/test/resources/kafka-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/build.gradle (91%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/client/MongodbClientManager.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigKey.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/config/ConfigurationHolder.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/constant/MongodbConstants.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/consumer/MongodbConsumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/consumer/MongodbReplicaSetConsumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/consumer/MongodbStandaloneConsumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/exception/MongodbStorageException.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/producer/MongodbProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/producer/MongodbReplicaSetProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/producer/MongodbStandaloneProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/storage/MongodbStorageResourceService.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/utils/MongodbCloudEventUtil.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/java/org/apache/eventmesh/storage/mongodb/utils/MongodbSequenceUtil.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/main/resources/mongodb-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/test/java/org/apache/eventmesh/storage/mongodb/MongodbConnectorTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/test/java/org/apache/eventmesh/storage/mongodb/MongodbServer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/test/java/org/apache/eventmesh/storage/mongodb/MongodbServerTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-mongodb/src/test/resources/mongodb-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/README.md (100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/build.gradle (95%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/pravega-storage.jpg (100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/PravegaStorageResourceServiceImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/client/PravegaClient.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/client/PravegaCloudEventWriter.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/client/PravegaEvent.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/client/SubscribeTask.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/config/PravegaStorageConfig.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/java/org/apache/eventmesh/storage/pravega/exception/PravegaStorageException.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/main/resources/pravega-storage.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/test/java/org/apache/eventmesh/storage/pravega/client/PravegaClientTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/test/java/org/apache/eventmesh/storage/pravega/config/PravegaStorageConfigTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pravega/src/test/resources/pravega-storage.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/build.gradle (91%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/client/PulsarClientWrapper.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/config/ClientConfiguration.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/constant/PulsarConstant.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/consumer/PulsarConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/producer/AbstractProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/producer/ProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/producer/PulsarProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/storage/StorageResourceServicePulsarImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/java/org/apache/eventmesh/storage/pulsar/utils/CloudEventUtils.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-pulsar =>
eventmesh-storage-plugin/eventmesh-storage-pulsar}/src/main/resources/pulsar-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-pulsar/src/test/java/org/apache/eventmesh/storage/pulsar/config/ClientConfigurationTest.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-pulsar =>
eventmesh-storage-plugin/eventmesh-storage-pulsar}/src/test/resources/pulsar-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/build.gradle (91%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/client/RabbitmqClient.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/client/RabbitmqConnectionFactory.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/cloudevent/RabbitmqCloudEvent.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/cloudevent/RabbitmqCloudEventWriter.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/config/ConfigurationHolder.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/consumer/RabbitmqConsumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/consumer/RabbitmqConsumerHandler.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/exception/RabbitmqStorageException.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/producer/RabbitmqProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/storage/RabbitmqStorageResourceService.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/java/org/apache/eventmesh/storage/rabbitmq/utils/ByteArrayUtils.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-rabbitmq =>
eventmesh-storage-plugin/eventmesh-storage-rabbitmq}/src/main/resources/rabbitmq-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage/rabbitmq/RabbitmqMockConnectionFactory.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage/rabbitmq/RabbitmqServer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage/rabbitmq/cloudevent/RabbitmqCloudEventTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage/rabbitmq/config/ConfigurationHolderTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage/rabbitmq/consumer/RabbitmqConsumerTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rabbitmq/src/test/java/org/apache/eventmesh/storage/rabbitmq/producer/RabbitmqProducerTest.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-rabbitmq =>
eventmesh-storage-plugin/eventmesh-storage-rabbitmq}/src/test/resources/rabbitmq-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/build.gradle (96%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/client/RedissonClient.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/cloudevent/CloudEventCodec.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/config/RedisProperties.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/consumer/RedisConsumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/producer/RedisProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/main/java/org/apache/eventmesh/storage/redis/storage/RedisStorageResourceService.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-redis =>
eventmesh-storage-plugin/eventmesh-storage-redis}/src/main/resources/redis-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage/redis/AbstractRedisServer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage/redis/client/RedissonClientTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage/redis/config/RedisPropertiesTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage/redis/connector/UnitTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage/redis/consumer/RedisConsumerTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-redis/src/test/java/org/apache/eventmesh/storage/redis/producer/RedisProducerTest.java
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-redis =>
eventmesh-storage-plugin/eventmesh-storage-redis}/src/test/resources/redis-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/build.gradle (93%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/admin/RocketMQAdmin.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/admin/RocketMQAdminAdaptor.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/admin/command/Command.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/cloudevent/RocketMQMessageFactory.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/cloudevent/impl/RocketMQHeaders.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/cloudevent/impl/RocketMQMessageWriter.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/common/EventMeshConstants.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/config/ClientConfig.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/config/ClientConfiguration.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/consumer/PushConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/consumer/RocketMQConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/domain/NonStandardKeys.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/exception/RMQMessageFormatException.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/exception/RMQTimeoutException.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/patch/EventMeshMessageListenerConcurrently.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/AbstractProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/ProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/producer/RocketMQProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/storage/StorageResourceServiceRocketmqImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/utils/BeanUtils.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/utils/CloudEventUtils.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/eventmesh/storage/rocketmq/utils/OMSUtil.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage-plugin/eventmesh-storage-rocketmq}/src/main/resources/rocketmq-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage/rocketmq/config/ClientConfigurationTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage/rocketmq/consumer/PushConsumerImplTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage/rocketmq/producer/DefaultProducerImplTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage/rocketmq/producer/ProducerImplTest.java
(100%)
rename
{eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache
=>
eventmesh-storage-plugin/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage}/rocketmq/promise/DefaultPromiseTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage/rocketmq/utils/BeanUtilsTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
(100%)
rename {eventmesh-connector-plugin/eventmesh-connector-rocketmq =>
eventmesh-storage-plugin/eventmesh-storage-rocketmq}/src/test/resources/rocketmq-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/build.gradle (93%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/admin/StandaloneAdmin.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/admin/StandaloneAdminAdaptor.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/MessageQueue.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/StandaloneBroker.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/model/MessageEntity.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/model/TopicMetadata.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/task/HistoryMessageClear.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/task/HistoryMessageClearTask.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/task/Subscribe.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/broker/task/SubscribeTask.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/consumer/StandaloneConsumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/consumer/StandaloneConsumerAdaptor.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/producer/StandaloneProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/producer/StandaloneProducerAdaptor.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/java/org/apache/eventmesh/storage/standalone/resource/StandaloneStorageResourceService.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.storage.StorageResourceService
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/TestUtils.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/admin/StandaloneAdminTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/broker/MessageQueueTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/broker/StandaloneBrokerTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/broker/task/HistoryMessageClearTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/broker/task/SubscribeTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/consumer/StandaloneConsumerTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-storage-plugin}/eventmesh-storage-standalone/src/test/java/org/apache/eventmesh/storage/standalone/producer/StandaloneProducerTest.java
(100%)
rename {eventmesh-connector-plugin =>
eventmesh-storage-plugin}/gradle.properties (100%)
delete mode 100644 eventmesh-storage/build.gradle
delete mode 100644 eventmesh-storage/eventmesh-storage-api/build.gradle
delete mode 100644 eventmesh-storage/eventmesh-storage-api/gradle.properties
delete mode 100644
eventmesh-storage/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
delete mode 100644
eventmesh-storage/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
delete mode 100644
eventmesh-storage/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/EventListener.java
delete mode 100644
eventmesh-storage/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
delete mode 100644
eventmesh-storage/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
delete mode 100644
eventmesh-storage/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/LifeCycle.java
delete mode 100644
eventmesh-storage/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java
delete mode 100644
eventmesh-storage/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/SendCallback.java
delete mode 100644
eventmesh-storage/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/SendResult.java
delete mode 100644
eventmesh-storage/eventmesh-storage-api/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
delete mode 100644
eventmesh-storage/eventmesh-storage-kafka/src/main/resources/kafka-client.properties
delete mode 100644
eventmesh-storage/eventmesh-storage-kafka/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
delete mode 100644
eventmesh-storage/eventmesh-storage-kafka/src/test/resources/kafka-client.properties
delete mode 100644
eventmesh-storage/eventmesh-storage-pulsar/src/main/resources/pulsar-client.properties
delete mode 100644
eventmesh-storage/eventmesh-storage-pulsar/src/test/resources/pulsar-client.properties
delete mode 100644
eventmesh-storage/eventmesh-storage-rabbitmq/src/main/resources/rabbitmq-client.properties
delete mode 100644
eventmesh-storage/eventmesh-storage-rabbitmq/src/test/resources/rabbitmq-client.properties
delete mode 100644
eventmesh-storage/eventmesh-storage-redis/src/main/resources/redis-client.properties
delete mode 100644
eventmesh-storage/eventmesh-storage-redis/src/test/resources/redis-client.properties
delete mode 100644
eventmesh-storage/eventmesh-storage-rocketmq/src/main/resources/rocketmq-client.properties
delete mode 100644
eventmesh-storage/eventmesh-storage-rocketmq/src/test/java/org/apache/eventmesh/storage/rocketmq/promise/DefaultPromiseTest.java
delete mode 100644
eventmesh-storage/eventmesh-storage-rocketmq/src/test/resources/rocketmq-client.properties
delete mode 100644 eventmesh-storage/gradle.properties
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
