You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/05/07 08:36:12 UTC
[incubator-eventmesh] branch develop updated (ce62aa09 -> 6014ddb1)
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
from ce62aa09 Add files via upload
new 0b105de1 update project version to 1.3.0-RELEASE
new 3f38b820 update docs
new 8f0670f1 Delete gradle/wrapper directory
new 52205e36 Merge branch '1.3.0-RELEASE' of https://github.com/apache/incubator-eventmesh into 1.3.0-RELEASE
new d6037d45 update Dockerfile and build.gradle
new be0fb292 update build.gradle
new 2790b788 update Dockerfile path
new 1e99c799 Update .asf.yaml
new 2175a4b0 Update .asf.yaml
new 91ff4bc7 [Infra] trigger branch protection change
new 4d220baa [Infra] retrigger .asf.yaml protections
new 8454128d update some docs
new 84efbdab update Dockerfile path
new 53a4b943 Update java sdk docs (#663)
new 5592df5e Add files via upload
new 7aaa3499 [Infra] retrigger .asf.yaml protections
new 1ddb0bf1 Merge pull request #675 from xwm1992/master
new 9b76a9e4 Update .asf.yaml
new 8519fb00 [ISSUE #670] fix checkstyle check fail (#680)
new 5adc007b [MINOR] Fixed redundant boxing operations (#684)
new 1654c47e [MINOR] new Runnable() can be replaced with lambda (#685)
new fd60ab98 [MINOR] ConfigurationWrapper class adds thread pool shutdown (#683)
new 852c22b3 [ISSUE #677] Translate readme files from English to Chinese (#678)
new 2b3e8614 [ISSUE #405]update cloudevents examples (#688)
new 52d423fc Bump gradle version to 7.3.3 Support Java17 build
new a1140abe Merge pull request #689 from Shoothzj/gradle-7-3
new 032bb0d8 [ISSUE #690]Remove extra code style check job in CI (#691)
new 0cadf298 Update intro.md (#693)
new 9fca9462 Add files via upload (#694)
new 5c0f8a99 [ISSUE #692]Change the default merge strategy to squash (#695)
new 8ac37a0d [ISSUE #673] update eventmesh-runtime-quickstart-with-docker.md en & cn (#698)
new a9d102c9 [MINOR] Change Tar and Zip name (#699)
new 70080e73 [Issue #702] Fix Slack Join link (#705)
new 80aa61a6 Updated Notice file to 2022 (#704)
new 5dc964b0 add instruction docs of trace and metrics in eventmesh (#706)
new db6b34f2 [ISSUE #405]Fix args typo in examples (#707)
new 2ff99664 [Issue #533] Adding design doc for EventMesh Workflow
new 1cb00234 [ISSUE #696] Add metrics plugin (#709)
new 52ec3d76 [ISSUE #713] Fix trace bug (#712)
new d7b0fe30 [Issue #553] Adding design doc for EventMesh Workflow (#714)
new d6a4ed14 Merge remote-tracking branch 'origin/master' into workflow
new 32c6f9a0 [Issue #553] update the design doc.
new 2accf26a Merge pull request #715 from jinrongluo/workflow
new ba5b0cea small updates to doc
new 0c25347e small update
new 6494a178 adding asyncapi type to event defs
new 964bb6c2 Merge pull request #717 from tsurdilo/workflowup
new 7625d3c8 Remove unnecessary call toString (#719)
new f0758d2b [Issue #553] add workflow diagram to the design doc
new 628abc8e Merge pull request #720 from jinrongluo/workflow
new 2564bc80 Update intro.md (#722)
new cb9e572b Update roadmap.md (#721)
new 73ae07e0 Missed exception cause (#724)
new 33e7021f [ISSUE #726] Remove the misleading annotation (#725)
new 8703a143 [ISSUE #729] Bump netty version (#730)
new dc475b55 [ISSUE #732] Binary package failed to execute (#733)
new 93b2442e [Issue #735] log4j 2.17.1 (#736)
new 8fcddf00 [MINOR] Remove the unnecessary boxing (#731)
new 127972ed Use archiveBaseName and archiveVersion to optimize gradle zip task (#728)
new 85f100a3 Add environment and version selector in bug_report.yml (#734)
new 53941c60 Fix bug report template (#741)
new 42e1c90b add eventmesh-admin-rocketmq into rootProject
new b1a65409 Merge pull request #743 from wqliang/enhance/fixMissingJar
new c99dd2dc [ISSUE #737] Add Netty license (#738)
new 7c7d81fb [Issue #750] junit should only be used in tests (#751)
new 58c0d5d9 [Issue #752] upgrade httpclient (#753)
new 4616366a [Issue-754] upgrade guava (#757)
new b8891ee3 [Issue #758] validate subscriber Url (#759)
new 85de5c7a [Issue #655] Adding send message constraints for message size and batch size (#760)
new ed074253 [MINOR] Fix plugin cannot load properties from classpath (#763)
new 62eeb0eb [MINOR] Remove unused field in example (#766)
new 97ed0811 [MINOR] Allow run script in other directory (#765)
new 83550693 [MINOR] Fix the hardcode ip address (#767)
new e051d58f [Issue #768] fix issue in update HTTP subscriber (#769)
new ba015907 update checkstyle.xml (#773)
new 25b7a164 Rebase the grpc branch to master branch (#771)
new 12a223c4 [Issue #774] Optimize the object property description of eventmesh client (#775)
new c93c7c5d Update roadmap.md (#779)
new 6f40eb92 [Issue #780] Modify the define level of EventListener from Topic to Consumer (#781)
new 874d5fa9 [ISSUE #786] remove eventmesh-sdk-java model redundant code (#789)
new 95d87bab Update roadmap.md (#791)
new 16df47da [ISSUE #783] clean useless code in runtime module (#787)
new cde95c0a [ISSUE #696] Add trace plugin (#749)
new bab7e11f [ISSUE #784] Fix words misspell, optimize admin http method code (#792)
new a52bf296 [Issue #658] Eventmesh Http Support CloudEvents Webhook spec (#772)
new 5ebe073b [ISSUE #782] delete invalid code in eventmesh-connector-plugin module (#793)
new b67726e0 [ISSUE #795] Fix doc eventmesh-runtime-quickstart-with-docker.md (#798)
new 5708ec26 [Enhancement] Some suggestions for eventmesh-examples (#794)
new 00c4d24c [Enhancement] compile project with junit error (#802)
new caaa7a43 [Enhancement] Run CI on all branch (#805)
new e5bf7310 [MINOR] sort dependencise before check (#808)
new 8fe412c3 [ISSUE #806] code optimization and delete invalid code in eventmesh-e… (#807)
new 2c1baac2 add zipkin plugin properties
new 5ce0a55a Merge pull request #810 from wqliang/addTracePluginProperties
new fcfe5ac2 Rename prometheus metrics plugin name (#811)
new 5bc8638a [MINOR] Add trace switch (#812)
new 0a252c99 MINOR: Fix load config properties may get error in windows due to file seperate (#813)
new 7370053a Update roadmap.md (#818)
new 05fd6288 MONIOR: Remove tool directory (#814)
new 8054f270 Lint the documentations with markdownlint (#820)
new a90bd426 Update bug_report.yml, fix typo (#824)
new 87c8b714 Update README.md (#826)
new 6a4db8b1 Update README.md (#829)
new 0280df1e Updated slack invite link in README (#831)
new b0966ef8 Merge remote-tracking branch 'upstream/master' into develop
new 3df63b53 [ISSUE #838] Removed redundant code (#842)
new 00ab5b56 [ISSUE #834] Support nacos registry (#835)
new 5b7b6c4c [ISSUE #834] Support nacos registry (#835)
new bb51ac9a [ISSUE #847] Could not find or load main class by test script (#848)
new f6b117f0 Optimized documentation docker script code blocks (#846)
new 7e18b174 upgrade spring libs & jackson-databind s version to fix CVEs issues (#849)
new aded3b20 [MINOR] update ci.yml enable codecov (#850)
new c4786dd9 Merge remote-tracking branch 'upstream/master' into develop
new ec35f02b Merge branch 'upstream-develop' into develop
new 6014ddb1 Merge pull request #833 from jefftlin/develop
The 912 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 | 4 +-
.github/ISSUE_TEMPLATE/bug_report.yml | 24 +-
.github/PULL_REQUEST_TEMPLATE.md | 4 +-
.github/workflows/ci.yml | 49 +-
NOTICE | 2 +-
README.md | 28 +-
README.zh-CN.md | 37 +-
build.gradle | 66 +-
.../{eventmesh-rocketmq => eventmesh}/Dockerfile | 2 +-
.../instructions/{eclipse.zh-CN.md => eclipse.md} | 0
.../eventmesh-metrics-Prometheus-instruction.md | 46 +
docs/cn/instructions/eventmesh-runtime-protocol.md | 162 +-
.../eventmesh-runtime-quickstart-with-docker.md | 177 +
.../instructions/eventmesh-runtime-quickstart.md | 20 +-
.../instructions/eventmesh-sdk-java-quickstart.md | 55 +-
.../eventmesh-trace-Zipkin-instruction.md | 49 +
docs/cn/instructions/quickstart.md | 11 +-
docs/cn/intro.md | 1 +
.../features/eventmesh-cloudevents-sdk-binding.md | 11 +-
.../en/features/eventmesh-metrics-export-design.md | 6 +-
.../en/features/eventmesh-schemaregistry-design.md | 6 +-
docs/en/features/eventmesh-stream-design.md | 93 +-
docs/en/features/eventmesh-trace-design.md | 18 +-
docs/en/features/eventmesh-workflow-design.md | 276 ++
docs/en/features/spi.md | 1 +
.../eventmesh-metrics-Prometheus-instruction.md | 46 +
docs/en/instructions/eventmesh-runtime-protocol.md | 163 +
.../eventmesh-runtime-quickstart-with-docker.md | 183 +-
.../instructions/eventmesh-runtime-quickstart.md | 28 +-
.../instructions/eventmesh-sdk-java-quickstart.md | 64 +-
docs/en/instructions/eventmesh-store-quickstart.md | 22 +-
.../eventmesh-trace-Zipkin-instruction.md | 45 +
docs/en/intro.md | 19 +
docs/en/roadmap.md | 39 +
docs/images/Prometheus-download.png | Bin 0 -> 57766 bytes
docs/images/eventmesh-orchestration.png | Bin 272622 -> 2779741 bytes
docs/images/features/eventmesh-workflow-arch.jpg | Bin 0 -> 166972 bytes
docs/images/features/eventmesh-workflow-diag.png | Bin 0 -> 135137 bytes
.../images/features/eventmesh-workflow-usecase.jpg | Bin 0 -> 109159 bytes
docs/images/prometheus-yml.png | Bin 0 -> 20290 bytes
docs/images/promethus-search.png | Bin 0 -> 122129 bytes
eventmesh-admin/README.md | 12 +-
.../apache/eventmesh/admin/rocketmq/Constants.java | 12 +-
.../eventmesh/admin/rocketmq/HttpMethod.java | 11 +-
.../admin/rocketmq/controller/AdminController.java | 8 +-
.../admin/rocketmq/handler/TopicsHandler.java | 18 +-
.../admin/rocketmq/response/TopicResponse.java | 6 +-
.../eventmesh/admin/rocketmq/util/JsonUtils.java | 10 +-
.../eventmesh/admin/rocketmq/util/NetUtils.java | 15 +-
.../admin/rocketmq/util/RequestMapping.java | 20 +-
.../admin/rocketmq/util/UrlMappingPattern.java | 8 +-
eventmesh-common/build.gradle | 10 +-
.../org/apache/eventmesh/common/Constants.java | 4 +-
.../apache/eventmesh/common/ThreadPoolFactory.java | 2 +-
.../common/config/CommonConfiguration.java | 211 +-
.../common/config/ConfigurationWrapper.java | 32 +-
.../loadbalance/RandomLoadBalanceSelector.java | 5 +-
.../eventmesh/common/loadbalance/Weight.java | 10 +-
.../WeightRandomLoadBalanceSelector.java | 3 +-
.../WeightRoundRobinLoadBalanceSelector.java | 5 +-
.../common/protocol/SubscriptionItem.java | 33 +-
.../common/BatchMessageWrapper.java} | 22 +-
.../common/protocol/grpc/common/ProtocolKey.java | 42 +
.../common/SimpleMessageWrapper.java} | 22 +-
.../common/protocol/grpc/common/StatusCode.java | 70 +
.../common/protocol/grpc/protos/BatchMessage.java | 2574 +++++++++++++
.../grpc/protos/BatchMessageOrBuilder.java | 84 +
.../protocol/grpc/protos/ConsumerServiceGrpc.java | 445 +++
.../common/protocol/grpc/protos/EventmeshGrpc.java | 283 ++
.../common/protocol/grpc/protos/Heartbeat.java | 2033 ++++++++++
.../protocol/grpc/protos/HeartbeatOrBuilder.java | 93 +
.../protocol/grpc/protos/HeartbeatServiceGrpc.java | 290 ++
.../protocol/grpc/protos/PublisherServiceGrpc.java | 476 +++
.../common/protocol/grpc/protos/RequestHeader.java | 1931 ++++++++++
.../grpc/protos/RequestHeaderOrBuilder.java | 147 +
.../common/protocol/grpc/protos/Response.java | 788 ++++
.../protocol/grpc/protos/ResponseOrBuilder.java | 57 +
.../common/protocol/grpc/protos/SimpleMessage.java | 1754 +++++++++
.../grpc/protos/SimpleMessageOrBuilder.java | 144 +
.../common/protocol/grpc/protos/Subscription.java | 3934 ++++++++++++++++++++
.../grpc/protos/SubscriptionOrBuilder.java | 97 +
.../common/protocol/http/HttpCommand.java | 30 +-
.../protocol/http/body/BaseResponseBody.java | 4 +-
.../eventmesh/common/protocol/http/body/Body.java | 4 +-
.../http/body/client/HeartbeatRequestBody.java | 22 +-
.../http/body/client/HeartbeatResponseBody.java | 9 +-
.../protocol/http/body/client/RegRequestBody.java | 12 +-
.../protocol/http/body/client/RegResponseBody.java | 9 +-
.../http/body/client/SubscribeRequestBody.java | 12 +-
.../http/body/client/SubscribeResponseBody.java | 9 +-
.../http/body/client/UnRegRequestBody.java | 16 +-
.../http/body/client/UnRegResponseBody.java | 9 +-
.../http/body/client/UnSubscribeRequestBody.java | 12 +-
.../http/body/client/UnSubscribeResponseBody.java | 9 +-
.../http/body/message/PushMessageRequestBody.java | 26 +-
.../http/body/message/PushMessageResponseBody.java | 9 +-
.../http/body/message/ReplyMessageRequestBody.java | 26 +-
.../body/message/ReplyMessageResponseBody.java | 9 +-
.../body/message/SendMessageBatchRequestBody.java | 36 +-
.../body/message/SendMessageBatchResponseBody.java | 9 +-
.../message/SendMessageBatchV2RequestBody.java | 7 +-
.../message/SendMessageBatchV2ResponseBody.java | 9 +-
.../http/body/message/SendMessageRequestBody.java | 34 +-
.../http/body/message/SendMessageResponseBody.java | 10 +-
.../common/protocol/http/common/ProtocolKey.java | 2 +
.../protocol/http/header/BaseRequestHeader.java | 7 +-
.../protocol/http/header/BaseResponseHeader.java | 4 +-
.../common/protocol/http/header/Header.java | 4 +-
.../http/header/client/HeartbeatRequestHeader.java | 11 +-
.../header/client/HeartbeatResponseHeader.java | 6 +-
.../http/header/client/RegRequestHeader.java | 5 +-
.../http/header/client/RegResponseHeader.java | 6 +-
.../http/header/client/SubscribeRequestHeader.java | 5 +-
.../header/client/SubscribeResponseHeader.java | 6 +-
.../http/header/client/UnRegRequestHeader.java | 11 +-
.../http/header/client/UnRegResponseHeader.java | 6 +-
.../header/client/UnSubscribeRequestHeader.java | 5 +-
.../header/client/UnSubscribeResponseHeader.java | 6 +-
.../header/message/PushMessageRequestHeader.java | 9 +-
.../header/message/ReplyMessageRequestHeader.java | 5 +-
.../header/message/ReplyMessageResponseHeader.java | 6 +-
.../message/SendMessageBatchRequestHeader.java | 5 +-
.../message/SendMessageBatchResponseHeader.java | 6 +-
.../message/SendMessageBatchV2RequestHeader.java | 5 +-
.../message/SendMessageBatchV2ResponseHeader.java | 6 +-
.../header/message/SendMessageRequestHeader.java | 5 +-
.../header/message/SendMessageResponseHeader.java | 6 +-
.../common/protocol/tcp/EventMeshClientInfo.java | 7 +-
.../common/protocol/tcp/EventMeshMessage.java | 4 +-
.../eventmesh/common/protocol/tcp/Header.java | 12 +-
.../common/protocol/tcp/HeartBeatInfo.java | 12 +-
.../eventmesh/common/protocol/tcp/Package.java | 2 +
.../common/protocol/tcp/RedirectInfo.java | 9 +-
.../common/protocol/tcp/RegisterInfo.java | 6 +-
.../common/protocol/tcp/Subscription.java | 6 +-
.../common/protocol/tcp/UnRegisterInfo.java | 12 +-
.../eventmesh/common/protocol/tcp/UserAgent.java | 94 +-
.../eventmesh/common/protocol/tcp/codec/Codec.java | 21 +-
.../common/utils/ConfigurationContextUtil.java | 69 +
.../org/apache/eventmesh/common/utils/IPUtils.java | 77 +-
.../eventmesh/common/utils/RandomStringUtils.java | 2 +-
.../eventmesh/common/EventMeshMessageTest.java | 4 +-
.../loadbalance/RandomLoadBalanceSelectorTest.java | 10 +-
.../WeightRandomLoadBalanceSelectorTest.java | 12 +-
.../WeightRoundRobinLoadBalanceSelectorTest.java | 10 +-
.../protocol/http/body/BaseResponseBodyTest.java | 5 +-
.../http/header/BaseRequestHeaderTest.java | 7 +-
.../http/header/BaseResponseHeaderTest.java | 5 +-
.../header/client/AbstractRequestHeaderTest.java | 1 +
.../header/client/AbstractResponseHeaderTest.java | 5 +-
.../header/client/HeartbeatRequestHeaderTest.java | 4 +-
.../header/client/HeartbeatResponseHeaderTest.java | 4 -
.../http/header/client/RegRequestHeaderTest.java | 4 +-
.../header/client/SubscribeRequestHeaderTest.java | 4 +-
.../http/header/client/UnRegRequestHeaderTest.java | 4 +-
.../client/UnSubscribeRequestHeaderTest.java | 4 +-
.../message/PushMessageRequestHeaderTest.java | 9 +-
.../message/PushMessageResponseHeaderTest.java | 5 +-
.../message/ReplyMessageRequestHeaderTest.java | 9 +-
.../message/ReplyMessageResponseHeaderTest.java | 5 +-
.../common/protocol/tcp/codec/CodecTest.java | 17 +-
.../eventmesh/common/utils/ThreadUtilsTest.java | 56 -
.../src/test/resources/configuration.properties | 7 +-
.../org/apache/eventmesh/api/AbstractContext.java | 3 +
.../apache/eventmesh/api/RequestReplyCallback.java | 3 +
.../api/connector/ConnectorResourceService.java | 6 +-
.../apache/eventmesh/api/consumer/Consumer.java | 6 +-
.../rocketmq/MessagingAccessPointImpl.java | 90 -
.../rocketmq/admin/command/CreateTopicCommand.java | 2 +-
.../cloudevent/RocketMQMessageFactory.java | 19 +-
.../impl/RocketMQBinaryMessageReader.java | 7 +-
.../rocketmq/cloudevent/impl/RocketMQHeaders.java | 4 +-
.../cloudevent/impl/RocketMQMessageWriter.java | 12 +-
.../rocketmq/config/ClientConfiguration.java | 94 +-
.../rocketmq/config/ConfigurationWrapper.java | 39 +-
.../ConnectorResourceServiceRocketmqImpl.java | 1 +
.../rocketmq/consumer/PushConsumerImpl.java | 72 +-
.../rocketmq/consumer/RocketMQConsumerImpl.java | 14 +-
.../connector/rocketmq/domain/NonStandardKeys.java | 3 +
.../rocketmq/domain/RocketMQConstants.java | 3 +
.../patch/EventMeshConsumeConcurrentlyContext.java | 1 +
.../EventMeshMessageListenerConcurrently.java | 9 +-
.../rocketmq/producer/AbstractProducer.java | 56 +-
.../connector/rocketmq/producer/ProducerImpl.java | 45 +-
.../rocketmq/producer/RocketMQProducerImpl.java | 14 +-
.../connector/rocketmq/utils/BeanUtils.java | 100 +-
.../connector/rocketmq/utils/CloudEventUtils.java | 26 +-
.../connector/rocketmq/utils/OMSUtil.java | 262 +-
.../ConsumeMessageConcurrentlyService.java | 67 +-
.../producer/DefaultProducerImplTest.java | 51 +-
.../rocketmq/consumer/PushConsumerImplTest.java | 21 +-
.../apache/rocketmq/producer/ProducerImplTest.java | 24 +-
.../org/apache/rocketmq/utils/BeanUtilsTest.java | 11 +-
.../eventmesh-connector-standalone/build.gradle | 1 -
.../connector/standalone/broker/MessageQueue.java | 3 +-
.../standalone/broker/StandaloneBroker.java | 6 +-
.../standalone/broker/model/MessageEntity.java | 4 +-
.../standalone/broker/model/TopicMetadata.java | 6 +-
.../broker/task/HistoryMessageClearTask.java | 7 +-
.../standalone/broker/task/SubScribeTask.java | 16 +-
.../standalone/consumer/StandaloneConsumer.java | 21 +-
.../consumer/StandaloneConsumerAdaptor.java | 101 +-
.../standalone/producer/StandaloneProducer.java | 22 +-
.../producer/StandaloneProducerAdaptor.java | 10 -
.../standalone/broker/StandaloneBrokerTest.java | 16 +-
.../{http_pub.sh => http_pub_eventmeshmessage.sh} | 2 +-
.../{tcp_sub.sh => tcp_eventmeshmessage_sub.sh} | 2 +-
.../{tcp_pub.sh => tcp_pub_eventmeshmessage.sh} | 2 +-
...st.sh => tcp_pub_eventmeshmessage_broadcast.sh} | 2 +-
...st.sh => tcp_sub_eventmeshmessage_broadcast.sh} | 2 +-
eventmesh-examples/build.gradle | 7 +
.../apache/eventmesh/common/ExampleConstants.java | 45 +
.../CloudEventsBatchPublishInstance.java | 86 +
.../cloudevents/CloudEventsPublishInstance.java | 84 +
.../cloudevents/CloudEventsRequestInstance.java | 85 +
.../eventmeshmessage/AsyncPublishBroadcast.java | 77 +
.../pub/eventmeshmessage/AsyncPublishInstance.java | 77 +
.../pub/eventmeshmessage/BatchPublishInstance.java | 78 +
.../pub/eventmeshmessage/RequestReplyInstance.java | 79 +
.../grpc/sub/CloudEventsAsyncSubscribe.java | 82 +
.../grpc/sub/CloudEventsSubscribeReply.java | 86 +
.../grpc/sub/EventmeshAsyncSubscribe.java | 81 +
.../grpc/sub/EventmeshSubscribeBroadcast.java | 81 +
.../grpc/sub/EventmeshSubscribeReply.java | 85 +
.../sub/app}/SpringBootDemoApplication.java | 2 +-
.../sub/app}/controller/SubController.java | 21 +-
.../sub => grpc/sub/app}/service/SubService.java | 78 +-
.../demo/pub/cloudevents/AsyncPublishInstance.java | 66 +-
.../pub/eventmeshmessage/AsyncPublishInstance.java | 49 +-
.../eventmeshmessage/AsyncSyncRequestInstance.java | 38 +-
.../pub/eventmeshmessage/SyncRequestInstance.java | 34 +-
.../http/demo/sub/controller/SubController.java | 20 +-
.../http/demo/sub/service/SubService.java | 41 +-
.../tcp/common/EventMeshTestCaseTopicSet.java | 34 -
.../eventmesh/tcp/common/EventMeshTestUtils.java | 111 +-
.../tcp/demo/pub/cloudevents/AsyncPublish.java | 31 +-
.../tcp/demo/pub/cloudevents/SyncRequest.java | 33 +-
.../demo/pub/eventmeshmessage/AsyncPublish.java | 25 +-
.../eventmeshmessage/AsyncPublishBroadcast.java | 23 +-
.../tcp/demo/pub/eventmeshmessage/SyncRequest.java | 25 +-
.../tcp/demo/sub/cloudevents/AsyncSubscribe.java | 32 +-
.../tcp/demo/sub/cloudevents/SyncResponse.java | 35 +-
.../demo/sub/eventmeshmessage/AsyncSubscribe.java | 34 +-
.../eventmeshmessage/AsyncSubscribeBroadcast.java | 26 +-
.../demo/sub/eventmeshmessage/SyncResponse.java | 33 +-
.../main/java/org/apache/eventmesh/util/Utils.java | 14 +-
.../src/main/resources/application.properties | 3 +-
.../build.gradle | 0
.../eventmesh-metrics-api}/build.gradle | 9 +-
.../eventmesh-metrics-api}/gradle.properties | 0
.../metrics/api/MetricsPluginFactory.java | 27 +-
.../eventmesh/metrics/api/MetricsRegistry.java | 36 +-
.../metrics/api/model/HttpSummaryMetrics.java | 157 +-
.../apache/eventmesh/metrics/api/model/Metric.java | 7 +-
.../metrics/api/model/TcpSummaryMetrics.java | 123 +
.../eventmesh-metrics-prometheus}/build.gradle | 21 +-
.../gradle.properties | 4 +-
.../prometheus/PrometheusMetricsRegistry.java | 87 +
.../prometheus/config/PrometheusConfiguration.java | 81 +
.../prometheus/metrics/PrometheusHttpExporter.java | 298 ++
.../prometheus/metrics/PrometheusTcpExporter.java | 89 +
...rg.apache.eventmesh.metrics.api.MetricsRegistry | 6 +-
.../src/main/resources/prometheus.properties | 3 +
.../src/main/resources}/prometheus.yml | 1 +
.../config/PrometheusConfigurationTest.java | 10 +-
.../src/test/resources/prometheus.properties | 2 +
.../gradle.properties | 0
.../eventmesh-protocol-api/build.gradle | 1 -
.../eventmesh/protocol/api/ProtocolAdaptor.java | 4 +-
.../protocol/api/ProtocolPluginFactory.java | 8 +-
.../eventmesh-protocol-cloudevents/build.gradle | 3 +-
.../cloudevents/CloudEventsProtocolAdaptor.java | 21 +-
.../resolver/grpc/GrpcMessageProtocolResolver.java | 233 ++
.../http/SendMessageBatchProtocolResolver.java | 3 +-
.../http/SendMessageBatchV2ProtocolResolver.java | 84 +-
.../http/SendMessageRequestProtocolResolver.java | 22 +-
.../resolver/tcp/TcpMessageProtocolResolver.java | 18 +-
.../CloudEventsProtocolAdaptorTest.java | 4 +-
.../eventmesh-protocol-grpc/build.gradle | 54 +
.../src/main/proto/eventmesh-client.proto | 155 +
.../eventmesh-protocol-meshmessage/build.gradle | 2 +-
.../meshmessage/MeshMessageProtocolAdaptor.java | 25 +-
.../resolver/grpc/GrpcMessageProtocolResolver.java | 268 ++
.../http/SendMessageBatchProtocolResolver.java | 3 +-
.../http/SendMessageBatchV2ProtocolResolver.java | 10 +-
.../http/SendMessageRequestProtocolResolver.java | 89 +-
.../resolver/tcp/TcpMessageProtocolResolver.java | 10 +-
.../MeshMessageProtocolAdaptorTest.java | 4 +-
.../eventmesh-protocol-openmessage/build.gradle | 1 -
.../openmessage/OpenMessageProtocolAdaptor.java | 6 +-
.../OpenMessageProtocolAdaptorTest.java | 4 +-
.../eventmesh/api/exception/RegistryException.java | 4 +
.../eventmesh/api/registry/RegistryService.java | 8 +-
.../api/registry/dto/EventMeshDataInfo.java | 4 +
.../api/registry/dto/EventMeshRegisterInfo.java | 4 +
.../api/registry/dto/EventMeshUnRegisterInfo.java | 14 +
.../eventmesh-registry-nacos}/build.gradle | 7 +-
.../registry/nacos/constant/NacosConstant.java | 22 +-
.../nacos/service/NacosRegistryService.java | 209 ++
...g.apache.eventmesh.api.registry.RegistryService | 6 +-
.../nacos/service/NacosRegistryServiceTest.java | 120 +
eventmesh-runtime/bin/start.sh | 2 +-
eventmesh-runtime/bin/stop.sh | 2 +-
eventmesh-runtime/build.gradle | 41 +-
eventmesh-runtime/conf/eventmesh.properties | 39 +-
.../java/org/apache/eventmesh/runtime/acl/Acl.java | 43 +-
.../admin/controller/ClientManageController.java | 6 +-
.../handler/QueryRecommendEventMeshHandler.java | 37 +-
.../handler/RedirectClientByIpPortHandler.java | 31 +-
.../admin/handler/RedirectClientByPathHandler.java | 33 +-
.../handler/RedirectClientBySubSystemHandler.java | 28 +-
.../admin/handler/RejectAllClientHandler.java | 2 +-
.../admin/handler/RejectClientByIpPortHandler.java | 16 +-
.../handler/RejectClientBySubSystemHandler.java | 20 +-
.../admin/handler/ShowClientBySystemHandler.java | 10 +-
.../runtime/admin/handler/ShowClientHandler.java | 18 +-
.../handler/ShowListenClientByTopicHandler.java | 12 +-
.../eventmesh/runtime/boot/AbstractHTTPServer.java | 91 +-
.../runtime/boot/AbstractRemotingServer.java | 9 +-
.../runtime/boot/EventMeshGrpcServer.java | 277 ++
.../runtime/boot/EventMeshHTTPServer.java | 98 +-
.../eventmesh/runtime/boot/EventMeshServer.java | 91 +-
.../eventmesh/runtime/boot/EventMeshStartup.java | 10 +-
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 194 +-
.../eventmesh/runtime/boot/SSLContextFactory.java | 10 +-
...ration.java => EventMeshGrpcConfiguration.java} | 128 +-
.../configuration/EventMeshHTTPConfiguration.java | 257 +-
.../configuration/EventMeshTCPConfiguration.java | 93 +-
.../runtime/connector/ConnectorResource.java | 6 +-
.../runtime/constants/EventMeshConstants.java | 3 +-
.../core/consumergroup/ConsumerGroupConf.java | 15 +-
.../core/consumergroup/ConsumerGroupTopicConf.java | 41 +-
.../core/consumergroup/ProducerGroupConf.java | 8 +-
.../runtime/core/plugin/MQConsumerWrapper.java | 22 +-
.../runtime/core/plugin/MQProducerWrapper.java | 5 +-
.../eventmesh/runtime/core/plugin/MQWrapper.java | 9 +-
.../protocol/grpc/consumer/ConsumerManager.java | 237 ++
.../protocol/grpc/consumer/EventMeshConsumer.java | 298 ++
.../consumergroup/ConsumerGroupClient.java | 91 +
.../consumergroup/ConsumerGroupTopicConfig.java | 73 +
.../grpc/consumer/consumergroup/GrpcType.java | 9 +-
.../consumer/consumergroup/StreamTopicConfig.java | 142 +
.../consumer/consumergroup/WebhookTopicConfig.java | 126 +
.../processor/BatchPublishMessageProcessor.java | 138 +
.../grpc/processor/HeartbeatProcessor.java | 113 +
.../grpc/processor/ReplyMessageProcessor.java | 139 +
.../grpc/processor/RequestMessageProcessor.java | 148 +
.../grpc/processor/SendAsyncMessageProcessor.java | 137 +
.../grpc/processor/SubscribeProcessor.java | 141 +
.../grpc/processor/SubscribeStreamProcessor.java | 141 +
.../grpc/processor/UnsubscribeProcessor.java | 111 +
.../protocol/grpc/producer/EventMeshProducer.java | 106 +
.../{http => grpc}/producer/ProducerManager.java | 36 +-
.../producer/SendMessageContext.java | 64 +-
.../protocol/grpc/push/AbstractPushRequest.java | 168 +
.../core/protocol/grpc/push/HandleMsgContext.java | 102 +
.../push/MessageHandler.java} | 71 +-
.../core/protocol/grpc/push/StreamPushRequest.java | 127 +
.../protocol/grpc/push/WebhookPushRequest.java | 261 ++
.../{http => grpc}/retry/DelayRetryable.java | 4 +-
.../core/protocol/grpc/retry/GrpcRetryer.java | 116 +
.../{http => grpc}/retry/RetryContext.java | 2 +-
.../protocol/grpc/service/ConsumerService.java | 165 +
.../core/protocol/grpc/service/EventEmitter.java | 61 +
.../protocol/grpc/service/HeartbeatService.java | 66 +
.../protocol/grpc/service/ProducerService.java | 108 +
.../core/protocol/grpc/service/ServiceUtils.java | 159 +
.../core/protocol/http/async/CompleteHandler.java | 5 +
.../http/consumer/ConsumerGroupManager.java | 15 +-
.../protocol/http/consumer/ConsumerManager.java | 190 +-
.../protocol/http/consumer/EventMeshConsumer.java | 269 +-
.../protocol/http/consumer/HandleMsgContext.java | 27 +-
.../http/processor/AdminMetricsProcessor.java | 5 +-
.../http/processor/AdminShutdownProcessor.java | 8 +-
.../http/processor/BatchSendMessageProcessor.java | 125 +-
.../processor/BatchSendMessageV2Processor.java | 182 +-
.../http/processor/HeartBeatProcessor.java | 78 +-
.../http/processor/ReplyMessageProcessor.java | 174 +-
.../http/processor/SendAsyncMessageProcessor.java | 103 +-
.../http/processor/SendSyncMessageProcessor.java | 197 +-
.../http/processor/SubscribeProcessor.java | 109 +-
.../http/processor/UnSubscribeProcessor.java | 133 +-
.../core/protocol/http/processor/inf/Client.java | 21 +-
.../http/processor/inf/HttpRequestProcessor.java | 7 +-
.../protocol/http/producer/EventMeshProducer.java | 13 +-
.../protocol/http/producer/ProducerManager.java | 5 +-
.../protocol/http/producer/SendMessageContext.java | 18 +-
.../http/push/AbstractHTTPPushRequest.java | 33 +-
.../protocol/http/push/AsyncHTTPPushRequest.java | 99 +-
.../core/protocol/http/push/HTTPClientPool.java | 76 +-
.../protocol/http/push/HTTPMessageHandler.java | 21 +-
.../core/protocol/http/push/MessageHandler.java | 3 +
.../core/protocol/http/retry/DelayRetryable.java | 3 +
.../core/protocol/http/retry/HttpRetryer.java | 55 +-
.../protocol/tcp/client/EventMeshTcp2Client.java | 26 +-
.../tcp/client/EventMeshTcpConnectionHandler.java | 14 +-
.../tcp/client/EventMeshTcpExceptionHandler.java | 13 +-
.../tcp/client/EventMeshTcpMessageDispatcher.java | 35 +-
.../tcp/client/group/ClientGroupWrapper.java | 431 +--
.../client/group/ClientSessionGroupMapping.java | 136 +-
.../group/dispatch/DownstreamDispatchStrategy.java | 7 +-
.../dispatch/FreePriorityDispatchStrategy.java | 11 +-
.../rebalance/EventMeshRebalanceService.java | 14 +-
.../rebalance/EventMeshRebalanceStrategy.java | 4 +
.../client/rebalance/EventmeshRebalanceImpl.java | 166 +-
.../client/recommend/EventMeshRecommendImpl.java | 130 +-
.../recommend/EventMeshRecommendStrategy.java | 8 +-
.../core/protocol/tcp/client/session/Session.java | 71 +-
.../tcp/client/session/SessionContext.java | 7 +-
.../tcp/client/session/push/ClientAckContext.java | 39 +-
.../client/session/push/DownStreamMsgContext.java | 83 +-
.../tcp/client/session/push/PushContext.java | 21 +-
.../tcp/client/session/push/SessionPusher.java | 40 +-
.../client/session/retry/EventMeshTcpRetryer.java | 27 +-
.../tcp/client/session/retry/RetryContext.java | 2 +-
.../tcp/client/session/send/SessionSender.java | 56 +-
.../client/session/send/UpStreamMsgContext.java | 25 +-
.../protocol/tcp/client/task/AbstractTask.java | 6 +-
.../core/protocol/tcp/client/task/GoodbyeTask.java | 8 +-
.../protocol/tcp/client/task/HeartBeatTask.java | 10 +-
.../core/protocol/tcp/client/task/HelloTask.java | 31 +-
.../core/protocol/tcp/client/task/ListenTask.java | 8 +-
.../protocol/tcp/client/task/MessageAckTask.java | 16 +-
.../tcp/client/task/MessageTransferTask.java | 75 +-
.../protocol/tcp/client/task/RecommendTask.java | 35 +-
.../protocol/tcp/client/task/SubscribeTask.java | 19 +-
.../protocol/tcp/client/task/UnSubscribeTask.java | 19 +-
.../eventmesh/runtime/domain/BytesMessageImpl.java | 113 -
.../eventmesh/runtime/domain/ConsumeRequest.java | 55 -
.../eventmesh/runtime/domain/NonStandardKeys.java | 30 -
.../eventmesh/runtime/domain/SendResultImpl.java | 39 -
.../runtime/exporter/EventMeshExporter.java | 29 -
.../eventmesh/runtime/exporter/ZipkinExporter.java | 46 -
.../runtime/metrics/http/GroupMetrics.java | 34 -
.../runtime/metrics/http/HTTPMetricsServer.java | 193 +-
.../runtime/metrics/http/HealthMetrics.java | 37 -
.../runtime/metrics/http/TcpSummaryMetrics.java | 395 --
.../runtime/metrics/http/TopicMetrics.java | 33 -
.../OpenTelemetryHTTPMetricsExporter.java | 309 --
.../OpenTelemetryPrometheusExporter.java | 60 -
.../OpenTelemetryTCPMetricsExporter.java | 106 -
.../runtime/metrics/tcp/EventMeshTcpMonitor.java | 248 +-
.../patch/EventMeshConsumeConcurrentlyContext.java | 44 -
.../EventMeshMessageListenerConcurrently.java | 69 -
.../eventmesh/runtime/registry/Registry.java | 18 +-
.../runtime/{exporter => trace}/LogExporter.java | 2 +-
.../runtime/trace/OpenTelemetryTraceFactory.java | 109 -
.../eventmesh/runtime/util/EventMeshUtil.java | 141 +-
.../eventmesh/runtime/util/HttpTinyClient.java | 27 +-
.../apache/eventmesh/runtime/util/IOTinyUtils.java | 20 +-
.../apache/eventmesh/runtime/util/NetUtils.java | 6 +-
.../eventmesh/runtime/util/RemotingHelper.java | 99 +-
.../org/apache/eventmesh/runtime/util/Utils.java | 68 +-
.../eventmesh/runtime/util/ValueComparator.java | 6 +-
.../apache/eventmesh/runtime/util/WebhookUtil.java | 109 +
.../handler/RedirectClientByIpPortHandlerTest.java | 12 +-
.../runtime/client/api/EventMeshClient.java | 6 +-
.../eventmesh/runtime/client/api/PubClient.java | 5 +-
.../eventmesh/runtime/client/api/SubClient.java | 7 +-
.../runtime/client/common/ClientConstants.java | 4 +-
.../runtime/client/common/ClientGlobal.java | 6 +-
.../eventmesh/runtime/client/common/Codec.java | 60 +-
.../runtime/client/common/MessageUtils.java | 20 +-
.../runtime/client/common/RequestContext.java | 7 +-
.../eventmesh/runtime/client/common/Server.java | 2 +-
.../eventmesh/runtime/client/common/TCPClient.java | 21 +-
.../runtime/client/common/UserAgentUtils.java | 12 +-
.../runtime/client/hook/ReceiveMsgHook.java | 4 +-
.../runtime/client/impl/EventMeshClientImpl.java | 57 +-
.../runtime/client/impl/PubClientImpl.java | 29 +-
.../runtime/client/impl/SubClientImpl.java | 64 +-
.../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/AsyncPubClient.java | 8 +-
.../eventmesh/runtime/demo/AsyncSubClient.java | 8 +-
.../eventmesh/runtime/demo/BroadCastPubClient.java | 1 -
.../eventmesh/runtime/demo/BroadCastSubClient.java | 8 +-
.../apache/eventmesh/runtime/demo/CCSubClient.java | 8 +-
.../apache/eventmesh/runtime/demo/CClientDemo.java | 34 +-
.../eventmesh/runtime/demo/SyncPubClient.java | 4 +-
.../eventmesh/runtime/demo/SyncSubClient.java | 10 +-
.../eventmesh/runtime/util/EventMeshUtilTest.java | 4 +-
eventmesh-runtime/src/test/resources/log4j2.xml | 9 +-
eventmesh-sdk-java/build.gradle | 10 +
.../config/EventMeshGrpcClientConfig.java} | 56 +-
.../grpc/consumer/EventMeshGrpcConsumer.java | 264 ++
.../client/grpc/consumer/ReceiveMsgHook.java | 20 +-
.../client/grpc/consumer/SubStreamHandler.java | 161 +
.../client/grpc/producer/CloudEventProducer.java | 136 +
.../grpc/producer/EventMeshGrpcProducer.java | 131 +
.../client/grpc/util/EventMeshClientUtil.java | 223 ++
.../eventmesh/client/http/AbstractHttpClient.java | 10 +-
.../http/consumer/EventMeshHttpConsumer.java | 59 +-
.../http/consumer/context/LiteConsumeContext.java | 102 -
.../consumer/listener/LiteMessageListener.java | 31 -
.../eventmesh/client/http/model/RequestParam.java | 7 +-
.../client/http/producer/CloudEventProducer.java | 76 +-
.../http/producer/EventMeshHttpProducer.java | 23 +-
.../http/producer/EventMeshMessageProducer.java | 67 +-
.../http/producer/EventMeshProtocolProducer.java | 2 +-
.../client/http/producer/OpenMessageProducer.java | 38 +-
.../producer/RRCallbackResponseHandlerAdapter.java | 29 +-
.../client/http/ssl/MyX509TrustManager.java | 11 +-
.../client/http/util/HttpLoadBalanceUtils.java | 19 +-
.../eventmesh/client/http/util/HttpUtils.java | 75 +-
.../eventmesh/client/tcp/EventMeshTCPClient.java | 2 +-
.../client/tcp/EventMeshTCPClientFactory.java | 9 +-
.../client/tcp/EventMeshTCPSubClient.java | 2 +-
.../client/tcp/common/AsyncRRCallback.java | 3 +
.../eventmesh/client/tcp/common/MessageUtils.java | 56 +-
.../client/tcp/common/RequestContext.java | 12 +-
.../eventmesh/client/tcp/common/TcpClient.java | 37 +-
.../client/tcp/conf/EventMeshTCPClientConfig.java | 4 +-
.../tcp/impl/AbstractEventMeshTCPPubHandler.java | 7 +-
.../tcp/impl/AbstractEventMeshTCPSubHandler.java | 7 +-
.../tcp/impl/cloudevent/CloudEventTCPClient.java | 2 +-
.../impl/cloudevent/CloudEventTCPPubClient.java | 18 +-
.../impl/cloudevent/CloudEventTCPSubClient.java | 17 +-
.../EventMeshMessageTCPClient.java | 4 +-
.../EventMeshMessageTCPPubClient.java | 13 +-
.../EventMeshMessageTCPSubClient.java | 9 +-
.../tcp/impl/openmessage/OpenMessageTCPClient.java | 3 +-
.../impl/openmessage/OpenMessageTCPPubClient.java | 1 +
.../impl/openmessage/OpenMessageTCPSubClient.java | 3 +-
.../client/http/demo/AsyncPublishInstance.java | 26 +-
.../client/http/demo/AsyncSyncRequestInstance.java | 28 +-
.../client/http/demo/SyncRequestInstance.java | 26 +-
.../client/http/util/HttpLoadBalanceUtilsTest.java | 5 +-
.../client/tcp/common/EventMeshTestUtils.java | 44 +-
.../tcp/impl/EventMeshTCPClientFactoryTest.java | 14 +-
.../eventmesh-security-api/build.gradle | 2 +
.../org/apache/eventmesh/api/acl/AclService.java | 4 +
.../org/apache/eventmesh/api/auth/AuthService.java | 20 +-
.../api/common}/ConfigurationWrapper.java | 50 +-
.../eventmesh/api/exception/AclException.java | 4 +
.../{AclException.java => AuthException.java} | 7 +-
.../build.gradle | 2 +-
.../gradle.properties | 2 +-
.../auth/http/basic/config/AuthConfigs.java | 33 +-
.../auth/http/basic/impl/AuthHttpBasicService.java | 61 +
.../org.apache.eventmesh.api.auth.AuthService | 6 +-
.../src/main/resources/auth-http-basic.properties | 2 +
.../eventmesh/spi/EventMeshExtensionFactory.java | 21 +-
.../eventmesh/spi/EventMeshExtensionType.java | 2 +
.../org/apache/eventmesh/spi/EventMeshSPI.java | 1 +
.../spi/loader/EventMeshUrlClassLoader.java | 1 +
.../spi/loader/JarExtensionClassLoader.java | 26 +-
.../spi/loader/MetaInfExtensionClassLoader.java | 5 +-
.../spi/EventMeshExtensionFactoryTest.java | 1 +
.../spi/example/TestPrototypeExtension.java | 3 +
.../spi/example/TestSingletonExtension.java | 3 +
.../build.gradle | 0
.../eventmesh-trace-api}/build.gradle | 11 +-
.../eventmesh-trace-api}/gradle.properties | 0
.../eventmesh/trace/api/TracePluginFactory.java | 27 +-
.../apache/eventmesh/trace/api/TraceService.java | 35 +-
.../trace/api/config/ExporterConfiguration.java | 117 +
.../src/main/resources/exporter.properties | 19 +-
.../eventmesh-trace-zipkin}/build.gradle | 16 +-
.../eventmesh-trace-zipkin}/gradle.properties | 3 +
.../eventmesh/trace/zipkin/ZipkinTraceService.java | 118 +
.../trace/zipkin/config/ZipkinConfiguration.java | 96 +
.../org.apache.eventmesh.trace.api.TraceService | 4 +-
.../src/main/resources/zipkin.properties | 4 +
.../gradle.properties | 0
gradle.properties | 2 +-
gradle/wrapper/gradle-wrapper.jar | Bin 58910 -> 59536 bytes
gradle/wrapper/gradle-wrapper.properties | 3 +-
gradlew | 31 +-
gradlew.bat | 49 +-
settings.gradle | 11 +
style/checkStyle.xml | 23 +-
.../third-party-dependencies/check-dependencies.sh | 26 +-
.../known-dependencies.txt | 84 +-
tools/third-party-licenses/LICENSE | 76 +-
...jc-annotations.txt => LICENSE-grpc-context.txt} | 62 +-
...2objc-annotations.txt => LICENSE-grpc-core.txt} | 62 +-
...notations.txt => LICENSE-grpc-netty-shaded.txt} | 62 +-
...objc-annotations.txt => LICENSE-grpc-netty.txt} | 62 +-
...otations.txt => LICENSE-grpc-protobuf-lite.txt} | 62 +-
...c-annotations.txt => LICENSE-grpc-protobuf.txt} | 62 +-
...2objc-annotations.txt => LICENSE-grpc-stub.txt} | 62 +-
...ENSE-commons-beanutils.txt => LICENSE-gson.txt} | 0
...der-okhttp3.txt => LICENSE-httpasyncclient.txt} | 0
...E-assertj-core.txt => LICENSE-httpcore-nio.txt} | 0
...commons-beanutils.txt => LICENSE-ipaddress.txt} | 0
.../licenses/LICENSE-javax.annotation-api.txt | 759 ++++
...E-checker-qual.txt => LICENSE-nacos-client.txt} | 0
...ENSE-netty-all.txt => LICENSE-netty-buffer.txt} | 0
...E-netty-all.txt => LICENSE-netty-codec-dns.txt} | 0
...tty-all.txt => LICENSE-netty-codec-haproxy.txt} | 0
...-netty-all.txt => LICENSE-netty-codec-http.txt} | 0
...netty-all.txt => LICENSE-netty-codec-http2.txt} | 0
...ty-all.txt => LICENSE-netty-codec-memcache.txt} | 0
...-netty-all.txt => LICENSE-netty-codec-mqtt.txt} | 0
...netty-all.txt => LICENSE-netty-codec-redis.txt} | 0
...-netty-all.txt => LICENSE-netty-codec-smtp.txt} | 0
...netty-all.txt => LICENSE-netty-codec-socks.txt} | 0
...netty-all.txt => LICENSE-netty-codec-stomp.txt} | 0
...E-netty-all.txt => LICENSE-netty-codec-xml.txt} | 0
...CENSE-netty-all.txt => LICENSE-netty-codec.txt} | 0
...ENSE-netty-all.txt => LICENSE-netty-common.txt} | 0
...tty-all.txt => LICENSE-netty-handler-proxy.txt} | 0
...NSE-netty-all.txt => LICENSE-netty-handler.txt} | 0
...> LICENSE-netty-resolver-dns-classes-macos.txt} | 0
...=> LICENSE-netty-resolver-dns-native-macos.txt} | 0
...etty-all.txt => LICENSE-netty-resolver-dns.txt} | 0
...SE-netty-all.txt => LICENSE-netty-resolver.txt} | 0
...-all.txt => LICENSE-netty-tcnative-classes.txt} | 0
...t => LICENSE-netty-transport-classes-epoll.txt} | 0
... => LICENSE-netty-transport-classes-kqueue.txt} | 0
...xt => LICENSE-netty-transport-native-epoll.txt} | 0
...t => LICENSE-netty-transport-native-kqueue.txt} | 0
...LICENSE-netty-transport-native-unix-common.txt} | 0
...ty-all.txt => LICENSE-netty-transport-rxtx.txt} | 0
...ty-all.txt => LICENSE-netty-transport-sctp.txt} | 0
...tty-all.txt => LICENSE-netty-transport-udt.txt} | 0
...E-netty-all.txt => LICENSE-netty-transport.txt} | 0
...ns-beanutils.txt => LICENSE-opencensus-api.txt} | 0
...=> LICENSE-opencensus-contrib-grpc-metrics.txt} | 0
....txt => LICENSE-proto-google-common-protos.txt} | 0
.../licenses/LICENSE-protobuf-java.txt | 48 +
...SE-assertj-core.txt => LICENSE-reflections.txt} | 0
...E-cloudevents-api.txt => LICENSE-snakeyaml.txt} | 0
626 files changed, 32101 insertions(+), 8684 deletions(-)
rename docker/{eventmesh-rocketmq => eventmesh}/Dockerfile (94%)
rename docs/cn/instructions/{eclipse.zh-CN.md => eclipse.md} (100%)
create mode 100644 docs/cn/instructions/eventmesh-metrics-Prometheus-instruction.md
create mode 100644 docs/cn/instructions/eventmesh-runtime-quickstart-with-docker.md
create mode 100644 docs/cn/instructions/eventmesh-trace-Zipkin-instruction.md
create mode 100644 docs/en/features/eventmesh-workflow-design.md
create mode 100644 docs/en/instructions/eventmesh-metrics-Prometheus-instruction.md
create mode 100644 docs/en/instructions/eventmesh-trace-Zipkin-instruction.md
create mode 100644 docs/images/Prometheus-download.png
create mode 100644 docs/images/features/eventmesh-workflow-arch.jpg
create mode 100644 docs/images/features/eventmesh-workflow-diag.png
create mode 100644 docs/images/features/eventmesh-workflow-usecase.jpg
create mode 100644 docs/images/prometheus-yml.png
create mode 100644 docs/images/promethus-search.png
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/ServiceState.java => eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/Constants.java (85%)
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/common/ServiceState.java => eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/HttpMethod.java (86%)
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/{tcp/Package.java => grpc/common/BatchMessageWrapper.java} (68%)
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/ProtocolKey.java
copy eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/{tcp/Package.java => grpc/common/SimpleMessageWrapper.java} (67%)
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/common/StatusCode.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/BatchMessage.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/BatchMessageOrBuilder.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/ConsumerServiceGrpc.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/EventmeshGrpc.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Heartbeat.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/HeartbeatOrBuilder.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/HeartbeatServiceGrpc.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/PublisherServiceGrpc.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/RequestHeader.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/RequestHeaderOrBuilder.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Response.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/ResponseOrBuilder.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SimpleMessage.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SimpleMessageOrBuilder.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/Subscription.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/grpc/protos/SubscriptionOrBuilder.java
create mode 100644 eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/ConfigurationContextUtil.java
delete mode 100644 eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/ThreadUtilsTest.java
delete mode 100644 eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/MessagingAccessPointImpl.java
rename eventmesh-examples/bin/{http_pub.sh => http_pub_eventmeshmessage.sh} (98%)
rename eventmesh-examples/bin/{tcp_sub.sh => tcp_eventmeshmessage_sub.sh} (98%)
rename eventmesh-examples/bin/{tcp_pub.sh => tcp_pub_eventmeshmessage.sh} (98%)
rename eventmesh-examples/bin/{tcp_pub_broadcast.sh => tcp_pub_eventmeshmessage_broadcast.sh} (98%)
rename eventmesh-examples/bin/{tcp_sub_broadcast.sh => tcp_sub_eventmeshmessage_broadcast.sh} (98%)
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/common/ExampleConstants.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/cloudevents/CloudEventsBatchPublishInstance.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/cloudevents/CloudEventsPublishInstance.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/cloudevents/CloudEventsRequestInstance.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/AsyncPublishBroadcast.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/AsyncPublishInstance.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/BatchPublishInstance.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/pub/eventmeshmessage/RequestReplyInstance.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/CloudEventsAsyncSubscribe.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/CloudEventsSubscribeReply.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/EventmeshAsyncSubscribe.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/EventmeshSubscribeBroadcast.java
create mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/grpc/sub/EventmeshSubscribeReply.java
copy eventmesh-examples/src/main/java/org/apache/eventmesh/{http/demo/sub => grpc/sub/app}/SpringBootDemoApplication.java (96%)
copy eventmesh-examples/src/main/java/org/apache/eventmesh/{http/demo/sub => grpc/sub/app}/controller/SubController.java (88%)
copy eventmesh-examples/src/main/java/org/apache/eventmesh/{http/demo/sub => grpc/sub/app}/service/SubService.java (53%)
delete mode 100644 eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java
copy {eventmesh-connector-plugin => eventmesh-metrics-plugin}/build.gradle (100%)
copy {eventmesh-connector-plugin/eventmesh-connector-api => eventmesh-metrics-plugin/eventmesh-metrics-api}/build.gradle (82%)
copy {eventmesh-admin => eventmesh-metrics-plugin/eventmesh-metrics-api}/gradle.properties (100%)
copy eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/ReceiveMsgHook.java => eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/MetricsPluginFactory.java (53%)
copy eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java => eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/MetricsRegistry.java (57%)
rename eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/SummaryMetrics.java => eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/HttpSummaryMetrics.java (76%)
copy eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java => eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/Metric.java (84%)
create mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-api/src/main/java/org/apache/eventmesh/metrics/api/model/TcpSummaryMetrics.java
copy {eventmesh-connector-plugin/eventmesh-connector-api => eventmesh-metrics-plugin/eventmesh-metrics-prometheus}/build.gradle (63%)
copy {eventmesh-security-plugin/eventmesh-security-acl => eventmesh-metrics-plugin/eventmesh-metrics-prometheus}/gradle.properties (95%)
create mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/PrometheusMetricsRegistry.java
create mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfiguration.java
create mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/metrics/PrometheusHttpExporter.java
create mode 100644 eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/java/org/apache/eventmesh/metrics/prometheus/metrics/PrometheusTcpExporter.java
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/gradle.properties => eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.metrics.api.MetricsRegistry (91%)
copy eventmesh-examples/gradle.properties => eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/resources/prometheus.properties (90%)
rename {eventmesh-runtime/conf => eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/main/resources}/prometheus.yml (99%)
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq/config/ConfigurationWrapperTest.java => eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/java/org/apache/eventmesh/metrics/prometheus/config/PrometheusConfigurationTest.java (74%)
copy eventmesh-runtime/gradle.properties => eventmesh-metrics-plugin/eventmesh-metrics-prometheus/src/test/resources/prometheus.properties (95%)
copy {eventmesh-admin => eventmesh-metrics-plugin}/gradle.properties (100%)
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/grpc/GrpcMessageProtocolResolver.java
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-grpc/build.gradle
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-grpc/src/main/proto/eventmesh-client.proto
create mode 100644 eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/grpc/GrpcMessageProtocolResolver.java
copy {eventmesh-connector-plugin/eventmesh-connector-standalone => eventmesh-registry-plugin/eventmesh-registry-nacos}/build.gradle (82%)
copy eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/LifeCycle.java => eventmesh-registry-plugin/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/constant/NacosConstant.java (64%)
create mode 100644 eventmesh-registry-plugin/eventmesh-registry-nacos/src/main/java/org/apache/eventmesh/registry/nacos/service/NacosRegistryService.java
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/gradle.properties => eventmesh-registry-plugin/eventmesh-registry-nacos/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.registry.RegistryService (91%)
create mode 100644 eventmesh-registry-plugin/eventmesh-registry-nacos/src/test/java/org/apache/eventmesh/registry/nacos/service/NacosRegistryServiceTest.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/EventMeshGrpcServer.java
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/configuration/{EventMeshHTTPConfiguration.java => EventMeshGrpcConfiguration.java} (58%)
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/ConsumerManager.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/EventMeshConsumer.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/ConsumerGroupClient.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/ConsumerGroupTopicConfig.java
rename eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/HandleResult.java => eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/GrpcType.java (86%)
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/StreamTopicConfig.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/consumer/consumergroup/WebhookTopicConfig.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/BatchPublishMessageProcessor.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/HeartbeatProcessor.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/ReplyMessageProcessor.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/RequestMessageProcessor.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/SendAsyncMessageProcessor.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/SubscribeProcessor.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/SubscribeStreamProcessor.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/processor/UnsubscribeProcessor.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/producer/EventMeshProducer.java
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/{http => grpc}/producer/ProducerManager.java (71%)
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/{http => grpc}/producer/SendMessageContext.java (67%)
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/AbstractPushRequest.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/HandleMsgContext.java
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/{http/push/HTTPMessageHandler.java => grpc/push/MessageHandler.java} (52%)
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/StreamPushRequest.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/push/WebhookPushRequest.java
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/{http => grpc}/retry/DelayRetryable.java (92%)
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/retry/GrpcRetryer.java
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/{http => grpc}/retry/RetryContext.java (96%)
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ConsumerService.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/EventEmitter.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/HeartbeatService.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ProducerService.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/grpc/service/ServiceUtils.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/BytesMessageImpl.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/ConsumeRequest.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/NonStandardKeys.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/SendResultImpl.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/exporter/EventMeshExporter.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/exporter/ZipkinExporter.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/GroupMetrics.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/HealthMetrics.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/TcpSummaryMetrics.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/http/TopicMetrics.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryHTTPMetricsExporter.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryPrometheusExporter.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/metrics/opentelemetry/OpenTelemetryTCPMetricsExporter.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/patch/EventMeshConsumeConcurrentlyContext.java
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/patch/EventMeshMessageListenerConcurrently.java
rename eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/{exporter => trace}/LogExporter.java (98%)
delete mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/trace/OpenTelemetryTraceFactory.java
create mode 100644 eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/WebhookUtil.java
delete mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/CSVFormat.java
delete mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/Data.java
delete mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/OMSFactoryTest.java
delete mode 100644 eventmesh-runtime/src/test/java/org/apache/eventmesh/runtime/cloudevent/OMSWriterTest.java
copy eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/{http/conf/EventMeshHttpClientConfig.java => grpc/config/EventMeshGrpcClientConfig.java} (51%)
create mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/EventMeshGrpcConsumer.java
rename eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/domain/RocketMQConstants.java => eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/ReceiveMsgHook.java (71%)
create mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/consumer/SubStreamHandler.java
create mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/CloudEventProducer.java
create mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/producer/EventMeshGrpcProducer.java
create mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/grpc/util/EventMeshClientUtil.java
delete mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/context/LiteConsumeContext.java
delete mode 100644 eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/listener/LiteMessageListener.java
copy eventmesh-spi/src/test/java/org/apache/eventmesh/spi/example/TestSingletonExtension.java => eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/auth/AuthService.java (72%)
copy {eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config => eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/common}/ConfigurationWrapper.java (57%)
copy eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/exception/{AclException.java => AuthException.java} (85%)
copy eventmesh-security-plugin/{eventmesh-security-acl => eventmesh-security-auth-http-basic}/build.gradle (99%)
copy eventmesh-security-plugin/{eventmesh-security-acl => eventmesh-security-auth-http-basic}/gradle.properties (96%)
copy eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java => eventmesh-security-plugin/eventmesh-security-auth-http-basic/src/main/java/org/apache/eventmesh/auth/http/basic/config/AuthConfigs.java (55%)
create mode 100644 eventmesh-security-plugin/eventmesh-security-auth-http-basic/src/main/java/org/apache/eventmesh/auth/http/basic/impl/AuthHttpBasicService.java
copy eventmesh-connector-plugin/eventmesh-connector-rocketmq/gradle.properties => eventmesh-security-plugin/eventmesh-security-auth-http-basic/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.auth.AuthService (90%)
copy eventmesh-examples/gradle.properties => eventmesh-security-plugin/eventmesh-security-auth-http-basic/src/main/resources/auth-http-basic.properties (95%)
copy {eventmesh-connector-plugin => eventmesh-trace-plugin}/build.gradle (100%)
copy {eventmesh-connector-plugin/eventmesh-connector-api => eventmesh-trace-plugin/eventmesh-trace-api}/build.gradle (82%)
copy {eventmesh-admin => eventmesh-trace-plugin/eventmesh-trace-api}/gradle.properties (100%)
copy eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/ReceiveMsgHook.java => eventmesh-trace-plugin/eventmesh-trace-api/src/main/java/org/apache/eventmesh/trace/api/TracePluginFactory.java (54%)
copy eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java => eventmesh-trace-plugin/eventmesh-trace-api/src/main/java/org/apache/eventmesh/trace/api/TraceService.java (63%)
create mode 100644 eventmesh-trace-plugin/eventmesh-trace-api/src/main/java/org/apache/eventmesh/trace/api/config/ExporterConfiguration.java
copy eventmesh-common/src/test/resources/configuration.properties => eventmesh-trace-plugin/eventmesh-trace-api/src/main/resources/exporter.properties (67%)
copy {eventmesh-connector-plugin/eventmesh-connector-api => eventmesh-trace-plugin/eventmesh-trace-zipkin}/build.gradle (76%)
copy {eventmesh-examples => eventmesh-trace-plugin/eventmesh-trace-zipkin}/gradle.properties (95%)
create mode 100644 eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/java/org/apache/eventmesh/trace/zipkin/ZipkinTraceService.java
create mode 100644 eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/java/org/apache/eventmesh/trace/zipkin/config/ZipkinConfiguration.java
copy eventmesh-connector-plugin/eventmesh-connector-standalone/gradle.properties => eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.trace.api.TraceService (92%)
copy eventmesh-examples/gradle.properties => eventmesh-trace-plugin/eventmesh-trace-zipkin/src/main/resources/zipkin.properties (88%)
copy {eventmesh-admin => eventmesh-trace-plugin}/gradle.properties (100%)
copy tools/third-party-licenses/licenses/{LICENSE-j2objc-annotations.txt => LICENSE-grpc-context.txt} (87%)
copy tools/third-party-licenses/licenses/{LICENSE-j2objc-annotations.txt => LICENSE-grpc-core.txt} (87%)
copy tools/third-party-licenses/licenses/{LICENSE-j2objc-annotations.txt => LICENSE-grpc-netty-shaded.txt} (87%)
copy tools/third-party-licenses/licenses/{LICENSE-j2objc-annotations.txt => LICENSE-grpc-netty.txt} (87%)
copy tools/third-party-licenses/licenses/{LICENSE-j2objc-annotations.txt => LICENSE-grpc-protobuf-lite.txt} (87%)
copy tools/third-party-licenses/licenses/{LICENSE-j2objc-annotations.txt => LICENSE-grpc-protobuf.txt} (87%)
copy tools/third-party-licenses/licenses/{LICENSE-j2objc-annotations.txt => LICENSE-grpc-stub.txt} (87%)
copy tools/third-party-licenses/licenses/{LICENSE-commons-beanutils.txt => LICENSE-gson.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-zipkin-sender-okhttp3.txt => LICENSE-httpasyncclient.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-assertj-core.txt => LICENSE-httpcore-nio.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-commons-beanutils.txt => LICENSE-ipaddress.txt} (100%)
create mode 100644 tools/third-party-licenses/licenses/LICENSE-javax.annotation-api.txt
copy tools/third-party-licenses/licenses/{LICENSE-checker-qual.txt => LICENSE-nacos-client.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-buffer.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec-dns.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec-haproxy.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec-http.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec-http2.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec-memcache.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec-mqtt.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec-redis.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec-smtp.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec-socks.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec-stomp.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec-xml.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-codec.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-common.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-handler-proxy.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-handler.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-resolver-dns-classes-macos.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-resolver-dns-native-macos.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-resolver-dns.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-resolver.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-tcnative-classes.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-transport-classes-epoll.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-transport-classes-kqueue.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-transport-native-epoll.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-transport-native-kqueue.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-transport-native-unix-common.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-transport-rxtx.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-transport-sctp.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-transport-udt.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-netty-all.txt => LICENSE-netty-transport.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-commons-beanutils.txt => LICENSE-opencensus-api.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-commons-beanutils.txt => LICENSE-opencensus-contrib-grpc-metrics.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-rocketmq-acl.txt => LICENSE-proto-google-common-protos.txt} (100%)
create mode 100644 tools/third-party-licenses/licenses/LICENSE-protobuf-java.txt
copy tools/third-party-licenses/licenses/{LICENSE-assertj-core.txt => LICENSE-reflections.txt} (100%)
copy tools/third-party-licenses/licenses/{LICENSE-cloudevents-api.txt => LICENSE-snakeyaml.txt} (100%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org