This is an automated email from the ASF dual-hosted git repository. wqliang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
commit 935c2f278594cc44a1f116fe2be8ebbe2f0cc3d0 Merge: eeaff3c3d a85788ea9 Author: wqliang <[email protected]> AuthorDate: Tue Mar 7 11:02:46 2023 +0800 Merge pull request #3356 from apache/revert-3350-master Revert "split storage and connectors" .../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(-) --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
