This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch cloudevents
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git.
from 737c0f0 [ISSUE #274] Adding Eventmesh Stream component to support
Event Streaming (#445)
add 3da43aa fix netty options (#449)
add f26cc1c [ISSUE #456] Automatic License report and check (#462)
add b760873 [ISSUE #451] Fix SSLContext Initialize error (#458)
add 33571fa [ISSUE #457] message ack problem in retry or repush by
closeSession (#459)
add 00571d1 [ISSUE #461] fix global flow control problem (#469)
add 8c450e1 [ISSUE #460]Support custom retry times configuration when
SubcriptionType is SYNC (#463)
add 509104b [ISSUE #465]All third part dependencies should be controlled
at root build.gradle (#466)
add dcfc765 [ISSUE #468] ThreadUtilTest failed (#470)
add 9e172e8 [ISSUE #374] add unit test for header class. (#472)
add 0e4def2 maybe there is no need to use atomicboolean here (#474)
add 05e3421 [ISSUE #476] Biz Exceptions occured in EventMesh cause
connection close of client (#477)
add f8f2fdb Update CONTRIBUTING.zh-CN.md
add 1a924b6 Update CONTRIBUTING.md
add 4bc1a0a Add SPI design docs (#480)
add fefe391 fix configuration property get error (#479)
add 339d58c Update README.md
add 4e3211d Update README.zh-CN.md
add d5ac681 [ISSUE #484] Support access control for EventMesh (#485)
add 8c72f23 Update README.md
add 31a3825 Update README.zh-CN.md
add bd6321c remove webank lisence
add 81d5be6 Add files via upload
add c365fa0 use RandomStringGenerator instead deprecated class
RandomStringUtils (#495)
add f545bae Add files via upload
add 879c77f [ISSUE #496] fix the ClassCastException (#499)
add dadaf39 [ISSUE #340]merge otel metric branch 2 develop (#494)
add 9899c25 [ISSUE #492] Support resources initilization and release of
connector in EventMesh (#493)
add a62bf65 [ISSUE #488]Support registry adaptor plugin (#489)
add 95db813 polish quickstart (#504)
add aeed6f5 [ISSUE #339] add design doc for integrating OpenSchema (#502)
add d46b8bd otel metric polish (#503)
add 19af7cf [ISSUE #490] Support service invocation (#508)
add 106ca96 [ISSUE #505]remove all RandomStringUtils. (#510)
add 6c222cc add http trace http point. (#509)
add ed57833 Improve the directory structure of docs (#516)
add d89b309 change eventmesh-test to eventmesh-examples
add 16ae31a change eventmesh-test to eventmesh-examples
add bd8d736 [ISSUE #435] Initial Creation of eventMesh-admin module in
EventMesh (#513)
add 84b2f4d Issue #405 Fix SubscriptionType typo error (#522)
add f12bf52 [ISSUE #375] In memory as event store (#507)
add 3510c83 [ISSUE #339] Add a skeleton for separated openschema registry
service and implement most APIs that doesn't need compatibility check. (#525)
add 9831b0e Lint and fix style of Markdown files in docs (#533)
add 537ed82 Implement the conversion from openmessaging to cloudevent
(#514)
add bc610f9 rename name and package path of schema-registry module
add 9c1d21f [ISSUE #541] rename issue (#542)
add 546765e [Issue #523] Adding Flow control RateLimiter support in Http
Message Send Processor (#524)
add b9abbcd [Issue #528] enhance Retry support for HTTP and TCP
processors. (#529)
add 87d6d8b update readme
add 4b2fef9 update quickstart
add 6b7280a [ISSUE #367] Optimize plugin load (#519)
add bdf226a update namesrv registry name
add 8b6c827 add weighted random load balance selector (#526)
add 6068be3 Update README.md
add d1972ac Update README.md
add 36ea9a6 Update the checkstyle file and remove code style file (#552)
add 66d6159 Change issue template to yml (#521)
add e2adda8 [Issue #554] Removing hardcoded username and password in the
project code (#555)
add 2a64e79 Fix issue template (#556)
add 62d2067 Preview docs (#543)
add b652be9 [ISSUE #550] Remove unused jar in plugin module (#551)
add 9337efc Revert "[Issue #554] Removing hardcoded username and password
in the project code (#555)" (#559)
add a4a4a9f [ISSUE #550] Deduplicate plugin jar (#558)
add af56653 [ISSUE #536] fix OpenSchemaRegistryApplication start error
(#561)
add dd3385f [Issue#554] removing hardcoded username and password (#560)
add c8410af Update .asf.yaml
add 3e75d4f [ISSUE #565] Update JarExtensionClassLoader.java (#566)
add bdd9aa0 [Issue #567] Optimize config file location (#568)
add 1c471bf Update .asf.yaml
add cc5b4c9 contributing guide edit import check style step (#573)
add 25c2515 [WIP][ISSUE #482]Add protocol adaptor plugin (#572)
new 6f57a90 readme.md
add bfa9798 update eventmesh-runtime.png
add b60ebbe Add files via upload
add 3379af4 update README.md
add e99aa2d upload wechat-official png
add 87a53b9 update README
add 4e7be93 update README
add 062fa57 [Feature #564] Support CloudEvents protocols for pub/sub in
EventMesh-feature design (#574)
new 88f8ffc Merge branch 'develop' of
https://github.com/apache/incubator-eventmesh into develop
The 2 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:
.asf.yaml | 3 +-
.github/ISSUE_TEMPLATE/bug_report.md | 42 -
.github/ISSUE_TEMPLATE/bug_report.yml | 91 ++
.github/ISSUE_TEMPLATE/documentation_related.md | 11 -
.github/ISSUE_TEMPLATE/documentation_related.yml | 60 ++
.github/ISSUE_TEMPLATE/enhancement_request.md | 36 -
.github/ISSUE_TEMPLATE/enhancement_request.yml | 70 ++
.github/ISSUE_TEMPLATE/feature_request.md | 37 -
.github/ISSUE_TEMPLATE/feature_request.yml | 62 ++
.github/ISSUE_TEMPLATE/question.md | 11 -
.github/ISSUE_TEMPLATE/question.yml | 51 +
.github/workflows/ci.yml | 4 +-
.gitignore | 3 +-
CONTRIBUTING.md | 42 +-
CONTRIBUTING.zh-CN.md | 46 +-
README.md | 118 ++-
README.zh-CN.md | 16 +-
build.gradle | 285 ++---
docs/.vuepress/config.js | 93 --
docs/.vuepress/public/images/bus.png | Bin 105121 -> 0 bytes
docs/.vuepress/public/images/eventmesh-arch.png | Bin 45297 -> 0 bytes
docs/.vuepress/public/images/eventmesh-define.png | Bin 19431 -> 0 bytes
.../public/images/eventmesh-landscape.png | Bin 33151 -> 0 bytes
docs/.vuepress/public/images/eventmesher.png | Bin 91666 -> 0 bytes
.../public/images/features/RR-call-p1.png | Bin 13792 -> 0 bytes
...a-distributing-architecture-in-financial-EN.png | Bin 49874 -> 0 bytes
.../a-distributing-architecture-in-financial.png | Bin 49865 -> 0 bytes
.../images/features/adjust-queue-expand-p1.png | Bin 26604 -> 0 bytes
.../images/features/adjust-queue-shrink-p1.png | Bin 43400 -> 0 bytes
.../public/images/features/architecture-p1.png | Bin 29028 -> 0 bytes
.../.vuepress/public/images/features/broadcast.png | Bin 28016 -> 0 bytes
.../public/images/features/circuit-break-p1.png | Bin 17847 -> 0 bytes
.../public/images/features/dark-launch-p1.png | Bin 30959 -> 0 bytes
.../public/images/features/invoke_nearby-p1.png | Bin 54826 -> 0 bytes
.../.vuepress/public/images/features/multicast.png | Bin 28170 -> 0 bytes
.../public/images/features/subscribe-nearby-p1.png | Bin 24447 -> 0 bytes
.../public/images/features/tongchengduohuo-p1.png | Bin 160110 -> 0 bytes
docs/.vuepress/public/images/features/unicast.png | Bin 18522 -> 0 bytes
docs/.vuepress/public/images/mesh-helper.png | Bin 44009 -> 0 bytes
docs/.vuepress/public/images/qqgroup-crcode.png | Bin 25916 -> 0 bytes
docs/README.md | 90 --
docs/_config.yml | 20 -
docs/cn/blog/.gitkeep | 0
docs/cn/community/.gitkeep | 0
docs/cn/documentation/.gitkeep | 0
docs/cn/documentation/_category_.json | 4 +
docs/cn/features/_category_.json | 4 +
docs/cn/features/{https.zh-CN.md => https.md} | 6 +-
docs/cn/features/spi.md | 112 ++
docs/cn/instructions/_category_.json | 4 +
docs/cn/instructions/eclipse.zh-CN.md | 33 +
...ocol.zh-CN.md => eventmesh-runtime-protocol.md} | 6 +-
...rt.zh-CN.md => eventmesh-runtime-quickstart.md} | 41 +-
...t.zh-CN.md => eventmesh-sdk-java-quickstart.md} | 2 +-
...tart.zh-CN.md => eventmesh-store-quickstart.md} | 4 +-
.../{quickstart.zh-CN.md => quickstart.md} | 53 +-
docs/cn/{README.md => intro.md} | 0
docs/en/blog/.gitkeep | 0
docs/en/community/.gitkeep | 0
docs/en/documentation/.gitkeep | 0
docs/en/documentation/_category_.json | 4 +
docs/en/features/_category_.json | 4 +
.../features/eventmesh-cloudevents-sdk-binding.md | 80 +-
.../en/features/eventmesh-metrics-export-design.md | 47 +
.../en/features/eventmesh-schemaregistry-design.md | 138 +++
docs/en/features/https.md | 4 +-
docs/en/features/spi.md | 117 +++
docs/en/instructions/_category_.json | 4 +
docs/en/instructions/eventmesh-runtime-protocol.md | 8 +-
.../eventmesh-runtime-quickstart-with-docker.md | 74 ++
.../instructions/eventmesh-runtime-quickstart.md | 248 +----
.../instructions/eventmesh-sdk-java-quickstart.md | 2 +-
docs/en/instructions/quickstart.md | 21 -
docs/en/{README.md => intro.md} | 0
docs/eventmesh.md | 37 -
docs/images/eventmesh-arch2.png | Bin 0 -> 103686 bytes
docs/images/eventmesh-runtime.png | Bin 1726098 -> 2101892
bytes
.../features/eventmesh-schemaregistry-arch.png | Bin 0 -> 34053 bytes
.../features/eventmesh-schemaregistry-process.jpg | Bin 0 -> 794647 bytes
.../eventmesh-schemaregistry-projectstructure.png | Bin 0 -> 45279 bytes
docs/images/wechat-official.jpg | Bin 0 -> 28051 bytes
docs/images/wechat-official.png | Bin 0 -> 21067 bytes
eventmesh-admin/README.md | 53 +
{eventmesh-common => eventmesh-admin}/build.gradle | 5 +-
.../gradle.properties | 3 +-
eventmesh-common/build.gradle | 64 +-
eventmesh-common/gradle.properties | 3 -
.../apache/eventmesh/common/RandomStringUtil.java} | 17 +-
.../eventmesh/common/command/HttpCommand.java | 52 +-
.../common/config/CommonConfiguration.java | 48 +-
.../common/config/ConfigurationWrapper.java | 28 +-
.../eventmesh/common/exception/JsonException.java | 17 +-
.../common/loadbalance/LoadBalanceType.java | 3 +-
...r.java => WeightRandomLoadBalanceSelector.java} | 48 +-
.../common/protocol/SubscriptionItem.java | 8 +-
...{SubcriptionType.java => SubscriptionType.java} | 4 +-
.../http/body/client/HeartbeatRequestBody.java | 36 +-
.../protocol/http/body/client/RegRequestBody.java | 31 +-
.../http/body/client/SubscribeRequestBody.java | 29 +-
.../http/body/client/UnRegRequestBody.java | 31 +-
.../http/body/client/UnSubscribeRequestBody.java | 29 +-
.../http/body/message/PushMessageRequestBody.java | 44 +-
.../http/body/message/ReplyMessageRequestBody.java | 42 +-
.../body/message/SendMessageBatchRequestBody.java | 49 +-
.../http/body/message/SendMessageRequestBody.java | 49 +-
.../protocol/http/common/EventMeshRetCode.java | 4 +-
.../http/header/client/RegRequestHeader.java | 10 +-
.../http/header/client/SubscribeRequestHeader.java | 10 +-
.../header/client/UnSubscribeRequestHeader.java | 10 +-
.../header/message/PushMessageResponseHeader.java | 10 +-
.../header/message/ReplyMessageRequestHeader.java | 10 +-
.../message/SendMessageBatchRequestHeader.java | 10 +-
.../message/SendMessageBatchV2RequestHeader.java | 10 +-
.../header/message/SendMessageRequestHeader.java | 10 +-
.../apache/eventmesh/common/utils/JsonUtils.java | 83 ++
.../apache/eventmesh/common/ThreadUtilTest.java | 11 +-
.../WeightRandomLoadBalanceSelectorTest.java | 86 ++
.../PushMessageRequestHeaderTest.java} | 39 +-
.../PushMessageResponseHeaderTest.java} | 25 +-
.../message/ReplyMessageRequestHeaderTest.java | 61 ++
.../ReplyMessageResponseHeaderTest.java} | 20 +-
.../src/test/resources/configuration.properties | 2 +
eventmesh-connector-plugin/build.gradle | 23 +-
.../eventmesh-connector-api/build.gradle | 21 +-
.../eventmesh-connector-api/gradle.properties | 7 +-
.../api/connector/ConnectorResourceService.java | 22 +-
.../eventmesh/api/consumer/MeshMQPushConsumer.java | 3 +-
.../eventmesh/api/producer/MeshMQProducer.java | 7 +-
.../eventmesh-connector-rocketmq/build.gradle | 56 +-
.../eventmesh-connector-rocketmq/gradle.properties | 7 +-
.../ConnectorResourceServiceRocketmqImpl.java | 15 +-
.../rocketmq/consumer/RocketMQConsumerImpl.java | 78 +-
.../connector/rocketmq/producer/ProducerImpl.java | 78 +-
.../rocketmq/producer/RocketMQProducerImpl.java | 21 +-
.../connector/rocketmq/utils/OMSUtil.java | 8 +-
.../ConsumeMessageConcurrentlyService.java | 22 +-
...entmesh.api.connector.ConnectorResourceService} | 2 +-
.../src/main/resources}/rocketmq-client.properties | 0
.../eventmesh-connector-standalone}/build.gradle | 7 +-
.../gradle.properties | 4 +-
.../standalone}/MessagingAccessPointImpl.java | 16 +-
.../connector/standalone/broker/MessageQueue.java | 223 ++++
.../standalone/broker/StandaloneBroker.java | 143 +++
.../standalone/broker/model/MessageEntity.java | 72 ++
.../standalone/broker/model/TopicMetadata.java | 45 +-
.../broker/task/HistoryMessageClearTask.java | 69 ++
.../standalone/broker/task/SubScribeTask.java | 108 ++
.../standalone/consumer/StandaloneConsumer.java | 145 +++
.../StandaloneMeshMQPushConsumerAdaptor.java | 135 +++
.../producer/StandaloneMeshMQProducerAdaptor.java | 125 +++
.../standalone/producer/StandaloneProducer.java | 127 +++
.../StandaloneConnectorResourceService.java | 17 +-
...entmesh.api.connector.ConnectorResourceService} | 2 +-
...pache.eventmesh.api.consumer.MeshMQPushConsumer | 2 +-
...rg.apache.eventmesh.api.producer.MeshMQProducer | 2 +-
.../standalone/broker/StandaloneBrokerTest.java | 58 +
eventmesh-connector-plugin/gradle.properties | 7 +-
.../bin/http_pub.sh | 0
.../bin/http_sub.sh | 0
.../bin/tcp_pub.sh | 0
.../bin/tcp_pub_broadcast.sh | 0
.../bin/tcp_sub.sh | 0
.../bin/tcp_sub_broadcast.sh | 0
.../build.gradle | 14 +-
.../gradle.properties | 1 -
.../eventmesh/http/demo/AsyncPublishInstance.java | 6 +-
.../http/demo/AsyncSyncRequestInstance.java | 6 +-
.../eventmesh/http/demo/SyncRequestInstance.java | 6 +-
.../http/demo/sub/SpringBootDemoApplication.java | 4 +-
.../http/demo/sub/controller/SubController.java | 16 +-
.../http/demo/sub/service/SubService.java | 4 +-
.../tcp/common/EventMeshTestCaseTopicSet.java | 0
.../eventmesh/tcp/common/EventMeshTestUtils.java | 0
.../apache/eventmesh/tcp/demo/AsyncPublish.java | 0
.../eventmesh/tcp/demo/AsyncPublishBroadcast.java | 0
.../apache/eventmesh/tcp/demo/AsyncSubscribe.java | 4 +-
.../tcp/demo/AsyncSubscribeBroadcast.java | 4 +-
.../org/apache/eventmesh/tcp/demo/SyncRequest.java | 0
.../apache/eventmesh/tcp/demo/SyncResponse.java | 4 +-
.../main/java/org/apache/eventmesh/util/Utils.java | 0
.../src/main/resources}/application.properties | 0
.../src/main/resources}/log4j2.xml | 0
.../src/main/resources}/server.env | 0
.../eventmesh-protocol-api}/build.gradle | 10 +-
.../eventmesh/protocol/api/ProtocolAdaptor.java | 61 ++
.../protocol/api/ProtocolPluginFactory.java | 55 +
.../api/exception/ProtocolHandleException.java | 20 +-
.../eventmesh-protocol-cloudevents}/build.gradle | 12 +-
.../cloudevents/CloudEventsProtocolAdaptor.java | 36 +-
.../cloudevents/CloudEventsProtocolConstant.java | 7 +-
...g.apache.eventmesh.protocol.api.ProtocolAdaptor | 2 +-
.../CloudEventsProtocolAdaptorTest.java | 26 +-
.../eventmesh-protocol-openmessage}/build.gradle | 14 +-
.../openmessage/OpenMessageProtocolAdaptor.java | 39 +-
.../openmessage/OpenMessageProtocolConstant.java | 12 +-
...g.apache.eventmesh.protocol.api.ProtocolAdaptor | 2 +-
.../OpenMessageProtocolAdaptorTest.java | 27 +-
.../build.gradle | 2 +-
.../eventmesh-registry-api}/build.gradle | 5 +-
.../eventmesh/api/exception/RegistryException.java | 12 +-
.../eventmesh/api/registry/RegistryService.java | 44 +
.../api/registry/dto/EventMeshDataInfo.java | 63 ++
.../api/registry/dto/EventMeshRegisterInfo.java | 58 +
.../api/registry/dto/EventMeshUnRegisterInfo.java | 28 +-
.../eventmesh-registry-namesrv}/build.gradle | 8 +-
.../namesrv/RegistryServiceNamesrvImpl.java | 63 ++
...g.apache.eventmesh.api.registry.RegistryService | 3 +-
eventmesh-runtime/bin/start.sh | 14 -
eventmesh-runtime/build.gradle | 48 +-
eventmesh-runtime/conf/eventmesh.properties | 24 +-
eventmesh-runtime/conf/log4j2.xml | 4 +
.../conf/prometheus.yml | 35 +-
eventmesh-runtime/gradle.properties | 4 -
.../java/org/apache/eventmesh/runtime/acl/Acl.java | 115 ++
.../admin/controller/ClientManageController.java | 14 +-
...er.java => QueryRecommendEventMeshHandler.java} | 61 +-
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 10 +-
.../runtime/boot/EventMeshHTTPServer.java | 39 +-
.../eventmesh/runtime/boot/EventMeshServer.java | 41 +-
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 103 +-
.../configuration/EventMeshHTTPConfiguration.java | 23 +-
.../configuration/EventMeshTCPConfiguration.java | 157 +--
.../runtime/connector/ConnectorResource.java | 24 +-
.../runtime/constants/EventMeshConstants.java | 2 +
.../runtime/core/plugin/MQProducerWrapper.java | 8 +-
.../protocol/cloudevent/OMSMessageFactory.java | 99 ++
.../cloudevent/impl/OMSBinaryMessageReader.java | 90 ++
.../core/protocol/cloudevent/impl/OMSHeaders.java | 36 +-
.../protocol/cloudevent/impl/OMSMessageWriter.java | 100 ++
.../core/protocol/http/async/AsyncContext.java | 13 +-
.../protocol/http/consumer/ConsumerManager.java | 120 ++-
.../http/processor/BatchSendMessageProcessor.java | 42 +-
.../processor/BatchSendMessageV2Processor.java | 33 +-
.../http/processor/HeartBeatProcessor.java | 24 +
.../http/processor/ReplyMessageProcessor.java | 19 +-
.../http/processor/SendAsyncMessageProcessor.java | 44 +-
.../http/processor/SendSyncMessageProcessor.java | 304 +++---
.../http/processor/SubscribeProcessor.java | 148 ++-
.../http/processor/UnSubscribeProcessor.java | 175 ++--
.../core/protocol/http/processor/inf/Client.java | 48 +-
.../protocol/http/producer/EventMeshProducer.java | 8 +-
.../protocol/http/push/AsyncHTTPPushRequest.java | 146 ++-
.../tcp/client/EventMeshTcpMessageDispatcher.java | 61 +-
.../tcp/client/group/ClientGroupWrapper.java | 431 ++++----
.../client/group/ClientSessionGroupMapping.java | 46 +
.../rebalance/EventMeshRebalanceService.java | 72 ++
.../rebalance/EventMeshRebalanceStrategy.java} | 7 +-
.../client/rebalance/EventmeshRebalanceImpl.java | 208 ++++
.../client/recommend/EventMeshRecommendImpl.java | 195 ++++
.../recommend/EventMeshRecommendStrategy.java} | 14 +-
.../client/session/push/DownStreamMsgContext.java | 101 +-
.../tcp/client/session/push/SessionPusher.java | 12 +-
.../session/push/retry/EventMeshTcpRetryer.java | 210 ----
.../client/session/retry/EventMeshTcpRetryer.java | 127 +++
.../client/session}/retry/RetryContext.java | 13 +-
.../tcp/client/session/send/SessionSender.java | 19 +-
.../client/session/send/UpStreamMsgContext.java | 115 +-
.../protocol/tcp/client/task/HeartBeatTask.java | 9 +
.../core/protocol/tcp/client/task/HelloTask.java | 9 +
.../protocol/tcp/client/task/MessageAckTask.java | 4 +-
.../tcp/client/task/MessageTransferTask.java | 60 +-
.../protocol/tcp/client/task/RecommendTask.java | 101 ++
.../protocol/tcp/client/task/SubscribeTask.java | 9 +
.../runtime/metrics/http/HTTPMetricsServer.java | 23 +
.../OpenTelemetryHTTPMetricsExporter.java | 309 ++++++
.../OpenTelemetryPrometheusExporter.java | 60 ++
.../OpenTelemetryTCPMetricsExporter.java | 106 ++
.../runtime/metrics/tcp/EventMeshTcpMonitor.java | 35 +
.../eventmesh/runtime/registry/Registry.java | 66 ++
.../eventmesh/runtime/util/EventMeshUtil.java | 15 +-
.../runtime/client/api/EventMeshClient.java | 6 +-
.../eventmesh/runtime/client/api/SubClient.java | 6 +-
.../runtime/client/common/MessageUtils.java | 22 +-
.../runtime/client/impl/EventMeshClientImpl.java | 10 +-
.../runtime/client/impl/SubClientImpl.java | 13 +-
.../eventmesh/runtime/cloudevent/CSVFormat.java | 107 ++
.../apache/eventmesh/runtime/cloudevent/Data.java | 197 ++++
.../runtime/cloudevent/OMSFactoryTest.java | 260 +++++
.../runtime/cloudevent/OMSWriterTest.java | 287 +++++
.../eventmesh/runtime/demo/AsyncSubClient.java | 4 +-
.../eventmesh/runtime/demo/BroadCastSubClient.java | 4 +-
.../apache/eventmesh/runtime/demo/CCSubClient.java | 4 +-
.../apache/eventmesh/runtime/demo/CClientDemo.java | 6 +-
.../eventmesh/runtime/demo/SyncSubClient.java | 4 +-
.../eventmesh/runtime/util/EventMeshUtilTest.java} | 17 +-
.../build.gradle | 3 +-
.../eventmesh-schema-registry-server}/build.gradle | 18 +-
.../server/OpenSchemaRegistryApplication.java | 11 +-
.../server/controller/CompatibilityController.java | 54 +
.../server/controller/SchemaController.java | 43 +
.../server/controller/SubjectController.java | 85 ++
.../registry/server/domain/Compatibility.java | 17 +-
.../schema/registry/server/domain/Schema.java | 38 +-
.../server/domain/SchemaWithSubjectName.java | 59 ++
.../schema/registry/server/domain/Subject.java | 60 ++
.../registry/server/domain/SubjectWithSchema.java | 57 +
.../server/enumerate/CompatibilityEnum.java | 33 +
.../registry/server/exception/ErrorResponse.java | 19 +-
.../registry/server/exception/ExceptionEnum.java | 42 +
.../server/exception/OpenSchemaException.java | 30 +-
.../exception/OpenSchemaExceptionHandler.java | 23 +-
.../server/repository/SchemaRepository.java | 42 +
.../server/repository/SubjectRepository.java | 36 +-
.../server/request/SchemaCreateRequest.java | 9 +-
.../server/request/SubjectCreateRequest.java | 9 +-
.../response/CompatibilityResultResponse.java | 18 +-
.../registry/server/response/SchemaIdResponse.java | 17 +-
.../server/response/SubjectAndVersionResponse.java | 15 +-
.../server/service/CompatibilityChecker.java | 11 +-
.../server/service/CompatibilityService.java | 101 ++
.../registry/server/service/SchemaService.java | 68 ++
.../registry/server/service/SubjectService.java | 221 ++++
.../src/main/resources/application.yml | 25 +-
.../src/main/resources/h2/db.mv.db | Bin 0 -> 24576 bytes
eventmesh-sdk-java/build.gradle | 18 +
eventmesh-sdk-java/gradle.properties | 4 -
.../client/http/conf/LiteClientConfig.java | 6 +-
.../client/http/consumer/LiteConsumer.java | 169 +--
.../client/http/producer/LiteProducer.java | 176 ++--
.../producer/RRCallbackResponseHandlerAdapter.java | 45 +-
.../client/http/ssl/MyX509TrustManager.java | 16 +-
.../client/http/util/HttpLoadBalanceUtils.java | 74 +-
.../eventmesh/client/tcp/EventMeshClient.java | 4 +-
.../eventmesh/client/tcp/SimpleSubClient.java | 4 +-
.../client/tcp/common/EventMeshCommon.java | 4 +-
.../eventmesh/client/tcp/common/MessageUtils.java | 10 +-
.../client/tcp/impl/DefaultEventMeshClient.java | 6 +-
.../client/tcp/impl/SimpleSubClientImpl.java | 8 +-
.../client/http/demo/AsyncPublishInstance.java | 6 +-
.../client/http/demo/AsyncSyncRequestInstance.java | 6 +-
.../client/http/demo/SyncRequestInstance.java | 6 +-
.../client/http/util/HttpLoadBalanceUtilsTest.java | 10 +
.../eventmesh/client/tcp/demo/AsyncSubscribe.java | 4 +-
.../client/tcp/demo/AsyncSubscribeBroadcast.java | 4 +-
.../eventmesh/client/tcp/demo/SyncResponse.java | 4 +-
.../build.gradle | 0
.../eventmesh-security-acl}/build.gradle | 5 +-
.../apache/eventmesh/acl/impl/AclServiceImpl.java | 47 +-
.../org.apache.eventmesh.api.acl.AclService | 5 +-
.../eventmesh-security-api}/build.gradle | 5 +-
.../apache/eventmesh/api/acl/AclPropertyKeys.java | 19 +-
.../org/apache/eventmesh/api/acl/AclService.java | 28 +-
.../eventmesh/api/exception/AclException.java | 12 +-
eventmesh-spi/build.gradle | 6 +-
eventmesh-spi/gradle.properties | 4 -
.../eventmesh/spi/EventMeshExtensionFactory.java | 22 +-
...nException.java => EventMeshExtensionType.java} | 24 +-
.../org/apache/eventmesh/spi/EventMeshSPI.java | 6 +
.../spi/loader/EventMeshUrlClassLoader.java | 56 +
.../eventmesh/spi/loader/ExtensionClassLoader.java | 9 +-
.../spi/loader/JarExtensionClassLoader.java | 63 +-
.../spi/loader/MetaInfExtensionClassLoader.java | 4 +-
.../spi/example/TestPrototypeExtension.java | 3 +-
.../spi/example/TestSingletonExtension.java | 3 +-
eventmesh-starter/gradle.properties | 4 -
eventmesh-test/gradle.properties | 20 -
gradle.properties | 3 +-
settings.gradle | 14 +-
style/checkStyle-suppressions.xml | 25 -
style/checkStyle.xml | 319 +++++-
style/codeStyle.xml | 143 ---
tool/license/allowed-licenses.txt | 1103 ++++++++++++++++++++
362 files changed, 11404 insertions(+), 3562 deletions(-)
delete mode 100644 .github/ISSUE_TEMPLATE/bug_report.md
create mode 100644 .github/ISSUE_TEMPLATE/bug_report.yml
delete mode 100644 .github/ISSUE_TEMPLATE/documentation_related.md
create mode 100644 .github/ISSUE_TEMPLATE/documentation_related.yml
delete mode 100644 .github/ISSUE_TEMPLATE/enhancement_request.md
create mode 100644 .github/ISSUE_TEMPLATE/enhancement_request.yml
delete mode 100644 .github/ISSUE_TEMPLATE/feature_request.md
create mode 100644 .github/ISSUE_TEMPLATE/feature_request.yml
delete mode 100644 .github/ISSUE_TEMPLATE/question.md
create mode 100644 .github/ISSUE_TEMPLATE/question.yml
delete mode 100644 docs/.vuepress/config.js
delete mode 100644 docs/.vuepress/public/images/bus.png
delete mode 100644 docs/.vuepress/public/images/eventmesh-arch.png
delete mode 100644 docs/.vuepress/public/images/eventmesh-define.png
delete mode 100644 docs/.vuepress/public/images/eventmesh-landscape.png
delete mode 100644 docs/.vuepress/public/images/eventmesher.png
delete mode 100644 docs/.vuepress/public/images/features/RR-call-p1.png
delete mode 100644
docs/.vuepress/public/images/features/a-distributing-architecture-in-financial-EN.png
delete mode 100644
docs/.vuepress/public/images/features/a-distributing-architecture-in-financial.png
delete mode 100644
docs/.vuepress/public/images/features/adjust-queue-expand-p1.png
delete mode 100644
docs/.vuepress/public/images/features/adjust-queue-shrink-p1.png
delete mode 100644 docs/.vuepress/public/images/features/architecture-p1.png
delete mode 100644 docs/.vuepress/public/images/features/broadcast.png
delete mode 100644 docs/.vuepress/public/images/features/circuit-break-p1.png
delete mode 100644 docs/.vuepress/public/images/features/dark-launch-p1.png
delete mode 100644 docs/.vuepress/public/images/features/invoke_nearby-p1.png
delete mode 100644 docs/.vuepress/public/images/features/multicast.png
delete mode 100644
docs/.vuepress/public/images/features/subscribe-nearby-p1.png
delete mode 100644 docs/.vuepress/public/images/features/tongchengduohuo-p1.png
delete mode 100644 docs/.vuepress/public/images/features/unicast.png
delete mode 100644 docs/.vuepress/public/images/mesh-helper.png
delete mode 100644 docs/.vuepress/public/images/qqgroup-crcode.png
delete mode 100644 docs/README.md
delete mode 100644 docs/_config.yml
delete mode 100644 docs/cn/blog/.gitkeep
delete mode 100644 docs/cn/community/.gitkeep
delete mode 100644 docs/cn/documentation/.gitkeep
create mode 100644 docs/cn/documentation/_category_.json
create mode 100644 docs/cn/features/_category_.json
rename docs/cn/features/{https.zh-CN.md => https.md} (85%)
create mode 100644 docs/cn/features/spi.md
create mode 100644 docs/cn/instructions/_category_.json
create mode 100644 docs/cn/instructions/eclipse.zh-CN.md
rename docs/cn/instructions/{eventmesh-runtime-protocol.zh-CN.md =>
eventmesh-runtime-protocol.md} (98%)
rename docs/cn/instructions/{eventmesh-runtime-quickstart.zh-CN.md =>
eventmesh-runtime-quickstart.md} (86%)
rename docs/cn/instructions/{eventmesh-sdk-java-quickstart.zh-CN.md =>
eventmesh-sdk-java-quickstart.md} (97%)
rename docs/cn/instructions/{eventmesh-store-quickstart.zh-CN.md =>
eventmesh-store-quickstart.md} (96%)
rename docs/cn/instructions/{quickstart.zh-CN.md => quickstart.md} (71%)
rename docs/cn/{README.md => intro.md} (100%)
delete mode 100644 docs/en/blog/.gitkeep
delete mode 100644 docs/en/community/.gitkeep
delete mode 100644 docs/en/documentation/.gitkeep
create mode 100644 docs/en/documentation/_category_.json
create mode 100644 docs/en/features/_category_.json
create mode 100644 docs/en/features/eventmesh-metrics-export-design.md
create mode 100644 docs/en/features/eventmesh-schemaregistry-design.md
create mode 100644 docs/en/features/spi.md
create mode 100644 docs/en/instructions/_category_.json
create mode 100644
docs/en/instructions/eventmesh-runtime-quickstart-with-docker.md
delete mode 100644 docs/en/instructions/quickstart.md
rename docs/en/{README.md => intro.md} (100%)
delete mode 100644 docs/eventmesh.md
create mode 100644 docs/images/eventmesh-arch2.png
create mode 100644 docs/images/features/eventmesh-schemaregistry-arch.png
create mode 100644 docs/images/features/eventmesh-schemaregistry-process.jpg
create mode 100644
docs/images/features/eventmesh-schemaregistry-projectstructure.png
create mode 100644 docs/images/wechat-official.jpg
create mode 100644 docs/images/wechat-official.png
create mode 100644 eventmesh-admin/README.md
copy {eventmesh-common => eventmesh-admin}/build.gradle (97%)
copy eventmesh-sdk-java/src/test/resources/application.properties =>
eventmesh-admin/gradle.properties (97%)
copy
eventmesh-common/src/{test/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeaderTest.java
=> main/java/org/apache/eventmesh/common/RandomStringUtil.java} (68%)
copy
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/ExtensionException.java =>
eventmesh-common/src/main/java/org/apache/eventmesh/common/exception/JsonException.java
(72%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/loadbalance/{WeightRoundRobinLoadBalanceSelector.java
=> WeightRandomLoadBalanceSelector.java} (52%)
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/{SubcriptionType.java
=> SubscriptionType.java} (94%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/JsonUtils.java
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/loadbalance/WeightRandomLoadBalanceSelectorTest.java
copy
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/{client/AbstractResponseHeaderTest.java
=> message/PushMessageRequestHeaderTest.java} (51%)
copy
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/{BaseRequestHeaderTest.java
=> message/PushMessageResponseHeaderTest.java} (50%)
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/message/ReplyMessageRequestHeaderTest.java
copy
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/{client/AbstractResponseHeaderTest.java
=> message/ReplyMessageResponseHeaderTest.java} (64%)
copy
eventmesh-spi/src/test/java/org/apache/eventmesh/spi/example/TestPrototypeExtension.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java
(60%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/connector/ConnectorResourceServiceRocketmqImpl.java
(71%)
rename
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/{eventmesh/connector
=> }/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java (96%)
copy
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/{org.apache.eventmesh.api.producer.MeshMQProducer
=> org.apache.eventmesh.api.connector.ConnectorResourceService} (89%)
rename {eventmesh-runtime/conf =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources}/rocketmq-client.properties
(100%)
copy {eventmesh-sdk-java =>
eventmesh-connector-plugin/eventmesh-connector-standalone}/build.gradle (80%)
copy eventmesh-sdk-java/src/test/resources/application.properties =>
eventmesh-connector-plugin/eventmesh-connector-standalone/gradle.properties
(97%)
copy
eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq
=>
eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone}/MessagingAccessPointImpl.java
(86%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/MessageQueue.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBroker.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/MessageEntity.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java
=>
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/TopicMetadata.java
(58%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/HistoryMessageClearTask.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/task/SubScribeTask.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneConsumer.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/consumer/StandaloneMeshMQPushConsumerAdaptor.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneMeshMQProducerAdaptor.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducer.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/resource/StandaloneConnectorResourceService.java
(71%)
copy
eventmesh-connector-plugin/{eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService}
(89%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq =>
eventmesh-connector-standalone}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.MeshMQPushConsumer
(88%)
copy eventmesh-connector-plugin/{eventmesh-connector-rocketmq =>
eventmesh-connector-standalone}/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.MeshMQProducer
(89%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/test/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBrokerTest.java
rename {eventmesh-test => eventmesh-examples}/bin/http_pub.sh (100%)
rename {eventmesh-test => eventmesh-examples}/bin/http_sub.sh (100%)
rename {eventmesh-test => eventmesh-examples}/bin/tcp_pub.sh (100%)
rename {eventmesh-test => eventmesh-examples}/bin/tcp_pub_broadcast.sh (100%)
rename {eventmesh-test => eventmesh-examples}/bin/tcp_sub.sh (100%)
rename {eventmesh-test => eventmesh-examples}/bin/tcp_sub_broadcast.sh (100%)
rename {eventmesh-test => eventmesh-examples}/build.gradle (88%)
copy eventmesh-sdk-java/src/test/resources/application.properties =>
eventmesh-examples/gradle.properties (98%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/http/demo/AsyncPublishInstance.java
(94%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/http/demo/AsyncSyncRequestInstance.java
(95%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/http/demo/SyncRequestInstance.java
(94%)
copy {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/http/demo/sub/SpringBootDemoApplication.java
(87%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/http/demo/sub/controller/SubController.java
(84%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/http/demo/sub/service/SubService.java
(98%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java
(100%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java
(100%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/tcp/demo/AsyncPublish.java
(100%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/tcp/demo/AsyncPublishBroadcast.java
(100%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/tcp/demo/AsyncSubscribe.java
(96%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/tcp/demo/AsyncSubscribeBroadcast.java
(96%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/tcp/demo/SyncRequest.java
(100%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/tcp/demo/SyncResponse.java
(96%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/util/Utils.java (100%)
rename {eventmesh-test/conf =>
eventmesh-examples/src/main/resources}/application.properties (100%)
rename {eventmesh-test/conf =>
eventmesh-examples/src/main/resources}/log4j2.xml (100%)
rename {eventmesh-test/conf =>
eventmesh-examples/src/main/resources}/server.env (100%)
copy {eventmesh-sdk-java =>
eventmesh-protocol-plugin/eventmesh-protocol-api}/build.gradle (78%)
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-api/src/main/java/org/apache/eventmesh/protocol/api/ProtocolAdaptor.java
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-api/src/main/java/org/apache/eventmesh/protocol/api/ProtocolPluginFactory.java
copy
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/ExtensionException.java =>
eventmesh-protocol-plugin/eventmesh-protocol-api/src/main/java/org/apache/eventmesh/protocol/api/exception/ProtocolHandleException.java
(70%)
copy {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents}/build.gradle (72%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/RegisterInfo.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/CloudEventsProtocolAdaptor.java
(57%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/async/CompleteHandler.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/CloudEventsProtocolConstant.java
(83%)
copy
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.protocol.api.ProtocolAdaptor
(90%)
copy
eventmesh-common/src/test/java/org/apache/eventmesh/common/IPUtilTest.java =>
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/test/java/org/apache/eventmesh/protocol/cloudevents/CloudEventsProtocolAdaptorTest.java
(57%)
copy {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-protocol-plugin/eventmesh-protocol-openmessage}/build.gradle (65%)
copy
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/MeshMQPushConsumer.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-openmessage/src/main/java/org/apache/eventmesh/protocol/openmessage/OpenMessageProtocolAdaptor.java
(54%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/ServiceState.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-openmessage/src/main/java/org/apache/eventmesh/protocol/openmessage/OpenMessageProtocolConstant.java
(83%)
copy
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-protocol-plugin/eventmesh-protocol-openmessage/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.protocol.api.ProtocolAdaptor
(90%)
copy
eventmesh-common/src/test/java/org/apache/eventmesh/common/IPUtilTest.java =>
eventmesh-protocol-plugin/eventmesh-protocol-openmessage/src/test/java/org/apache/eventmesh/protocol/openmessage/OpenMessageProtocolAdaptorTest.java
(57%)
copy {eventmesh-common => eventmesh-registry-plugin}/build.gradle (99%)
copy {eventmesh-sdk-java =>
eventmesh-registry-plugin/eventmesh-registry-api}/build.gradle (89%)
copy eventmesh-starter/src/main/java/org/apache/eventmesh/starter/StartUp.java
=>
eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/exception/RegistryException.java
(74%)
create mode 100644
eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/registry/RegistryService.java
create mode 100644
eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/registry/dto/EventMeshDataInfo.java
create mode 100644
eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/registry/dto/EventMeshRegisterInfo.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ServerGlobal.java
=>
eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/registry/dto/EventMeshUnRegisterInfo.java
(60%)
copy {eventmesh-sdk-java =>
eventmesh-registry-plugin/eventmesh-registry-namesrv}/build.gradle (83%)
create mode 100644
eventmesh-registry-plugin/eventmesh-registry-namesrv/src/main/java/org/apache/eventmesh/registry/namesrv/RegistryServiceNamesrvImpl.java
copy
eventmesh-spi/src/test/resources/META-INF/eventmesh/org.apache.eventmesh.spi.example.TestPrototypeExtension
=>
eventmesh-registry-plugin/eventmesh-registry-namesrv/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.registry.RegistryService
(91%)
copy eventmesh-connector-plugin/gradle.properties =>
eventmesh-runtime/conf/prometheus.yml (56%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/acl/Acl.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/{ShowListenClientByTopicHandler.java
=> QueryRecommendEventMeshHandler.java} (53%)
copy
eventmesh-spi/src/test/java/org/apache/eventmesh/spi/example/SingletonExtension.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/connector/ConnectorResource.java
(50%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/cloudevent/OMSMessageFactory.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/cloudevent/impl/OMSBinaryMessageReader.java
copy
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/BaseRequestHeaderTest.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/cloudevent/impl/OMSHeaders.java
(55%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/cloudevent/impl/OMSMessageWriter.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventMeshRebalanceService.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/{http/async/CompleteHandler.java
=> tcp/client/rebalance/EventMeshRebalanceStrategy.java} (83%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventmeshRebalanceImpl.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/recommend/EventMeshRecommendImpl.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{util/ValueComparator.java
=> core/protocol/tcp/client/recommend/EventMeshRecommendStrategy.java} (67%)
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/push/retry/EventMeshTcpRetryer.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/retry/EventMeshTcpRetryer.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/{http
=> tcp/client/session}/retry/RetryContext.java (81%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/RecommendTask.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryHTTPMetricsExporter.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryPrometheusExporter.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryTCPMetricsExporter.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/registry/Registry.java
create mode 100644
eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/CSVFormat.java
create mode 100644
eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/Data.java
create mode 100644
eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/OMSFactoryTest.java
create mode 100644
eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/OMSWriterTest.java
copy
eventmesh-runtime/src/{main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=> test/java/org/apache/eventmesh/runtime/util/EventMeshUtilTest.java} (71%)
copy {eventmesh-common => eventmesh-schema-registry}/build.gradle (99%)
copy {eventmesh-connector-plugin/eventmesh-connector-api =>
eventmesh-schema-registry/eventmesh-schema-registry-server}/build.gradle (59%)
rename
eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/sub/SpringBootDemoApplication.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/OpenSchemaRegistryApplication.java
(72%)
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/controller/CompatibilityController.java
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/controller/SchemaController.java
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/controller/SubjectController.java
copy
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/RocketMQConstants.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/domain/Compatibility.java
(75%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionMode.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/domain/Schema.java
(64%)
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/domain/SchemaWithSubjectName.java
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/domain/Subject.java
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/domain/SubjectWithSchema.java
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/enumerate/CompatibilityEnum.java
copy
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/exception/ErrorResponse.java
(75%)
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/exception/ExceptionEnum.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/BaseRequestBody.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/exception/OpenSchemaException.java
(58%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/http/body/BaseRequestBody.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/exception/OpenSchemaExceptionHandler.java
(59%)
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/repository/SchemaRepository.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/RegisterInfo.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/repository/SubjectRepository.java
(50%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/async/CompleteHandler.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/request/SchemaCreateRequest.java
(82%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/http/async/CompleteHandler.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/request/SubjectCreateRequest.java
(81%)
copy
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/response/CompatibilityResultResponse.java
(75%)
copy
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/RocketMQConstants.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/response/SchemaIdResponse.java
(76%)
copy
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/RocketMQConstants.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/response/SubjectAndVersionResponse.java
(77%)
copy
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/RocketMQConstants.java
=>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/service/CompatibilityChecker.java
(78%)
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/service/CompatibilityService.java
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/service/SchemaService.java
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/java/org/apache/eventmesh/schema/registry/server/service/SubjectService.java
copy eventmesh-common/src/test/resources/configuration.properties =>
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/resources/application.yml
(68%)
create mode 100644
eventmesh-schema-registry/eventmesh-schema-registry-server/src/main/resources/h2/db.mv.db
copy {eventmesh-spi => eventmesh-security-plugin}/build.gradle (100%)
copy {eventmesh-sdk-java =>
eventmesh-security-plugin/eventmesh-security-acl}/build.gradle (83%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/consumergroup/ProducerGroupConf.java
=>
eventmesh-security-plugin/eventmesh-security-acl/src/main/java/org/apache/eventmesh/acl/impl/AclServiceImpl.java
(50%)
copy eventmesh-sdk-java/src/test/resources/application.properties =>
eventmesh-security-plugin/eventmesh-security-acl/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.acl.AclService
(93%)
copy {eventmesh-sdk-java =>
eventmesh-security-plugin/eventmesh-security-api}/build.gradle (89%)
copy
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/RegResponseHeaderTest.java
=>
eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/acl/AclPropertyKeys.java
(67%)
copy
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/MeshMQPushConsumer.java
=>
eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/acl/AclService.java
(56%)
copy eventmesh-starter/src/main/java/org/apache/eventmesh/starter/StartUp.java
=>
eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/exception/AclException.java
(75%)
copy
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/{ExtensionException.java
=> EventMeshExtensionType.java} (63%)
create mode 100644
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/loader/EventMeshUrlClassLoader.java
delete mode 100644 eventmesh-test/gradle.properties
delete mode 100644 style/checkStyle-suppressions.xml
delete mode 100644 style/codeStyle.xml
create mode 100644 tool/license/allowed-licenses.txt
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
