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 eeaff3c3d Merge pull request #3355 from
apache/revert-3354-eventmesh-3353
add a85788ea9 Revert "split storage and connectors"
new 935c2f278 Merge pull request #3356 from apache/revert-3350-master
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 | 0
.../eventmesh-connector-api/build.gradle | 0
.../eventmesh-connector-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
.../api/connector/ConnectorResourceService.java | 0
.../apache/eventmesh/api/consumer/Consumer.java | 0
.../api/exception/ConnectorRuntimeException.java | 0
.../api/exception/OnExceptionContext.java | 0
.../api/factory/ConnectorPluginFactory.java | 0
.../apache/eventmesh/api/producer/Producer.java | 0
.../eventmesh-connector-kafka/build.gradle | 0
.../eventmesh-connector-kafka/gradle.properties | 0
.../connector/kafka/common/Constants.java | 0
.../connector/kafka/common/EventMeshConstants.java | 0
.../kafka/config/ClientConfiguration.java | 0
.../ConnectorResourceServiceKafkaImpl.java | 0
.../connector/kafka/consumer/ConsumerImpl.java | 0
.../kafka/consumer/KafkaConsumerImpl.java | 0
.../kafka/consumer/KafkaConsumerRunner.java | 0
.../kafka/producer/KafkaProducerImpl.java | 0
.../connector/kafka/producer/ProducerImpl.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 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-connector-knative/build.gradle | 0
.../eventmesh-connector-knative/gradle.properties | 0
.../knative/cloudevent/KnativeMessageFactory.java | 0
.../impl/KnativeBinaryMessageReader.java | 0
.../knative/cloudevent/impl/KnativeHeaders.java | 0
.../cloudevent/impl/KnativeMessageWriter.java | 0
.../knative/config/ClientConfiguration.java | 0
.../ConnectorResourceServiceKnativeImpl.java | 0
.../knative/consumer/DefaultConsumer.java | 0
.../knative/consumer/KnativeConsumerImpl.java | 0
.../knative/consumer/PullConsumerImpl.java | 0
.../connector/knative/domain/NonStandardKeys.java | 0
.../patch/EventMeshConsumeConcurrentlyContext.java | 0
.../patch/EventMeshConsumeConcurrentlyStatus.java | 0
.../EventMeshMessageListenerConcurrently.java | 0
.../knative/producer/AbstractProducer.java | 0
.../knative/producer/KnativeProducerImpl.java | 0
.../connector/knative/producer/ProducerImpl.java | 0
.../connector/knative/utils/CloudEventUtils.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../src/main/resources/knative-client.properties | 0
.../knative/config/ClientConfigurationTest.java | 0
.../knative/consumer/KnativeConsumerImplTest.java | 0
.../knative/producer/KnativeProducerImplTest.java | 0
.../src/test/resources/knative-client.properties | 0
.../eventmesh-connector-pravega/README.md | 0
.../eventmesh-connector-pravega/build.gradle | 0
.../eventmesh-connector-pravega/gradle.properties | 0
.../pravega-connector.jpg | Bin
.../PravegaConnectorResourceServiceImpl.java | 0
.../connector/pravega/PravegaConsumerImpl.java | 0
.../connector/pravega/PravegaProducerImpl.java | 0
.../connector/pravega/client/PravegaClient.java | 0
.../pravega/client/PravegaCloudEventWriter.java | 0
.../connector/pravega/client/PravegaEvent.java | 0
.../connector/pravega/client/SubscribeTask.java | 0
.../pravega/config/PravegaConnectorConfig.java | 0
.../exception/PravegaConnectorException.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../main/resources/pravega-connector.properties | 0
.../pravega/client/PravegaClientTest.java | 0
.../pravega/config/PravegaConnectorConfigTest.java | 0
.../test/resources/pravega-connector.properties | 0
.../eventmesh-connector-pulsar/build.gradle | 0
.../eventmesh-connector-pulsar/gradle.properties | 0
.../pulsar/client/PulsarClientWrapper.java | 0
.../pulsar/config/ClientConfiguration.java | 0
.../ConnectorResourceServicePulsarImpl.java | 0
.../pulsar/consumer/PulsarConsumerImpl.java | 0
.../pulsar/producer/AbstractProducer.java | 0
.../connector/pulsar/producer/ProducerImpl.java | 0
.../pulsar/producer/PulsarProducerImpl.java | 0
.../connector/pulsar/utils/CloudEventUtils.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../src/main/resources/pulsar-client.properties | 0
.../pulsar/config/ClientConfigurationTest.java | 0
.../src/test/resources/pulsar-client.properties | 0
.../eventmesh-connector-rabbitmq/build.gradle | 0
.../eventmesh-connector-rabbitmq/gradle.properties | 0
.../connector/rabbitmq/client/RabbitmqClient.java | 0
.../rabbitmq/client/RabbitmqConnectionFactory.java | 0
.../rabbitmq/cloudevent/RabbitmqCloudEvent.java | 0
.../cloudevent/RabbitmqCloudEventWriter.java | 0
.../rabbitmq/config/ConfigurationHolder.java | 120 ++++++++++-----------
.../RabbitmqConnectorResourceService.java | 0
.../rabbitmq/consumer/RabbitmqConsumer.java | 0
.../rabbitmq/consumer/RabbitmqConsumerHandler.java | 0
.../exception/RabbitmqaConnectorException.java | 0
.../rabbitmq/producer/RabbitmqProducer.java | 0
.../connector/rabbitmq/utils/ByteArrayUtils.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../src/main/resources/rabbitmq-client.properties | 0
.../rabbitmq/RabbitmqMockConnectionFactory.java | 0
.../connector/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-connector-redis/build.gradle | 0
.../eventmesh-connector-redis/gradle.properties | 0
.../connector/redis/client/RedissonClient.java | 0
.../redis/cloudevent/CloudEventCodec.java | 0
.../connector/redis/config/RedisProperties.java | 0
.../connector/RedisConnectorResourceService.java | 0
.../connector/redis/consumer/RedisConsumer.java | 0
.../connector/redis/producer/RedisProducer.java | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../src/main/resources/redis-client.properties | 0
.../connector/redis/AbstractRedisServer.java | 0
.../connector/redis/client/RedissonClientTest.java | 0
.../redis/config/RedisPropertiesTest.java | 0
.../connector/redis/connector/UnitTest.java | 0
.../redis/consumer/RedisConsumerTest.java | 0
.../redis/producer/RedisProducerTest.java | 0
.../src/test/resources/redis-client.properties | 0
.../eventmesh-connector-rocketmq/build.gradle | 0
.../eventmesh-connector-rocketmq/gradle.properties | 0
.../connector/rocketmq/admin/RocketMQAdmin.java | 0
.../rocketmq/admin/RocketMQAdminAdaptor.java | 0
.../connector/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
.../connector/rocketmq/config/ClientConfig.java | 0
.../rocketmq/config/ClientConfiguration.java | 0
.../ConnectorResourceServiceRocketmqImpl.java | 0
.../rocketmq/consumer/PushConsumerImpl.java | 0
.../rocketmq/consumer/RocketMQConsumerImpl.java | 0
.../connector/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
.../connector/rocketmq/producer/ProducerImpl.java | 0
.../rocketmq/producer/RocketMQProducerImpl.java | 0
.../connector/rocketmq/utils/BeanUtils.java | 0
.../connector/rocketmq/utils/CloudEventUtils.java | 0
.../connector/rocketmq/utils/OMSUtil.java | 0
.../ConsumeMessageConcurrentlyService.java | 0
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../src/main/resources/rocketmq-client.properties | 0
.../rocketmq/config/ClientConfigurationTest.java | 0
.../producer/DefaultProducerImplTest.java | 0
.../rocketmq/consumer/PushConsumerImplTest.java | 0
.../apache/rocketmq/producer/ProducerImplTest.java | 0
.../rocketmq/promise/DefaultPromiseTest.java | 0
.../org/apache/rocketmq/utils/BeanUtilsTest.java | 0
.../org.apache.io.openmessaging.producer.Producer | 0
.../src/test/resources/rocketmq-client.properties | 0
.../eventmesh-connector-standalone/build.gradle | 0
.../gradle.properties | 0
.../standalone/admin/StandaloneAdmin.java | 0
.../standalone/admin/StandaloneAdminAdaptor.java | 0
.../connector/standalone/broker/MessageQueue.java | 0
.../standalone/broker/StandaloneBroker.java | 0
.../standalone/broker/model/MessageEntity.java | 0
.../standalone/broker/model/TopicMetadata.java | 0
.../broker/task/HistoryMessageClearTask.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
.../StandaloneConnectorResourceService.java | 0
.../eventmesh/org.apache.eventmesh.api.admin.Admin | 0
...ventmesh.api.connector.ConnectorResourceService | 0
.../org.apache.eventmesh.api.consumer.Consumer | 0
.../org.apache.eventmesh.api.producer.Producer | 0
.../standalone/broker/StandaloneBrokerTest.java | 0
.../gradle.properties | 0
eventmesh-connectors/README | 1 -
207 files changed, 60 insertions(+), 61 deletions(-)
rename {eventmesh-storage => eventmesh-connector-plugin}/build.gradle (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/build.gradle (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventListener.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/LifeCycle.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendCallback.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendResult.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/Admin.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/admin/TopicProperties.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/Consumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/ConnectorRuntimeException.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/factory/ConnectorPluginFactory.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/build.gradle (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/Constants.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/common/EventMeshConstants.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/config/ClientConfiguration.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/connector/ConnectorResourceServiceKafkaImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/ConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/consumer/KafkaConsumerRunner.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/KafkaProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/java/org/apache/eventmesh/connector/kafka/producer/ProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/main/resources/kafka-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/test/java/org/apache/eventmesh/connector/kafka/config/ClientConfigurationTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-kafka/src/test/resources/kafka-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/build.gradle (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/KnativeMessageFactory.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeBinaryMessageReader.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeHeaders.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/cloudevent/impl/KnativeMessageWriter.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/config/ClientConfiguration.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/connector/ConnectorResourceServiceKnativeImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/DefaultConsumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/consumer/PullConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/domain/NonStandardKeys.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyContext.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshConsumeConcurrentlyStatus.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/patch/EventMeshMessageListenerConcurrently.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/AbstractProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/producer/ProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/java/org/apache/eventmesh/connector/knative/utils/CloudEventUtils.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/main/resources/knative-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/config/ClientConfigurationTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/consumer/KnativeConsumerImplTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/test/java/org/apache/eventmesh/connector/knative/producer/KnativeProducerImplTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-knative/src/test/resources/knative-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/README.md (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/build.gradle (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/pravega-connector.jpg
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConnectorResourceServiceImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/PravegaProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaClient.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaCloudEventWriter.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/PravegaEvent.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/client/SubscribeTask.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfig.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/java/org/apache/eventmesh/connector/pravega/exception/PravegaConnectorException.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/main/resources/pravega-connector.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/client/PravegaClientTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/test/java/org/apache/eventmesh/connector/pravega/config/PravegaConnectorConfigTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pravega/src/test/resources/pravega-connector.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/build.gradle (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/client/PulsarClientWrapper.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/config/ClientConfiguration.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/connector/ConnectorResourceServicePulsarImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/consumer/PulsarConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/AbstractProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/ProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/producer/PulsarProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/java/org/apache/eventmesh/connector/pulsar/utils/CloudEventUtils.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/main/resources/pulsar-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/test/java/org/apache/eventmesh/connector/pulsar/config/ClientConfigurationTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-pulsar/src/test/resources/pulsar-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/build.gradle (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/gradle.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqClient.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/client/RabbitmqConnectionFactory.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEvent.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventWriter.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolder.java
(96%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/connector/RabbitmqConnectorResourceService.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerHandler.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/exception/RabbitmqaConnectorException.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/java/org/apache/eventmesh/connector/rabbitmq/utils/ByteArrayUtils.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/main/resources/rabbitmq-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqMockConnectionFactory.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/RabbitmqServer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/cloudevent/RabbitmqCloudEventTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/config/ConfigurationHolderTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/consumer/RabbitmqConsumerTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/test/java/org/apache/eventmesh/connector/rabbitmq/producer/RabbitmqProducerTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rabbitmq/src/test/resources/rabbitmq-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/build.gradle (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/gradle.properties (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/client/RedissonClient.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/cloudevent/CloudEventCodec.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/config/RedisProperties.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/connector/RedisConnectorResourceService.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/main/java/org/apache/eventmesh/connector/redis/producer/RedisProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/main/resources/redis-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/AbstractRedisServer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/client/RedissonClientTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/config/RedisPropertiesTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/connector/UnitTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/consumer/RedisConsumerTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/test/java/org/apache/eventmesh/connector/redis/producer/RedisProducerTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-redis/src/test/resources/redis-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/build.gradle (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/gradle.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdmin.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/RocketMQAdminAdaptor.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/command/Command.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/RocketMQMessageFactory.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQHeaders.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQMessageWriter.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/common/EventMeshConstants.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfig.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/connector/ConnectorResourceServiceRocketmqImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQMessageFormatException.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQTimeoutException.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/AbstractProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/BeanUtils.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/OMSUtil.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/main/resources/rocketmq-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfigurationTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/producer/DefaultProducerImplTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/promise/DefaultPromiseTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-rocketmq/src/test/resources/rocketmq-client.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/build.gradle (100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/gradle.properties
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdmin.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/admin/StandaloneAdminAdaptor.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/MessageQueue.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBroker.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/MessageEntity.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/TopicMetadata.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/HistoryMessageClearTask.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/SubScribeTask.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumerAdaptor.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducer.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducerAdaptor.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/resource/StandaloneConnectorResourceService.java
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.admin.Admin
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(100%)
rename {eventmesh-storage =>
eventmesh-connector-plugin}/eventmesh-connector-standalone/src/test/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBrokerTest.java
(100%)
rename {eventmesh-storage => eventmesh-connector-plugin}/gradle.properties
(100%)
delete mode 100644 eventmesh-connectors/README
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
