This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git.
from e4cff57 merg branch 1.2.0 release to master (#403)
new a1bbe89 [issue #176]Support Spi for extended implementation to
accommodate a variety of MQ
new addc672 event mesh project architecture adjustment
new 4a1b061 update rocketmq plugin impl
new 08149a2 update rocketmq plugin impl remove unused code
new 8054900 fix configurationWraper miss load
new 8507c63 update RocketMQConsumerImpl and PushConsumerImpl supply get
defaultPushConsumer
new 22ebe9f update RocketMQProducerImpl and MQProducerWrapper supply get
defaultMQProducer
new 1161c85 1.add module eventmesh-connector-api 2.change runtime and
connector dependency
new dccdc13 1.support rocketmq-connector plugin 2.modify
eventmesh-runtime imported classes from eventmesh-common
new e559d80 modify:add defibus plugin
new 214101b Merge branch '1.2.0' of
https://github.com/WeBankFinTech/EventMesh
new be0abfc 1.modify MQConsumerWrapper import ProxyConstants
new 0efcedd 1.support rocketmq-connector plugin 2.modify
eventmesh-runtime imported classes from eventmesh-common
new bb95114 1.support rocketmq-connector plugin 2.modify
eventmesh-runtime imported classes from eventmesh-common
new 00aa8e0 Merge branch '1.2.0' of https://github.com/xwm1992/EventMesh
into 1.2.0
new b7ff1e7 1.move rocketmq dependency from eventmesh-runtime to
eventmesh-connector-rocketmq 2.modify http processor
new 53374b3 Merge pull request #1 from WeBankFinTech/1.2.0
new f4f3210 Merge pull request #178 from xwm1992/1.2.0
new a8551de Merge branch '1.2.0' of
https://github.com/WeBankFinTech/EventMesh into 1.2.0
new dbae8bc gradle config modify
new ba8ba20 eventmesh-api modify
new 49c1bf9 eventmesh-connector-defibus modify:rename package, plugin impl
new 7b6816e eventmesh-runtime modify,delete rocketmq dependency
new 39d9178 Merge pull request #181 from lrhkobe/1.2.0
new ced6110 Merge branch '1.2.0' of
https://github.com/WeBankFinTech/EventMesh into 1.2.0
new c27a419 1.move rocketmq dependency from eventmesh-runtime to
eventmesh-connector-rocketmq 2.modify http processor 3.modify http subscribe
new 39df4f0 1.update connector-rocketmq version 2.change the directory
structure 3.add starter module
new 476a5fc 1.change starter version
new 19e0ee5 1.update root module version
new 8817cee 1.update eventmesh-rocketmq access_driver url 2.add
ProxyConsumer
new 7535b7d Merge pull request #183 from xwm1992/1.2.0
new 3afe038 1.eventmesh-api modify methodName 2.eventmesh-connector
modify relative method impl 3.attribute store place modify in msgConvert
new fc1b4d9 Merge pull request #185 from xwm1992/1.2.0
new ed3312e Merge branch '1.2.0' of
https://github.com/WeBankFinTech/EventMesh into 1.2.0
new f9d87cc remove dependency of eventmesh-common
new c7235b8 move defibus-client config from eventmesh-runtime to defibus
plugin
new 0d72f9c move rocketmq-client config from eventmesh-runtime to
rocketmq plugin
new 20744e2 1.fix manual ack problem 2.adjust runtime config file
new 6270c08 1.modify test tcp sdk demo
new 95f1f91 Merge pull request #187 from lrhkobe/1.2.0
new a17e11b Merge branch '1.2.0' of
https://github.com/WeBankFinTech/EventMesh into 1.2.0
new 451a77a 1.support http sub
new ca628f4 1.modify http sub
new 3233ea4 1.support http sub and SubscribeProcessor
new 9eb16cf 1.support http sub 2.support http subscription manage
3.support http heartBeat manage
new c40b891 1.update eventmesh-runtime start.sh
new 125595e 1.modify HeartBeatProcessor error retcode
new 3093ccd 1.modify .md files under the instructions 2.modify eventmesh
structure pictures 3.add protocol.md
new 451b334 1.modify docs\cn README.md
new 4a308a5 1.modify eventmesh README.md 2.modify eventmesh structure
pictures
new 15a731d 1.modify eventmesh README.md update protocol and roadmap
new 91ca467 Merge pull request #191 from xwm1992/1.2.0
new 2b2c0f6 1.modify protocol.zh-CN.md 2.modify README.md, README.zh-CN.md
new 9ccc42b Merge pull request #192 from xwm1992/1.2.0
new 4812fbb Merge pull request #174 from Candimy/master
new 5333e08 Update gitee-mirror.yml
new 65e4605 update moudles
new 6a32f5b Merge branch 'develop' of
https://github.com/WeBankFinTech/EventMesh into 1.2.0
new d41cf8e Merge pull request #194 from xwm1992/1.2.0
new 060c946 1.modify structure picture 2.fix Constants http time out value
new 6dff015 Merge pull request #195 from xwm1992/1.2.0
new 4bac2a4 1.modify roadMap
new 9dd626e Merge pull request #197 from xwm1992/1.2.0
new 3113fd1 fix rr reply bug,rollback delete config file in
eventmesh-common
new 080b57f Merge pull request #189 from lrhkobe/1.2.0
new 8f03048 1.bug fix:fix consumer missing bizNo
new b34d1ee 1.bug fix: fix rocketmq consumer missing bizNo
new 60ba2a0 Merge pull request #209 from xwm1992/1.2.0
new 1e4e503 [ISSUE #211]Rocketmq-connector throw nullpointer exception
new e5b4d5a Merge pull request #214 from xwm1992/1.2.0
new b87cc1b [ISSUE #212]For multiple listening instances, only the last
started instance can receive messages
new a7cf5f9 [ISSUE #212]For multiple listening instances, only the last
started instance can receive messages
new c5ef5e7 Merge pull request #215 from xwm1992/1.2.0
new ad8badc [ISSUE #216]EventMesh ProxyTcpRetryer throws
NumberFormatException
new a313ac7 Merge pull request #217 from xwm1992/1.2.0
new 8967dca [ISSUE #201]Could we support running eventmesh in docker
new d69f1d9 Merge pull request #218 from xwm1992/1.2.0
new 6cd07ad [ISSUE #222]When onChange is NEW, eventMesh occurred
NullPointException
new 28ee655 [ISSUE #226]eventMesh-rocketmq-connector tcp pub throw
operation time out exception
new ff72413 Merge pull request #227 from xwm1992/1.2.0
new 9a6f841 1.update eventmesh-define.png 2.update
eventmesh-runtime-quickstart.md and supply project-structure.png
new 2c2b4a0 Merge branch '1.2.0' of https://github.com/xwm1992/EventMesh
into 1.2.0
new 861ad5c Merge pull request #228 from xwm1992/1.2.0
new 18626fd update eventmesh-runtime.png
new b658fa8 Merge pull request #231 from xwm1992/1.2.0
new 12450b0 1.update .md files 2.update eventmesh-panels.png
project-structure.png
new da2e729 Merge pull request #233 from xwm1992/1.2.0
new 353a8a1 update .md files
new c15746b Merge pull request #234 from xwm1992/1.2.0
new 7e3b5db update README.md
new 69b09b9 Merge pull request #235 from xwm1992/1.2.0
new 46b20a3 update .md files
new f21a3eb Merge pull request #236 from xwm1992/1.2.0
new 43f9476 update README.md
new 12f4289 update RoadMap
new e3a6d50 Merge pull request #238 from xwm1992/1.2.0
new 40426d2 [ISSUE #237]Remove eventmesh-defibus-connector and normalize
code and file naming
new bc5152a Merge pull request #240 from xwm1992/1.2.0
new 6984ea9 [ISSUE #219]Supply detail information or read.me for
eventmesh running in docker
new be75b5b add english protocol document of eventmesh-runtime
new fe73472 update protocol document of eventmesh-runtime
new ff8a25d update README.md
new f7ce474 Merge pull request #244 from lrhkobe/1.2.0
new 42d9fdb Merge pull request #193 from WeBankFinTech/1.2.0
new d269154 Merge pull request #196 from WeBankFinTech/1.2.0
new 3959ea4 Merge pull request #198 from WeBankFinTech/1.2.0
new 2643c9e Merge pull request #205 from WeBankFinTech/1.2.0
new 05f7d36 Merge pull request #210 from WeBankFinTech/1.2.0
new 3e55934 Bump ini from 1.3.5 to 1.3.8
new e6a498d Merge pull request #177 from
WeBankFinTech/dependabot/npm_and_yarn/ini-1.3.8
new 37405ce Merge pull request #223 from WeBankFinTech/1.2.0
new 200c012 Format the style in the contributor guide.
new 5b9cc6b Merge pull request #224 from ShannonDing/patch-1
new c651502 Merge pull request #232 from WeBankFinTech/1.2.0
new e93b350 Merge pull request #239 from WeBankFinTech/1.2.0
new 0e0a35b Update README.md
new 0ae3bad Update README.md
new 4619017 Update README.md
new 354f1a4 Update README.md
new ea5c13b Update README.md
new d640e99 Merge pull request #241 from WeBankFinTech/1.2.0
new 115dabb Merge branch 'develop' into 1.2.0
new a959ce1 Merge branch '1.2.0' of
https://github.com/WeBankFinTech/EventMesh into 1.2.0
new 07bf12a update eventmesh-runtime-quickstart.zh-CN.md
new 499e478 [ISSUE #219]Supply detail information or read.me for
eventmesh running in docker
new e37d458 update quickstart.md
new c12a511 [ISSUE #256]Upgrade Openmessaging-api to 2.2.1-pubsub version
new 43ae020 1.update Constants 2.remove unused files
BytesMessageImpl.java and SendResultImpl.java
new 0598d75 supply not supportedOperation for consumerImpl
new 29ed0a0 update eventmesh-runtime.png and quickstart.zh-CN
new ca5a3a2 Merge pull request #247 from xwm1992/1.2.0
new 4060887 Merge pull request #248 from xwm1992/1.2.0
new 613623b Merge branch '1.2.0' of
https://github.com/WeBankFinTech/EventMesh into 1.2.0
new 20bfb9a Merge pull request #245 from WeBankFinTech/1.2.0
new e26c12e Merge pull request #249 from WeBankFinTech/1.2.0
new 3a42b21 Update README.md
new a8d680d Merge branch 'develop' of
https://github.com/WeBankFinTech/EventMesh into 1.2.0
new 57d2059 Merge pull request #254 from xwm1992/1.2.0
new 16c8a1d Merge pull request #255 from WeBankFinTech/1.2.0
new ae7da03 Merge pull request #258 from wqliang/1.2.1
new 636dcaa Merge branch '1.2.1' of
https://github.com/WeBankFinTech/EventMesh into 1.2.1
new 56e8e2a Merge pull request #259 from WeBankFinTech/1.2.1
new dc15881 [ISSUE #261]remove module eventmesh-registry
new e736fcf Merge pull request #262 from MajorHe1/1.2.1
new 9834373 Merge pull request #264 from WeBankFinTech/1.2.1
new b2f087c Bump prismjs from 1.22.0 to 1.23.0
new 73faf5f Merge pull request #230 from
WeBankFinTech/dependabot/npm_and_yarn/prismjs-1.23.0
new 0ba310b Bump elliptic from 6.5.3 to 6.5.4
new 59818a6 Merge pull request #246 from
WeBankFinTech/dependabot/npm_and_yarn/elliptic-6.5.4
new 1997e8b Bump y18n from 4.0.0 to 4.0.1
new 86e490f Merge pull request #260 from
WeBankFinTech/dependabot/npm_and_yarn/y18n-4.0.1
new b12bd52 [ISSUE #265]rename wemq and access to eventmesh
new a1f43c7 [ISSUE #265]rename proxy field to eventmesh
new 3d85d31 Merge pull request #266 from MajorHe1/1.2.2
new a8479cc [ISSUE #265] Specification of code structure and file naming
new fdd0bee upgrade gradle to 6.8.3
new 75c2646 Merge branch 'master' into develop
new 047a7f1 merge conflict
new 4c037eb merge conflict
new b0d2824 remove warn
new ccaae00 Merge pull request #252 from yangjun781120/master
new e7b4439 Merge branch 'develop' of
https://github.com/WeBankFinTech/EventMesh into 1.2.2
new 25438d6 remove eventmesh-registry module
new 2305ace Merge pull request #268 from wqliang/1.2.2
new f60e6cb Merge branch '1.2.2' of
https://github.com/WeBankFinTech/EventMesh into 1.2.2
new 5c4a1bb enabled http/tcp monitor logs
new 586dabe Merge pull request #269 from WeBankFinTech/1.2.2
new a2716fd Update README.md
new 1a1c325 Merge pull request #273 from qqeasonchen/patch-3
new ebe587b Changed com.webank to org.apache
new 06ca2f5 Merge pull request #285 from udesh/issue_278
new 97e59e3 refactor runtime module package com.webank to org.apache
new 33808d6 Merge pull request #300 from
liangyuanpeng/dev_refactor_package
new 014ecb6 refactor(eventmesh-sdk-java):rename to org.apache(#281)
new 0901e70 [ISSUE #281]refactor(eventmesh-sdk-java):rename to org.apache
new b8a5e80 Merge pull request #301 from zhangxiaopengmm/develop
new a99adc8 issue #277:refactor eventmesh-common package with org.apache
new 8e12c9c issue #277:rename package with org.apache
new 92cf430 Merge pull request #286 from keranbingaa/develop
new 60f7c96 Update README.zh-CN.md
new 6b86d30 Merge pull request #289 from apache/qqeasonchen-patch-1
new 8146fe6 [ISSUE #282]Refactor 'eventmesh-starter' package name to
org.apache
new 4403e33 Merge pull request #287 from yiliuchen/develop
new af6c352 Refactor 'eventmesh-connector-rocketmq' package name to
org.apache
new d463f8a Merge pull request #288 from sunxi92/fix
new 4eedbd7 Refactor 'eventmesh-test' package name to org.apache #283
new c7e3820 Refactor 'eventmesh-test' package name to org.apache #283
new aa132fd Refactor 'eventmesh-test' package name to org.apache #283
new 6d0621c Refactor 'eventmesh-test' package name to org.apache #283
new c33d157 Refactor 'eventmesh-test' package name to org.apache #283
new f77b49f Merge pull request #299 from surilli/develop
new 71b6441 Update codeStyle.xml
new 77a6565 Merge pull request #291 from apache/qqeasonchen-patch-2
new 9fdceed add licenses of apache for runtime module
new afa9f95 Merge pull request #303 from liangyuanpeng/fix_add_licenses
new adb4b90 add NOTICE
new 749072a Merge pull request #305 from iNanos/develop
new 241f553 bugfix for event-mesh-test module
new 648a57b change package name to org.apache
new aa2582b change package name to org.apache
new 79e2f7b format README.md
new 01fe061 change package name to org.apache
new 857d069 Merge pull request #307 from jonyangx/develop
new 49d1675 fix ISSUE #296:add licenses in each source file under the
eventmesh-sdk-java
new 37f670c Merge pull request #308 from keranbingaa/develop
new 471c151 [ISSUE #294]add licenses in file under
eventmesh-connector-rocketmq module
new 54b3bf8 Merge pull request #309 from yiliuchen/develop
new 0663245 [ISSUE #293]Lack of licenses in each source file under the
eventmesh-connector-api module
new bf5046f Merge pull request #311 from wqliang/develop
new bba5bc6 [ISSUE #298]Lack of licenses in each source file under the
eventmesh-test module
new 50c4ae0 Merge pull request #312 from xwm1992/develop
new a3f1c63 [ISSUE #297]Lack of licenses in each source file under the
eventmesh-starter module
new f9a9a0f Merge pull request #314 from xwm1992/develop
new fa37c43 Create .asf.yaml
new a233b1e Update .asf.yaml
new 514475d Merge pull request #315 from apache/qqeasonchen-patch-3
new 9329b7c Update .asf.yaml (#316)
new 5abc9f4 Update README.md
new ce335ed Update .asf.yaml
new 3283756 bugfix build.gradle tar task (#318)
new 973eaa0 [ISSUE #322] Rename package name "com.webank.eventmesh" to
"org.apache.eventmesh" (#319)
new abe06b9 fix(docs): change the travis location
new 65aab8a Create DISCLAIMER-WIP
new 639066a Delete CNAME
new acc483f Delete _config.yml
new 31ec7bd Delete package.json
new 95f20c6 Add files via upload
new e538163 Add files via upload
new ebd07c9 Delete eventmesh-multi-runtime.jpg
new ba5a765 Update README.md
new 98164a7 Update eventmesh-runtime-quickstart.md
new 9f986a4 Update README.zh-CN.md
new 31c9136 Update eventmesh-runtime-quickstart.zh-CN.md
new 8cf2a39 [ISSUE #325]Update gradle configuration for publishing
package to maven repository (#326)
new 2c5f0fc upgrade gradle to 7.0 and fix test bug. (#327)
new 3cd6e2a remove unused files
new 4de90ce prepare to release 1.2.0
new ad3f7ff update 1.2.0-release branch code (#399)
new 60f3fd8 update 1.2.0-release branch code (#400)
new 6b0c35f Create CNAME
new 739534b Add files via upload
new 5d3e974 Merge branch 'master' of https://github.com/xwm1992/EventMesh
new d30acc5 Merge branch 'master' of
https://github.com/apache/incubator-eventmesh
new dd69b23 [ISSUE #355] Setup Github workflows for CodeQL scans (#356)
new 76e9670 Migrate CI to Github Actions and enable coverage report (#365)
new 6b4eb3b [ISSUE #310] add github action for check license (#313)
new 34ac667 [ISSUE #310] Enable Github Actions for license check and fix
license headers (#377)
new 660d581 [ISSUE #359] Split handler from controller (#359) (#360)
new cc09132 [Issue #386] fixing ConsumerGroup Queue Consumer Offset not
synced up issue (#387)
new 78a3efe [ISSUE #366 ] remove custom-format topic concept (#388)
new f738036 [ISSUE #366] remove custom concept [dcn&®ion] (#390)
new 0d96267 [ISSUE #391] Optimize interface design in
eventmesh-connector-api (#392)
new 7455778 [ISSUE #406] Github Actions: Resource not accessible by
integration (#407)
new 62413b6 [ISSUE #411] Enable CI workflows running on
[0-9]+.[0-9]+.[0-9]+** branches (#412)
new 9ae313d Update README.md
new 1ae6ba2 Update README.zh-CN.md
new f1b36d7 Merge 1.3.0 to develop. (#430)
new ce1c872 [ISSUE #425] Using templates to encourage useful issues and
PRs (#426)
new 62f06e5 fix ConfigurationWrapper typo (#437)
new da16271 [ISSUE #438] Enable Github Actions for Checkstyle (#439)
new 6af80b6 [ISSUE #436] Fix typo errors for runtime package (#441)
new 8d08363 [ISSUE #428]Fix Chinese annotation (#431)
new f753a52 [ISSUE #367] Support prototype spi instance (#432)
new 92e68b6 add test case. (#440)
new beb33d1 Delete sChat2.jks
new bf9f69c [ISSUE #442] Fix findings filtered by Checkstyle workflow
(#443)
new 42cc92d [ISSUE #367] Refactor connector (#433)
new d65017c Add files via upload
new 9051b1b [ISSUE #274] Adding Eventmesh Stream component to support
Event Streaming (#445)
new 18e2c9b fix netty options (#449)
new cb8f457 [ISSUE #456] Automatic License report and check (#462)
new cb63b30 [ISSUE #451] Fix SSLContext Initialize error (#458)
new ebc81dd [ISSUE #457] message ack problem in retry or repush by
closeSession (#459)
new 5087166 [ISSUE #461] fix global flow control problem (#469)
new d37dc0a [ISSUE #460]Support custom retry times configuration when
SubcriptionType is SYNC (#463)
new 45a15fb [ISSUE #465]All third part dependencies should be controlled
at root build.gradle (#466)
new f89f98d [ISSUE #468] ThreadUtilTest failed (#470)
new 811c633 [ISSUE #374] add unit test for header class. (#472)
new dd5c339 maybe there is no need to use atomicboolean here (#474)
new c7f91db [ISSUE #476] Biz Exceptions occured in EventMesh cause
connection close of client (#477)
new a14e7b3 Update CONTRIBUTING.zh-CN.md
new 47b0036 Update CONTRIBUTING.md
new 83aaaee Add SPI design docs (#480)
new 78127a0 fix configuration property get error (#479)
new 0334fd2 Update README.md
new 04cd29f Update README.zh-CN.md
new ba77ea6 [ISSUE #484] Support access control for EventMesh (#485)
new fa603c4 Update README.md
new 23913af Update README.zh-CN.md
new b6b03e7 remove webank lisence
new 41c94fa Add files via upload
new 719229b use RandomStringGenerator instead deprecated class
RandomStringUtils (#495)
new 95a6991 Add files via upload
new 09ada0e [ISSUE #496] fix the ClassCastException (#499)
new 92c60b2 [ISSUE #340]merge otel metric branch 2 develop (#494)
new 59e8977 [ISSUE #492] Support resources initilization and release of
connector in EventMesh (#493)
new b38f44a [ISSUE #488]Support registry adaptor plugin (#489)
new f005e6c polish quickstart (#504)
new 9d4d538 [ISSUE #339] add design doc for integrating OpenSchema (#502)
new ba10b9a otel metric polish (#503)
new 7c76d5c [ISSUE #490] Support service invocation (#508)
new b9e4f8e [ISSUE #505]remove all RandomStringUtils. (#510)
new ac53cc2 add http trace http point. (#509)
new 255d890 Improve the directory structure of docs (#516)
new 8376189 change eventmesh-test to eventmesh-examples
new 4473711 change eventmesh-test to eventmesh-examples
new ae3fab6 [ISSUE #435] Initial Creation of eventMesh-admin module in
EventMesh (#513)
new 4527f8d Issue #405 Fix SubscriptionType typo error (#522)
new b3d036c [ISSUE #375] In memory as event store (#507)
new c0d6dcf [ISSUE #339] Add a skeleton for separated openschema registry
service and implement most APIs that doesn't need compatibility check. (#525)
new e6c4b2c Lint and fix style of Markdown files in docs (#533)
new 66bc41f Implement the conversion from openmessaging to cloudevent
(#514)
new f87e896 rename name and package path of schema-registry module
new bcaa91b [ISSUE #541] rename issue (#542)
new 492ae1a [Issue #523] Adding Flow control RateLimiter support in Http
Message Send Processor (#524)
new 73eac00 [Issue #528] enhance Retry support for HTTP and TCP
processors. (#529)
new 73ed0d4 update readme
new 623f007 update quickstart
new 154f4d7 [ISSUE #367] Optimize plugin load (#519)
new 0f8a4ae update namesrv registry name
new 3ee9c96 add weighted random load balance selector (#526)
new d554f30 Update README.md
new 9b573ea Update README.md
new 3b809fe Update the checkstyle file and remove code style file (#552)
new f802ed2 Change issue template to yml (#521)
new 9905876 [Issue #554] Removing hardcoded username and password in the
project code (#555)
new 3a96727 Fix issue template (#556)
new 91dacf0 Preview docs (#543)
new 37fbff2 [ISSUE #550] Remove unused jar in plugin module (#551)
new e130143 Revert "[Issue #554] Removing hardcoded username and password
in the project code (#555)" (#559)
new 4471b43 [ISSUE #550] Deduplicate plugin jar (#558)
new 6513403 [ISSUE #536] fix OpenSchemaRegistryApplication start error
(#561)
new a5cbbb8 [Issue#554] removing hardcoded username and password (#560)
new 7053b60 Update .asf.yaml
new 2b24d17 [ISSUE #565] Update JarExtensionClassLoader.java (#566)
new 4945df6 [Issue #567] Optimize config file location (#568)
new d4c3ffd Update .asf.yaml
new 50b113e contributing guide edit import check style step (#573)
new 2b07c0e [WIP][ISSUE #482]Add protocol adaptor plugin (#572)
new ff2a84e update eventmesh-runtime.png
new 804e633 Add files via upload
new d41ee3c update README.md
new 7dfca9f readme.md
new 4b9220d upload wechat-official png
new d04d1c3 [Feature #564] Support CloudEvents protocols for pub/sub in
EventMesh-feature design (#574)
new 5ad08cb [ISSUE #563] SDK SUPPORT CLOUD EVENT (#575)
new d8de028 Add files via upload
new 2833ee1 [Feature #562] support cloudevents api in
eventmesh-connector-api module (#578)
new 7ea91e9 [ISSUE #580] Add checkstyle gradle plugin (#581)
new 1b574d6 update wechat-official qr code
new 0c2446e update mesh-helper qr code
new d156a35 Add files via upload
new 8882be6 Update .asf.yaml
new 7bb4747 connector support cloud event (#586)
new c9c4982 [Feature #562] Support CloudEvents for pub/sub in EventMesh
runtime (#587)
new b5a2ccf [Bug #590] Consumer subscription topic is invalid (#590)
(#592)
new 6c2a85a [Feature #562] Implement CloudEvents protocol adaptor (#595)
new 3fec9e1 [Feature #562] Implement EventMeshMessage protocol adaptor
(#597)
new 21f8d8b Remove some unused code (#591)
new 70a5ed9 fixed a wrong url in cn-doc (#585)
new d95af81 update Eventmeshmessage plugin (#599)
new c22f543 Update eventmesh-store-quickstart.md
new 25437e0 Add protocol producer in java sdk (#600)
new 0c6a6fe Change Tcp interface (#603)
new ccf584b update http push request and adaptor (#606)
new 704a71d update java sdk (#607)
new c9289fc Fix standalone connector interface, fix example (#608)
new 108871c fix compile error (#609)
new e6f254b Java sdk update (#610)
new dae9632 Add EventMeshTCPClient, this client wrap the sub/sub client
(#611)
new af05181 runtime update (#612)
new 4a0cc25 Java sdk update (#615)
new 2223ea9 eventmesh-admin-rocketmq submodule and createTopic REST API
(#530)
new e3ea3e1 Fix some small issue (#616)
new 064f5da eventmeshmessage protocol adaptor for tcp (#618)
new 70d3d08 remove openschema implementation from em project
new ca36bb0 eventmesh message protocol for http pub/sub with standalone
connector (#619)
new f6f93cb create topic command (#531)
new d1059ed Java sdk update cloudevents pub/sub (#620)
new 0fcb401 Change TCP Decoder and Encoder (#621)
new 08297fc cloudevents protocol tcp pub/sub for sdk (#622)
new 627bdcb cloudevents protocol tcp pub/sub for sdk (#623)
new 0a9348b cloudevents protocol http pub/sub for sdk (#625)
new f63e8e3 cloudevents protocol pub/sub for http sdk (#627)
new 66fc455 Add AbstractEventMeshTCPSubHandler (#624)
new 3414b7a cloudevents/eventmesh message protocol pub/sub for sdk in
rocketmq-connector (#628)
new 38f3d70 cloudevents/eventmesh message protocol pub/sub for sdk in
rocketmq-connector (#629)
new 4907670 Safely delete useless log4j dependencies
new 3447484 Safely delete outdated metrics dependencies
new 4c8ccb2 Sately delete useless collections4 dependency
new ace55a6 Safely delete useless commons dependencies
new 2aeb424 Reback to the collections4, but let it not in api dependency
new 005fc5a Could not remove text for Safe Ramdom implementation
new 766ee76 Fix build error
new 74e6d1f Revert "Safely delete outdated metrics dependencies"
new c357924 Remove doclint warnings
new 032e012 sync request/response for sdk in rocketmq-connector (#634)
new 6c3df9f Update .asf.yaml
new 82e7f84 Update .asf.yaml
new 6ff0efa fix conflicts and update the code (#635)
new 3225678 supply apache header
new dd97a27 Remove license name, add LICENSE file
new 9bc9bc0 resolve conflict
new b863410 remove some not used in binary license
new 32aedc6 set connector plugin to standalone
new 9e00688 Add license check shell
new fe56ef9 Add jdk11 and otherOS in github ci
new 5e73ec1 Add comments
new f1e00e4 resolve javadoc failed on jdk11
new 97f6cb4 Change skywalking uses repo to main
new d64d06a remove unused files
new bf0d1cf [ISSUE #630] RocketMQProducerImpl cannot load config
properties from classpath (#631)
new 4d8c7ad [Bug #646] Missing the rocketmq message properties during
protocol conversion (#647)
new 238db2c [MINOR] Hide ctx in callback function and update contributing
doc (#644)
new ce9ea34 [ISSUE #405] remove some unused code (#649)
new 00ef1d8 [MINOR] Add third-part dependencies licenses (#650)
new 5cdd39f [MINOR] supply the license and update the third party license
file name (#653)
new d33876b [ISSUE #340]Add http trace http point (#527)
new 2c84b58 Update quick start docs (#656)
new e9da007 [MINOR] Upgrade log4j version to 2.16.0 (#654)
new ffdb133 [MINOR] update the license and add the third party license
files (#657)
new 452921e [ISSUE #604]Improve the rebalance algorithm (#605)
new f3a0a96 [Feature #547] Create and upload 1.3.0-snapshot docker image
(#659)
new 085aeb6 [MINOR] Upgrade log4j version to 2.17.0 (#662)
new 40a4418 Delete gradle/wrapper directory
new e4055e2 update docs
new 5838d6f update Dockerfile and build.gradle
new 822a0cb update build.gradle
new 502d1a7 update Dockerfile path
new dbd1273 rebase 1.3.0-release to master branch
new 79295ac Merge pull request #666 from xwm1992/master
The 751 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 | 8 +-
.github/ISSUE_TEMPLATE/bug_report.yml | 91 ++++
.github/ISSUE_TEMPLATE/documentation_related.yml | 60 +++
.github/ISSUE_TEMPLATE/enhancement_request.yml | 70 +++
.github/ISSUE_TEMPLATE/feature_request.yml | 62 +++
.github/ISSUE_TEMPLATE/question.yml | 51 ++
.github/PULL_REQUEST_TEMPLATE.md | 47 +-
.github/workflows/ci.yml | 57 ++-
.github/workflows/greetings.yml | 2 +-
.gitignore | 10 +-
CONTRIBUTING.md | 63 ++-
CONTRIBUTING.zh-CN.md | 68 ++-
README.md | 115 +++--
README.zh-CN.md | 48 +-
build.gradle | 355 ++++++-------
.../{eventmesh-rocketmq => eventmesh}/Dockerfile | 2 +-
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} | 12 +-
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} | 72 +--
...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/eventmesh-stream-design.md | 110 ++++
docs/en/features/eventmesh-trace-design.md | 89 ++++
docs/en/features/https.md | 10 +-
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 | 245 ++-------
.../instructions/eventmesh-sdk-java-quickstart.md | 2 +-
docs/en/instructions/eventmesh-store-quickstart.md | 52 +-
docs/en/instructions/quickstart.md | 21 -
docs/en/{README.md => intro.md} | 0
docs/eventmesh.md | 37 --
docs/images/Wechat-helper.jpeg | Bin 0 -> 41112 bytes
docs/images/eventmesh-arch2.png | Bin 0 -> 103686 bytes
docs/images/eventmesh-runtime.png | Bin 1726098 -> 2101892
bytes
docs/images/eventmesh-runtime2.png | Bin 0 -> 2041725 bytes
docs/images/eventmesh-stream-arch.png | Bin 0 -> 109325 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
.../eventmesh-stream-component-interface.png | Bin 0 -> 12267 bytes
.../features/eventmesh-stream-component-routes.png | Bin 0 -> 8367 bytes
.../eventmesh-stream-event_driven-consumer.png | Bin 0 -> 10788 bytes
.../features/eventmesh-stream-sync-producer.png | Bin 0 -> 9538 bytes
docs/images/mesh-helper.jpg | Bin 0 -> 18197 bytes
docs/images/project-structure.png | Bin 63401 -> 141844 bytes
docs/images/wechat-official.jpg | Bin 0 -> 28051 bytes
docs/images/wechat-official.png | Bin 0 -> 16935 bytes
eventmesh-admin/README.md | 53 ++
.../build.gradle | 41 +-
.../eventmesh-admin-rocketmq}/build.gradle | 15 +-
.../eventmesh-admin-rocketmq/gradle.properties | 3 +-
.../admin/rocketmq/controller/AdminController.java | 47 +-
.../admin/rocketmq/handler/TopicsHandler.java | 108 ++++
.../admin/rocketmq/request/TopicCreateRequest.java | 50 +-
.../admin/rocketmq/response/TopicResponse.java | 59 +--
.../eventmesh/admin/rocketmq/util/JsonUtils.java | 72 +++
.../eventmesh/admin/rocketmq/util/NetUtils.java | 51 ++
.../admin/rocketmq/util/RequestMapping.java | 60 +++
.../admin/rocketmq/util/UrlMappingPattern.java | 109 ++++
.../gradle.properties | 4 +-
eventmesh-common/build.gradle | 60 ++-
.../org/apache/eventmesh/common/Constants.java | 30 +-
.../apache/eventmesh/common/EventMeshMessage.java | 70 +++
.../org/apache/eventmesh/common/LiteMessage.java | 131 -----
.../apache/eventmesh/common/ThreadPoolFactory.java | 30 +-
.../common/config/CommonConfiguration.java | 269 +++++-----
...rationWraper.java => ConfigurationWrapper.java} | 34 +-
.../common/{ => exception}/EventMeshException.java | 9 +-
.../eventmesh/common/exception/JsonException.java | 19 +-
.../common/loadbalance/LoadBalanceType.java | 3 +-
.../loadbalance/RandomLoadBalanceSelector.java | 2 +-
...r.java => WeightRandomLoadBalanceSelector.java} | 50 +-
.../WeightRoundRobinLoadBalanceSelector.java | 2 +-
...ptionType.java => ProtocolTransportObject.java} | 30 +-
.../common/protocol/SubscriptionItem.java | 8 +-
.../{command => protocol/http}/HttpCommand.java | 92 ++--
.../http/body/client/HeartbeatRequestBody.java | 36 +-
.../http/body/client/HeartbeatResponseBody.java | 6 +-
.../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 | 44 +-
.../body/message/ReplyMessageResponseBody.java | 6 +-
.../body/message/SendMessageBatchRequestBody.java | 49 +-
.../body/message/SendMessageBatchResponseBody.java | 6 +-
.../message/SendMessageBatchV2RequestBody.java | 4 +-
.../message/SendMessageBatchV2ResponseBody.java | 6 +-
.../http/body/message/SendMessageRequestBody.java | 51 +-
.../http/body/message/SendMessageResponseBody.java | 30 +-
.../common/protocol/http/common/ClientRetCode.java | 11 +-
.../common/protocol/http/common/ClientType.java | 4 +-
.../protocol/http/common/EventMeshRetCode.java | 4 +-
.../common/protocol/http/common/ProtocolKey.java | 42 +-
.../common/protocol/http/common/RequestCode.java | 24 +-
.../http/header/client/HeartbeatRequestHeader.java | 20 +-
.../http/header/client/RegRequestHeader.java | 10 +-
.../http/header/client/RegResponseHeader.java | 10 +-
.../http/header/client/SubscribeRequestHeader.java | 10 +-
.../http/header/client/UnRegRequestHeader.java | 20 +-
.../header/client/UnSubscribeRequestHeader.java | 10 +-
.../header/message/PushMessageRequestHeader.java | 6 +-
.../header/message/PushMessageResponseHeader.java | 30 +-
.../header/message/ReplyMessageRequestHeader.java | 66 ++-
.../header/message/ReplyMessageResponseHeader.java | 10 +-
.../message/SendMessageBatchRequestHeader.java | 66 ++-
.../message/SendMessageBatchResponseHeader.java | 10 +-
.../message/SendMessageBatchV2RequestHeader.java | 67 ++-
.../message/SendMessageBatchV2ResponseHeader.java | 10 +-
.../header/message/SendMessageRequestHeader.java | 67 ++-
.../header/message/SendMessageResponseHeader.java | 10 +-
.../eventmesh/common/protocol/tcp/Command.java | 124 ++---
.../common/protocol/tcp/EventMeshMessage.java | 55 +-
.../eventmesh/common/protocol/tcp/Header.java | 71 ++-
.../eventmesh/common/protocol/tcp/Package.java | 42 +-
.../eventmesh/common/protocol/tcp/UserAgent.java | 152 ++----
.../eventmesh/common/protocol/tcp/codec/Codec.java | 220 +++++---
.../common/{IPUtil.java => utils/IPUtils.java} | 4 +-
.../apache/eventmesh/common/utils/JsonUtils.java | 83 +++
.../RandomStringUtils.java} | 26 +-
.../{ThreadUtil.java => utils/ThreadUtils.java} | 28 +-
.../eventmesh/common/EventMeshMessageTest.java | 74 +++
.../common/config/CommonConfigurationTest.java | 43 +-
.../common/config/ConfigurationWrapperTest.java | 40 +-
.../WeightRandomLoadBalanceSelectorTest.java | 86 ++++
.../eventmesh/common/loadbalance/WeightTest.java | 43 +-
.../common/protocol/http/HttpCommandTest.java | 92 ++++
.../protocol/http/body/BaseResponseBodyTest.java | 44 +-
.../http/header/BaseRequestHeaderTest.java | 24 +-
.../http/header/BaseResponseHeaderTest.java | 23 +-
.../header/client/AbstractRequestHeaderTest.java | 38 ++
.../header/client/AbstractResponseHeaderTest.java | 40 ++
.../header/client/HeartbeatRequestHeaderTest.java | 18 +-
.../header/client/HeartbeatResponseHeaderTest.java | 23 +-
.../http/header/client/RegRequestHeaderTest.java | 17 +-
.../http/header/client/RegResponseHeaderTest.java | 16 +-
.../header/client/SubscribeRequestHeaderTest.java | 17 +-
.../header/client/SubscribeResponseHeaderTest.java | 17 +-
.../http/header/client/UnRegRequestHeaderTest.java | 18 +-
.../header/client/UnRegResponseHeaderTest.java | 16 +-
.../client/UnSubscribeRequestHeaderTest.java | 17 +-
.../client/UnSubscribeResponseHeaderTest.java} | 28 +-
.../message/PushMessageRequestHeaderTest.java | 59 +++
.../message/PushMessageResponseHeaderTest.java | 43 ++
.../message/ReplyMessageRequestHeaderTest.java | 61 +++
.../message/ReplyMessageResponseHeaderTest.java | 38 ++
.../common/protocol/tcp/codec/CodecTest.java | 48 +-
.../eventmesh/common/utils/IPUtilsTest.java} | 31 +-
.../eventmesh/common/utils/ThreadUtilsTest.java | 56 +++
.../src/test/resources/configuration.properties | 14 +-
.../build.gradle | 0
.../eventmesh-connector-api}/build.gradle | 20 +-
.../eventmesh-connector-api}/gradle.properties | 0
.../org/apache/eventmesh/api/AbstractContext.java | 0
.../apache/eventmesh/api/AsyncConsumeContext.java | 7 +-
.../org/apache/eventmesh/api/EventListener.java | 17 +-
.../org/apache/eventmesh/api/EventMeshAction.java | 1 +
.../api/EventMeshAsyncConsumeContext.java | 7 +-
.../java/org/apache/eventmesh/api/LifeCycle.java | 16 +-
.../apache/eventmesh/api/RequestReplyCallback.java | 10 +-
.../org/apache/eventmesh/api/SendCallback.java | 13 +-
.../java/org/apache/eventmesh/api/SendResult.java | 25 +-
.../api/connector/ConnectorResourceService.java | 35 +-
.../apache/eventmesh/api/consumer/Consumer.java | 25 +-
.../api/exception/ConnectorRuntimeException.java | 35 +-
.../api/exception/OnExceptionContext.java | 26 +-
.../api/factory/ConnectorPluginFactory.java | 54 ++
.../apache/eventmesh/api/producer/Producer.java | 32 +-
.../eventmesh-connector-rocketmq/build.gradle | 59 +++
.../gradle.properties | 0
.../rocketmq/MessagingAccessPointImpl.java | 90 ++++
.../connector/rocketmq/admin/command/Command.java | 52 ++
.../rocketmq/admin/command/CreateTopicCommand.java | 84 ++++
.../cloudevent/RocketMQMessageFactory.java | 79 +++
.../impl/RocketMQBinaryMessageReader.java | 69 +++
.../rocketmq/cloudevent/impl/RocketMQHeaders.java | 39 ++
.../cloudevent/impl/RocketMQMessageWriter.java | 105 ++++
.../connector/rocketmq/common/Constants.java | 0
.../rocketmq/common/EventMeshConstants.java | 24 +-
.../connector/rocketmq/config/ClientConfig.java | 3 +-
.../rocketmq/config/ClientConfiguration.java | 201 ++++++++
.../rocketmq/config/ConfigurationWrapper.java | 68 ++-
.../ConnectorResourceServiceRocketmqImpl.java | 15 +-
.../rocketmq/consumer/PushConsumerImpl.java | 316 ++++++++++++
.../rocketmq/consumer/RocketMQConsumerImpl.java | 110 ++++
.../connector/rocketmq/domain/ConsumeRequest.java | 0
.../connector/rocketmq/domain/NonStandardKeys.java | 0
.../rocketmq/domain/RocketMQConstants.java | 0
.../exception/RMQMessageFormatException.java | 26 +-
.../rocketmq/exception/RMQTimeoutException.java | 21 +-
.../patch/EventMeshConsumeConcurrentlyContext.java | 0
.../patch/EventMeshConsumeConcurrentlyStatus.java | 0
.../EventMeshMessageListenerConcurrently.java | 0
.../rocketmq/producer/AbstractProducer.java | 59 ++-
.../connector/rocketmq/producer/ProducerImpl.java | 209 ++++++++
.../rocketmq/producer/RocketMQProducerImpl.java | 124 +++++
.../connector/rocketmq/promise/FutureState.java | 0
.../connector/rocketmq/utils/BeanUtils.java | 0
.../connector/rocketmq/utils/CloudEventUtils.java | 152 ++++++
.../connector/rocketmq/utils/OMSUtil.java | 292 +++++++++++
.../ConsumeMessageConcurrentlyService.java | 17 +-
...ventmesh.api.connector.ConnectorResourceService | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
.../src/main/resources}/rocketmq-client.properties | 3 +
.../rocketmq/config/ConfigurationWrapperTest.java | 18 +-
.../producer/DefaultProducerImplTest.java | 63 +++
.../rocketmq/consumer/PushConsumerImplTest.java | 47 +-
.../apache/rocketmq/producer/ProducerImplTest.java | 83 ++-
.../rocketmq/promise/DefaultPromiseTest.java | 0
.../org/apache/rocketmq/utils/BeanUtilsTest.java | 0
.../org.apache.io.openmessaging.producer.Producer | 0
.../src/test/resources}/rocketmq-client.properties | 0
.../eventmesh-connector-standalone/build.gradle | 7 +-
.../gradle.properties | 4 +-
.../connector/standalone/broker/MessageQueue.java | 223 ++++++++
.../standalone/broker/StandaloneBroker.java | 143 ++++++
.../standalone/broker/model/MessageEntity.java | 72 +++
.../standalone/broker/model/TopicMetadata.java | 52 +-
.../broker/task/HistoryMessageClearTask.java | 69 +++
.../standalone/broker/task/SubScribeTask.java | 116 +++++
.../standalone/consumer/StandaloneConsumer.java | 119 +++++
.../consumer/StandaloneConsumerAdaptor.java | 172 +++++++
.../standalone/producer/StandaloneProducer.java | 142 ++++++
.../producer/StandaloneProducerAdaptor.java | 111 ++++
.../StandaloneConnectorResourceService.java | 17 +-
...ventmesh.api.connector.ConnectorResourceService | 2 +-
.../org.apache.eventmesh.api.consumer.Consumer | 2 +-
.../org.apache.eventmesh.api.producer.Producer | 2 +-
.../standalone/broker/StandaloneBrokerTest.java | 61 +++
.../gradle.properties | 4 +-
eventmesh-connector-rocketmq/build.gradle | 60 ---
.../rocketmq/MessagingAccessPointImpl.java | 93 ----
.../rocketmq/config/ClientConfiguration.java | 152 ------
.../rocketmq/consumer/PushConsumerImpl.java | 335 -------------
.../rocketmq/consumer/RocketMQConsumerImpl.java | 182 -------
.../connector/rocketmq/producer/ProducerImpl.java | 139 -----
.../rocketmq/producer/RocketMQProducerImpl.java | 155 ------
.../connector/rocketmq/promise/DefaultPromise.java | 227 ---------
.../connector/rocketmq/utils/OMSUtil.java | 286 -----------
...rg.apache.io.openmessaging.MessagingAccessPoint | 20 -
.../bin/http_pub.sh | 9 +-
.../bin/http_sub.sh | 9 +-
.../bin/tcp_pub.sh | 9 +-
.../bin/tcp_pub_broadcast.sh | 9 +-
.../bin/tcp_sub.sh | 9 +-
.../bin/tcp_sub_broadcast.sh | 9 +-
.../build.gradle | 33 +-
.../gradle.properties | 0
.../demo/pub/cloudevents/AsyncPublishInstance.java | 97 ++++
.../pub/eventmeshmessage/AsyncPublishInstance.java | 88 ++++
.../eventmeshmessage/AsyncSyncRequestInstance.java | 99 ++++
.../pub/eventmeshmessage/SyncRequestInstance.java | 88 ++++
.../http/demo/sub/SpringBootDemoApplication.java | 4 +-
.../http/demo/sub/controller/SubController.java | 71 +++
.../http/demo/sub/service/SubService.java | 90 ++--
.../tcp/common/EventMeshTestCaseTopicSet.java | 0
.../eventmesh/tcp/common/EventMeshTestUtils.java | 202 ++++++++
.../tcp/demo/pub/cloudevents}/AsyncPublish.java | 34 +-
.../tcp/demo/pub/cloudevents/SyncRequest.java | 70 +++
.../demo/pub/eventmeshmessage}/AsyncPublish.java | 39 +-
.../eventmeshmessage}/AsyncPublishBroadcast.java | 37 +-
.../tcp/demo/pub/eventmeshmessage/SyncRequest.java | 57 +++
.../tcp/demo/sub/cloudevents}/AsyncSubscribe.java | 57 ++-
.../tcp/demo/sub/cloudevents/SyncResponse.java | 62 ++-
.../demo/sub/eventmeshmessage}/AsyncSubscribe.java | 57 ++-
.../eventmeshmessage}/AsyncSubscribeBroadcast.java | 54 +-
.../demo/sub/eventmeshmessage}/SyncResponse.java | 59 ++-
.../main/java/org/apache/eventmesh/util/Utils.java | 41 +-
.../src/main/resources}/application.properties | 0
.../src/main/resources}/log4j2.xml | 0
.../src/main/resources}/server.env | 0
.../eventmesh-protocol-api}/build.gradle | 24 +-
.../eventmesh/protocol/api/ProtocolAdaptor.java | 70 +++
.../protocol/api/ProtocolPluginFactory.java | 59 +++
.../api/exception/ProtocolHandleException.java | 30 +-
.../eventmesh-protocol-cloudevents}/build.gradle | 12 +-
.../gradle.properties | 4 +-
.../cloudevents/CloudEventsProtocolAdaptor.java | 143 ++++++
.../cloudevents/CloudEventsProtocolConstant.java | 6 +-
.../http/SendMessageBatchProtocolResolver.java | 14 +-
.../http/SendMessageBatchV2ProtocolResolver.java | 111 ++++
.../http/SendMessageRequestProtocolResolver.java | 110 ++++
.../resolver/tcp/TcpMessageProtocolResolver.java | 88 ++++
...g.apache.eventmesh.protocol.api.ProtocolAdaptor | 2 +-
.../CloudEventsProtocolAdaptorTest.java | 31 +-
.../eventmesh-protocol-meshmessage}/build.gradle | 12 +-
.../gradle.properties | 4 +-
.../meshmessage/MeshMessageProtocolAdaptor.java | 122 +++++
.../meshmessage/MeshMessageProtocolConstant.java | 6 +-
.../http/SendMessageBatchProtocolResolver.java | 14 +-
.../http/SendMessageBatchV2ProtocolResolver.java | 122 +++++
.../http/SendMessageRequestProtocolResolver.java | 129 +++++
.../resolver/tcp/TcpMessageProtocolResolver.java | 107 ++++
...g.apache.eventmesh.protocol.api.ProtocolAdaptor | 2 +-
.../MeshMessageProtocolAdaptorTest.java | 33 +-
.../eventmesh-protocol-openmessage}/build.gradle | 14 +-
.../gradle.properties | 4 +-
.../openmessage/OpenMessageProtocolAdaptor.java | 56 +++
.../openmessage/OpenMessageProtocolConstant.java | 10 +-
...g.apache.eventmesh.protocol.api.ProtocolAdaptor | 2 +-
.../OpenMessageProtocolAdaptorTest.java | 32 +-
.../build.gradle | 2 +-
.../eventmesh-registry-api/build.gradle | 5 +-
.../eventmesh/api/exception/RegistryException.java | 16 +-
.../eventmesh/api/registry/RegistryService.java | 44 ++
.../api/registry/dto/EventMeshDataInfo.java | 63 +++
.../api/registry/dto/EventMeshRegisterInfo.java | 58 +++
.../api/registry/dto/EventMeshUnRegisterInfo.java | 31 +-
eventmesh-runtime/bin/start.sh | 23 +-
eventmesh-runtime/bin/stop.sh | 6 +-
eventmesh-runtime/build.gradle | 56 ++-
eventmesh-runtime/conf/eventmesh.properties | 43 +-
eventmesh-runtime/conf/log4j2.xml | 4 +
.../{rocketmq-client.properties => prometheus.yml} | 32 +-
.../java/org/apache/eventmesh/runtime/acl/Acl.java | 115 +++++
.../admin/controller/ClientManageController.java | 23 +-
.../handler/QueryRecommendEventMeshHandler.java | 91 ++++
.../admin/handler/RejectAllClientHandler.java | 13 +-
...ractHTTPServer.java => AbstractHTTPServer.java} | 398 +++++++++------
.../runtime/boot/AbstractRemotingServer.java | 8 +-
.../runtime/boot/EventMeshHTTPServer.java | 112 +++--
.../eventmesh/runtime/boot/EventMeshServer.java | 48 +-
.../eventmesh/runtime/boot/EventMeshStartup.java | 10 +-
.../eventmesh/runtime/boot/EventMeshTCPServer.java | 103 +++-
.../configuration/EventMeshHTTPConfiguration.java | 87 ++--
.../configuration/EventMeshTCPConfiguration.java | 163 ++----
.../runtime/connector/ConnectorResource.java | 41 ++
.../runtime/constants/EventMeshConstants.java | 54 +-
.../core/consumergroup/ConsumerGroupTopicConf.java | 2 +-
.../runtime/core/plugin/MQConsumerWrapper.java | 38 +-
.../runtime/core/plugin/MQProducerWrapper.java | 67 +--
.../core/protocol/http/async/AsyncContext.java | 13 +-
.../protocol/http/consumer/ConsumerManager.java | 124 +++--
.../protocol/http/consumer/EventMeshConsumer.java | 80 +--
.../protocol/http/consumer/HandleMsgContext.java | 25 +-
.../http/processor/AdminMetricsProcessor.java | 4 +-
.../http/processor/AdminShutdownProcessor.java | 19 +-
.../http/processor/BatchSendMessageProcessor.java | 234 +++++----
.../processor/BatchSendMessageV2Processor.java | 290 +++++++----
.../http/processor/HeartBeatProcessor.java | 105 ++--
.../http/processor/ReplyMessageProcessor.java | 160 +++---
.../http/processor/SendAsyncMessageProcessor.java | 194 ++++---
.../http/processor/SendSyncMessageProcessor.java | 359 +++++++------
.../http/processor/SubscribeProcessor.java | 169 +++++--
.../http/processor/UnSubscribeProcessor.java | 189 ++++---
.../core/protocol/http/processor/inf/Client.java | 48 +-
.../http/processor/inf/HttpRequestProcessor.java | 2 +-
.../protocol/http/producer/EventMeshProducer.java | 22 +-
.../protocol/http/producer/SendMessageContext.java | 32 +-
.../protocol/http/push/AsyncHTTPPushRequest.java | 170 ++++---
.../core/protocol/http/retry/HttpRetryer.java | 4 +-
.../protocol/tcp/client/EventMeshTcp2Client.java | 60 +--
.../tcp/client/EventMeshTcpMessageDispatcher.java | 65 ++-
.../tcp/client/group/ClientGroupWrapper.java | 457 ++++++++---------
.../client/group/ClientSessionGroupMapping.java | 163 ++++--
.../group/dispatch/DownstreamDispatchStrategy.java | 2 +-
.../rebalance/EventMeshRebalanceService.java | 72 +++
.../rebalance/EventMeshRebalanceStrategy.java | 6 +-
.../client/rebalance/EventmeshRebalanceImpl.java | 249 +++++++++
.../client/recommend/EventMeshRecommendImpl.java | 198 ++++++++
.../recommend/EventMeshRecommendStrategy.java} | 14 +-
.../core/protocol/tcp/client/session/Session.java | 12 +-
.../tcp/client/session/push/ClientAckContext.java | 29 +-
.../client/session/push/DownStreamMsgContext.java | 124 +++--
.../tcp/client/session/push/SessionPusher.java | 33 +-
.../session/push/retry/EventMeshTcpRetryer.java | 210 --------
.../client/session/retry/EventMeshTcpRetryer.java | 127 +++++
.../tcp/client/session/retry/RetryContext.java | 58 +++
.../tcp/client/session/send/SessionSender.java | 80 +--
.../client/session/send/UpStreamMsgContext.java | 131 ++++-
.../core/protocol/tcp/client/task/GoodbyeTask.java | 16 +-
.../protocol/tcp/client/task/HeartBeatTask.java | 9 +
.../core/protocol/tcp/client/task/HelloTask.java | 9 +
.../protocol/tcp/client/task/MessageAckTask.java | 6 +-
.../tcp/client/task/MessageTransferTask.java | 171 ++++---
.../protocol/tcp/client/task/RecommendTask.java | 101 ++++
.../protocol/tcp/client/task/SubscribeTask.java | 9 +
.../runtime/exporter/EventMeshExporter.java} | 12 +-
.../eventmesh/runtime/exporter/LogExporter.java | 83 +++
.../eventmesh/runtime/exporter/ZipkinExporter.java | 46 ++
.../runtime/metrics/http/HTTPMetricsServer.java | 23 +
.../runtime/metrics/http/SummaryMetrics.java | 6 +-
.../runtime/metrics/http/TcpSummaryMetrics.java | 2 +-
.../OpenTelemetryHTTPMetricsExporter.java | 309 ++++++++++++
.../OpenTelemetryPrometheusExporter.java | 60 +++
.../OpenTelemetryTCPMetricsExporter.java | 106 ++++
.../runtime/metrics/tcp/EventMeshTcpMonitor.java | 35 ++
.../eventmesh/runtime/registry/Registry.java | 66 +++
.../eventmesh/runtime/trace/AttributeKeys.java | 44 ++
.../runtime/trace/OpenTelemetryTraceFactory.java | 109 ++++
.../apache/eventmesh/runtime/trace/SpanKey.java | 52 ++
.../eventmesh/runtime/util/EventMeshUtil.java | 163 +++---
.../org/apache/eventmesh/runtime/util/OMSUtil.java | 68 ---
.../org/apache/eventmesh/runtime/util/Utils.java | 122 ++---
.../eventmesh/runtime/util/ValueComparator.java | 6 +-
.../runtime/client/api}/EventMeshClient.java | 10 +-
.../eventmesh/runtime/client/api}/PubClient.java | 4 +-
.../eventmesh/runtime/client/api}/SubClient.java | 10 +-
.../runtime}/client/common/ClientConstants.java | 2 +-
.../runtime}/client/common/ClientGlobal.java | 2 +-
.../eventmesh/runtime}/client/common/Codec.java | 2 +-
.../runtime}/client/common/MessageUtils.java | 26 +-
.../runtime}/client/common/RequestContext.java | 2 +-
.../eventmesh/runtime}/client/common/Server.java | 2 +-
.../runtime}/client/common/TCPClient.java | 6 +-
.../runtime}/client/common/UserAgentUtils.java | 2 +-
.../runtime}/client/hook/ReceiveMsgHook.java | 4 +-
.../runtime}/client/impl/EventMeshClientImpl.java | 34 +-
.../runtime}/client/impl/PubClientImpl.java | 26 +-
.../runtime}/client/impl/SubClientImpl.java | 35 +-
.../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 | 23 +-
.../eventmesh/runtime}/demo/AsyncSubClient.java | 21 +-
.../runtime}/demo/BroadCastPubClient.java | 14 +-
.../runtime}/demo/BroadCastSubClient.java | 21 +-
.../eventmesh/runtime}/demo/CCPubClient.java | 10 +-
.../eventmesh/runtime}/demo/CCSubClient.java | 20 +-
.../eventmesh/runtime}/demo/CClientDemo.java | 27 +-
.../eventmesh/runtime}/demo/SyncPubClient.java | 15 +-
.../eventmesh/runtime}/demo/SyncSubClient.java | 21 +-
.../eventmesh/runtime/util/EventMeshUtilTest.java} | 17 +-
eventmesh-runtime/src/test/resources/log4j2.xml | 6 +-
eventmesh-sdk-java/build.gradle | 49 +-
.../eventmesh/client/http/AbstractHttpClient.java | 98 ++++
.../eventmesh/client/http/AbstractLiteClient.java | 74 ---
.../eventmesh/client/http/RemotingServer.java | 424 ----------------
.../http/conf/EventMeshHttpClientConfig.java | 80 +++
.../client/http/conf/LiteClientConfig.java | 207 --------
.../http/consumer/EventMeshHttpConsumer.java | 192 +++++++
.../client/http/consumer/LiteConsumer.java | 304 -----------
.../http/consumer/context/LiteConsumeContext.java | 2 +-
.../consumer/listener/LiteMessageListener.java | 4 +-
.../client/http/{http => model}/RequestParam.java | 27 +-
.../client/http/producer/CloudEventProducer.java | 169 +++++++
.../http/producer/EventMeshHttpProducer.java | 89 ++++
.../http/producer/EventMeshMessageProducer.java | 154 ++++++
...allback.java => EventMeshProtocolProducer.java} | 18 +-
.../client/http/producer/LiteProducer.java | 247 ---------
.../client/http/producer/OpenMessageProducer.java | 133 +++++
.../eventmesh/client/http/producer/RRCallback.java | 15 +-
.../producer/RRCallbackResponseHandlerAdapter.java | 90 ++--
.../client/http/ssl/MyX509TrustManager.java | 16 +-
.../client/http/util/HttpLoadBalanceUtils.java | 88 ++--
.../{http/HttpUtil.java => util/HttpUtils.java} | 87 ++--
.../eventmesh/client/tcp/EventMeshClient.java | 55 --
.../eventmesh/client/tcp/EventMeshTCPClient.java | 62 +++
.../client/tcp/EventMeshTCPClientFactory.java | 61 +++
.../client/tcp/EventMeshTCPPubClient.java | 53 ++
...leSubClient.java => EventMeshTCPSubClient.java} | 37 +-
.../client/tcp/common/EventMeshCommon.java | 94 +---
.../tcp/common/EventMeshThreadFactoryImpl.java | 49 --
.../eventmesh/client/tcp/common/MessageUtils.java | 121 +++--
.../{ReceiveMsgHook.java => PropertyConst.java} | 11 +-
.../client/tcp/common/ReceiveMsgHook.java | 21 +-
.../eventmesh/client/tcp/common/TcpClient.java | 120 +++--
.../client/tcp/conf/EventMeshTCPClientConfig.java | 17 +-
.../tcp/impl/AbstractEventMeshTCPPubHandler.java | 73 +++
.../tcp/impl/AbstractEventMeshTCPSubHandler.java | 81 +++
.../client/tcp/impl/DefaultEventMeshClient.java | 130 -----
.../client/tcp/impl/SimplePubClientImpl.java | 197 --------
.../client/tcp/impl/SimpleSubClientImpl.java | 187 -------
.../tcp/impl/cloudevent/CloudEventTCPClient.java | 113 +++++
.../impl/cloudevent/CloudEventTCPPubClient.java | 172 +++++++
.../impl/cloudevent/CloudEventTCPSubClient.java | 174 +++++++
.../EventMeshMessageTCPClient.java | 112 +++++
.../EventMeshMessageTCPPubClient.java | 171 +++++++
.../EventMeshMessageTCPSubClient.java | 160 ++++++
.../tcp/impl/openmessage/OpenMessageTCPClient.java | 114 +++++
.../impl/openmessage/OpenMessageTCPPubClient.java | 78 +++
.../impl/openmessage/OpenMessageTCPSubClient.java | 74 +++
.../client/http/demo/AsyncPublishInstance.java | 86 ++--
.../client/http/demo/AsyncSyncRequestInstance.java | 61 +--
.../client/http/demo/SyncRequestInstance.java | 58 +--
.../client/http/util/HttpLoadBalanceUtilsTest.java | 29 +-
.../client/tcp/common/EventMeshTestUtils.java | 67 ++-
.../client/tcp/demo/AsyncPublishBroadcast.java | 53 --
.../eventmesh/client/tcp/demo/AsyncSubscribe.java | 69 ---
.../client/tcp/demo/AsyncSubscribeBroadcast.java | 69 ---
.../eventmesh/client/tcp/demo/SyncRequest.java | 53 --
.../eventmesh/client/tcp/demo/SyncResponse.java | 69 ---
.../tcp/impl/EventMeshTCPClientFactoryTest.java | 54 ++
.../build.gradle | 0
.../eventmesh-security-acl/build.gradle | 5 +-
.../eventmesh-security-acl/gradle.properties | 4 +-
.../apache/eventmesh/acl/impl/AclServiceImpl.java | 60 +++
.../org.apache.eventmesh.api.acl.AclService | 2 +-
.../eventmesh-security-api/build.gradle | 5 +-
.../apache/eventmesh/api/acl/AclPropertyKeys.java | 10 +-
.../org/apache/eventmesh/api/acl/AclService.java | 29 +-
.../eventmesh/api/exception/AclException.java | 15 +-
.../build.gradle | 10 +-
.../gradle.properties | 4 +-
.../eventmesh/spi/EventMeshExtensionFactory.java | 119 +++++
.../eventmesh/spi/EventMeshExtensionType.java | 34 +-
.../org/apache/eventmesh/spi/EventMeshSPI.java | 41 +-
.../apache/eventmesh/spi/ExtensionException.java | 17 +-
.../spi/loader/EventMeshUrlClassLoader.java | 56 +++
.../eventmesh/spi/loader/ExtensionClassLoader.java | 26 +-
.../spi/loader/JarExtensionClassLoader.java | 151 ++++++
.../spi/loader/MetaInfExtensionClassLoader.java | 92 ++++
.../spi/EventMeshExtensionFactoryTest.java | 40 ++
.../eventmesh/spi/example/PrototypeExtension.java | 15 +-
.../eventmesh/spi/example/SingletonExtension.java | 15 +-
.../spi/example/TestPrototypeExtension.java | 13 +-
.../spi/example/TestSingletonExtension.java | 13 +-
...he.eventmesh.spi.example.TestPrototypeExtension | 3 +-
...he.eventmesh.spi.example.TestSingletonExtension | 3 +-
eventmesh-starter/build.gradle | 4 +-
eventmesh-test/build.gradle | 91 ----
.../eventmesh/http/demo/AsyncPublishInstance.java | 94 ----
.../http/demo/AsyncSyncRequestInstance.java | 99 ----
.../eventmesh/http/demo/SyncRequestInstance.java | 83 ---
.../http/demo/sub/controller/SubController.java | 51 --
.../eventmesh/tcp/common/EventMeshTestUtils.java | 154 ------
.../org/apache/eventmesh/tcp/demo/SyncRequest.java | 55 --
gradle.properties | 3 +
gradle/wrapper/gradle-wrapper.jar | Bin 58910 -> 0 bytes
gradle/wrapper/gradle-wrapper.properties | 21 -
gradlew | 30 +-
gradlew.bat | 46 +-
install.sh | 4 +-
settings.gradle | 22 +-
style/checkStyle.xml | 349 +++++++++++++
style/codeStyle.xml | 143 ------
style/copyright/Apache.xml | 24 -
.../third-party-dependencies/check-dependencies.sh | 36 ++
.../known-dependencies.txt | 79 +++
tools/third-party-licenses/LICENSE | 336 +++++++++++++
.../licenses/LICENSE-assertj-core.txt | 202 ++++++++
.../licenses/LICENSE-checker-qual.txt | 413 +++++++++++++++
.../licenses/LICENSE-cloudevents-api.txt | 203 ++++++++
.../licenses/LICENSE-cloudevents-core.txt | 203 ++++++++
.../licenses/LICENSE-cloudevents-json-jackson.txt | 203 ++++++++
.../licenses/LICENSE-commons-beanutils.txt | 202 ++++++++
.../licenses/LICENSE-commons-cli.txt | 202 ++++++++
.../licenses/LICENSE-commons-codec.txt | 202 ++++++++
.../licenses/LICENSE-commons-collections.txt | 202 ++++++++
.../licenses/LICENSE-commons-collections4.txt | 202 ++++++++
.../licenses/LICENSE-commons-digester.txt | 202 ++++++++
.../licenses/LICENSE-commons-lang3.txt | 202 ++++++++
.../licenses/LICENSE-commons-logging.txt | 202 ++++++++
.../licenses/LICENSE-commons-text.txt | 202 ++++++++
.../licenses/LICENSE-commons-validator.txt | 202 ++++++++
.../licenses/LICENSE-disruptor.txt | 201 ++++++++
.../licenses/LICENSE-dledger.txt | 203 ++++++++
.../licenses/LICENSE-error_prone_annotations.txt | 202 ++++++++
.../licenses/LICENSE-failureaccess.txt | 202 ++++++++
.../licenses/LICENSE-fastjson.txt | 201 ++++++++
.../licenses/LICENSE-guava.txt | 202 ++++++++
.../licenses/LICENSE-hamcrest-core.txt | 27 +
.../licenses/LICENSE-httpclient.txt | 558 +++++++++++++++++++++
.../licenses/LICENSE-httpcore.txt | 177 +++++++
.../licenses/LICENSE-j2objc-annotations.txt | 232 +++++++++
.../licenses/LICENSE-jackson-annotations.txt | 202 ++++++++
.../licenses/LICENSE-jackson-core.txt | 202 ++++++++
.../licenses/LICENSE-jackson-databind.txt | 202 ++++++++
.../licenses/LICENSE-javassist.txt | 141 ++++++
.../licenses/LICENSE-jcommander.txt | 202 ++++++++
.../third-party-licenses/licenses/LICENSE-jna.txt | 26 +
.../licenses/LICENSE-jsr305.txt | 28 ++
.../licenses/LICENSE-junit.txt | 213 ++++++++
.../licenses/LICENSE-listenablefuture.txt | 202 ++++++++
.../licenses/LICENSE-log4j-api.txt | 202 ++++++++
.../licenses/LICENSE-log4j-core.txt | 202 ++++++++
.../licenses/LICENSE-log4j-slf4j-impl.txt | 202 ++++++++
.../licenses/LICENSE-logback-core.txt | 14 +
.../licenses/LICENSE-metrics-annotation.txt | 202 ++++++++
.../licenses/LICENSE-metrics-core.txt | 202 ++++++++
.../licenses/LICENSE-metrics-healthchecks.txt | 202 ++++++++
.../licenses/LICENSE-metrics-json.txt | 202 ++++++++
.../licenses/LICENSE-netty-all.txt | 202 ++++++++
.../LICENSE-netty-tcnative-boringssl-static.txt | 202 ++++++++
.../licenses/LICENSE-okhttp.txt | 202 ++++++++
.../third-party-licenses/licenses/LICENSE-okio.txt | 202 ++++++++
.../licenses/LICENSE-openmessaging-api.txt | 202 ++++++++
.../licenses/LICENSE-opentelemetry-api-metrics.txt | 202 ++++++++
.../licenses/LICENSE-opentelemetry-api.txt | 202 ++++++++
.../licenses/LICENSE-opentelemetry-context.txt | 202 ++++++++
.../LICENSE-opentelemetry-exporter-prometheus.txt | 202 ++++++++
.../LICENSE-opentelemetry-exporter-zipkin.txt | 202 ++++++++
.../licenses/LICENSE-opentelemetry-sdk-common.txt | 202 ++++++++
.../licenses/LICENSE-opentelemetry-sdk-metrics.txt | 202 ++++++++
.../licenses/LICENSE-opentelemetry-sdk-trace.txt | 202 ++++++++
.../licenses/LICENSE-opentelemetry-sdk.txt | 202 ++++++++
.../licenses/LICENSE-opentelemetry-semconv.txt | 202 ++++++++
.../licenses/LICENSE-rocketmq-acl.txt | 201 ++++++++
.../licenses/LICENSE-rocketmq-broker.txt | 201 ++++++++
.../licenses/LICENSE-rocketmq-client.txt | 201 ++++++++
.../licenses/LICENSE-rocketmq-common.txt | 201 ++++++++
.../licenses/LICENSE-rocketmq-filter.txt | 201 ++++++++
.../licenses/LICENSE-rocketmq-logging.txt | 201 ++++++++
.../licenses/LICENSE-rocketmq-namesrv.txt | 201 ++++++++
.../licenses/LICENSE-rocketmq-remoting.txt | 201 ++++++++
.../licenses/LICENSE-rocketmq-srvutil.txt | 201 ++++++++
.../licenses/LICENSE-rocketmq-store.txt | 201 ++++++++
.../licenses/LICENSE-rocketmq-test.txt | 201 ++++++++
.../licenses/LICENSE-rocketmq-tools.txt | 201 ++++++++
.../licenses/LICENSE-simpleclient.txt | 201 ++++++++
.../licenses/LICENSE-simpleclient_common.txt | 201 ++++++++
.../licenses/LICENSE-simpleclient_httpserver.txt | 201 ++++++++
.../licenses/LICENSE-slf4j-api.txt | 21 +
.../licenses/LICENSE-snakeyam.txt | 202 ++++++++
.../licenses/LICENSE-system-rules.txt | 213 ++++++++
.../licenses/LICENSE-truth.txt | 202 ++++++++
.../licenses/LICENSE-zipkin-reporter.txt | 201 ++++++++
.../licenses/LICENSE-zipkin-sender-okhttp3.txt | 201 ++++++++
.../licenses/LICENSE-zipkin.txt | 216 ++++++++
657 files changed, 37139 insertions(+), 11129 deletions(-)
create mode 100644 .github/ISSUE_TEMPLATE/bug_report.yml
create mode 100644 .github/ISSUE_TEMPLATE/documentation_related.yml
create mode 100644 .github/ISSUE_TEMPLATE/enhancement_request.yml
create mode 100644 .github/ISSUE_TEMPLATE/feature_request.yml
create mode 100644 .github/ISSUE_TEMPLATE/question.yml
rename docker/{eventmesh-rocketmq => eventmesh}/Dockerfile (94%)
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} (62%)
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} (75%)
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/eventmesh-stream-design.md
create mode 100644 docs/en/features/eventmesh-trace-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/Wechat-helper.jpeg
create mode 100644 docs/images/eventmesh-arch2.png
create mode 100644 docs/images/eventmesh-runtime2.png
create mode 100644 docs/images/eventmesh-stream-arch.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/features/eventmesh-stream-component-interface.png
create mode 100644 docs/images/features/eventmesh-stream-component-routes.png
create mode 100644
docs/images/features/eventmesh-stream-event_driven-consumer.png
create mode 100644 docs/images/features/eventmesh-stream-sync-producer.png
create mode 100644 docs/images/mesh-helper.jpg
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/src/main/java/org/apache/eventmesh/common/protocol/SubcriptionType.java
=> eventmesh-admin/build.gradle (59%)
copy {eventmesh-connector-api =>
eventmesh-admin/eventmesh-admin-rocketmq}/build.gradle (63%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.consumer.MeshMQPushConsumer
=> eventmesh-admin/eventmesh-admin-rocketmq/gradle.properties (91%)
copy
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/FutureState.java
=>
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/controller/AdminController.java
(56%)
create mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/handler/TopicsHandler.java
copy
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/FutureState.java
=>
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/request/TopicCreateRequest.java
(53%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubscriptionItem.java
=>
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/response/TopicResponse.java
(52%)
create mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/JsonUtils.java
create mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/NetUtils.java
create mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/RequestMapping.java
create mode 100644
eventmesh-admin/eventmesh-admin-rocketmq/src/main/java/org/apache/eventmesh/admin/rocketmq/util/UrlMappingPattern.java
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.consumer.MeshMQPushConsumer
=> eventmesh-admin/gradle.properties (91%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/EventMeshMessage.java
delete mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/LiteMessage.java
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/config/{ConfigurationWraper.java
=> ConfigurationWrapper.java} (71%)
rename eventmesh-common/src/main/java/org/apache/eventmesh/common/{ =>
exception}/EventMeshException.java (87%)
copy eventmesh-runtime/src/test/java/client/hook/ReceiveMsgHook.java =>
eventmesh-common/src/main/java/org/apache/eventmesh/common/exception/JsonException.java
(69%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/loadbalance/{WeightRoundRobinLoadBalanceSelector.java
=> WeightRandomLoadBalanceSelector.java} (51%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/{SubcriptionType.java
=> ProtocolTransportObject.java} (71%)
rename eventmesh-common/src/main/java/org/apache/eventmesh/common/{command =>
protocol/http}/HttpCommand.java (68%)
rename eventmesh-common/src/main/java/org/apache/eventmesh/common/{IPUtil.java
=> utils/IPUtils.java} (98%)
create mode 100644
eventmesh-common/src/main/java/org/apache/eventmesh/common/utils/JsonUtils.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/{protocol/SubcriptionType.java
=> utils/RandomStringUtils.java} (67%)
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/{ThreadUtil.java =>
utils/ThreadUtils.java} (69%)
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/EventMeshMessageTest.java
copy
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/FutureState.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/config/CommonConfigurationTest.java
(52%)
copy
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/FutureState.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/config/ConfigurationWrapperTest.java
(57%)
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/loadbalance/WeightRandomLoadBalanceSelectorTest.java
copy
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/FutureState.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/loadbalance/WeightTest.java
(54%)
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/HttpCommandTest.java
copy
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/FutureState.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/body/BaseResponseBodyTest.java
(50%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/BaseRequestHeaderTest.java
(54%)
copy eventmesh-runtime/src/test/java/demo/CCPubClient.java =>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/BaseResponseHeaderTest.java
(60%)
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/AbstractRequestHeaderTest.java
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/AbstractResponseHeaderTest.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatRequestHeaderTest.java
(69%)
copy eventmesh-runtime/src/test/java/demo/CCPubClient.java =>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/HeartbeatResponseHeaderTest.java
(61%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/RegRequestHeaderTest.java
(70%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/RegResponseHeaderTest.java
(69%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/SubscribeRequestHeaderTest.java
(69%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/SubscribeResponseHeaderTest.java
(68%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegRequestHeaderTest.java
(70%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/UnRegResponseHeaderTest.java
(68%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/client/UnSubscribeRequestHeaderTest.java
(69%)
copy
eventmesh-common/src/{main/java/org/apache/eventmesh/common/protocol/SubcriptionType.java
=>
test/java/org/apache/eventmesh/common/protocol/http/header/client/UnSubscribeResponseHeaderTest.java}
(67%)
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/message/PushMessageRequestHeaderTest.java
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/message/PushMessageResponseHeaderTest.java
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/message/ReplyMessageRequestHeaderTest.java
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/http/header/message/ReplyMessageResponseHeaderTest.java
rename
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/SimplePubClient.java
=>
eventmesh-common/src/test/java/org/apache/eventmesh/common/protocol/tcp/codec/CodecTest.java
(52%)
copy
eventmesh-common/src/{main/java/org/apache/eventmesh/common/protocol/SubcriptionType.java
=> test/java/org/apache/eventmesh/common/utils/IPUtilsTest.java} (60%)
create mode 100644
eventmesh-common/src/test/java/org/apache/eventmesh/common/utils/ThreadUtilsTest.java
copy eventmesh-runtime/conf/rocketmq-client.properties =>
eventmesh-common/src/test/resources/configuration.properties (68%)
copy {eventmesh-common => eventmesh-connector-plugin}/build.gradle (100%)
copy {eventmesh-connector-api =>
eventmesh-connector-plugin/eventmesh-connector-api}/build.gradle (60%)
rename {eventmesh-connector-api =>
eventmesh-connector-plugin/eventmesh-connector-api}/gradle.properties (100%)
copy {eventmesh-connector-api =>
eventmesh-connector-plugin/eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/AbstractContext.java
(100%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AsyncConsumeContext.java
(84%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventListener.java
(67%)
copy {eventmesh-connector-api =>
eventmesh-connector-plugin/eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
(99%)
copy {eventmesh-connector-api =>
eventmesh-connector-plugin/eventmesh-connector-api}/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
(85%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/LifeCycle.java
(69%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RequestReplyCallback.java
(84%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendCallback.java
(69%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/SendResult.java
(62%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubcriptionType.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/ConnectorResourceService.java
(59%)
rename
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/MeshMQPushConsumer.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/consumer/Consumer.java
(65%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubcriptionType.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/ConnectorRuntimeException.java
(65%)
copy eventmesh-runtime/src/test/java/client/common/ClientConstants.java =>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/exception/OnExceptionContext.java
(67%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/factory/ConnectorPluginFactory.java
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/MeshMQProducer.java
=>
eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/Producer.java
(51%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/build.gradle
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/gradle.properties
(100%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/MessagingAccessPointImpl.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/command/Command.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/admin/command/CreateTopicCommand.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/RocketMQMessageFactory.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQBinaryMessageReader.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQHeaders.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/cloudevent/impl/RocketMQMessageWriter.java
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/eventmesh/connector/rocketmq/common/Constants.java
(100%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/eventmesh/connector/rocketmq/common/EventMeshConstants.java
(82%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfig.java
(98%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
rename
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ConfigurationWraper.java
=>
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ConfigurationWrapper.java
(50%)
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%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/ConsumeRequest.java
(100%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/NonStandardKeys.java
(100%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/eventmesh/connector/rocketmq/domain/RocketMQConstants.java
(100%)
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubcriptionType.java
=>
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/exception/RMQMessageFormatException.java
(63%)
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/exception/RMQTimeoutException.java
(67%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyContext.java
(100%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshConsumeConcurrentlyStatus.java
(100%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/eventmesh/connector/rocketmq/patch/EventMeshMessageListenerConcurrently.java
(100%)
rename
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/AbstractOMSProducer.java
=>
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/AbstractProducer.java
(69%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/FutureState.java
(100%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/BeanUtils.java
(100%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/CloudEventUtils.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/OMSUtil.java
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
(97%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
(89%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(90%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(90%)
copy {eventmesh-runtime/conf =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/main/resources}/rocketmq-client.properties
(86%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=>
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/connector/rocketmq/config/ConfigurationWrapperTest.java
(70%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/java/org/apache/eventmesh/producer/DefaultProducerImplTest.java
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/test/java/org/apache/rocketmq/consumer/PushConsumerImplTest.java
(69%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/test/java/org/apache/rocketmq/producer/ProducerImplTest.java
(62%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/test/java/org/apache/rocketmq/promise/DefaultPromiseTest.java
(100%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/test/java/org/apache/rocketmq/utils/BeanUtilsTest.java
(100%)
rename {eventmesh-connector-rocketmq =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq}/src/test/resources/META-INF/services/org.apache.io.openmessaging.producer.Producer
(100%)
copy {eventmesh-runtime/conf =>
eventmesh-connector-plugin/eventmesh-connector-rocketmq/src/test/resources}/rocketmq-client.properties
(100%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
=> eventmesh-connector-plugin/eventmesh-connector-standalone/build.gradle (84%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=> eventmesh-connector-plugin/eventmesh-connector-standalone/gradle.properties
(91%)
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-common/src/main/java/org/apache/eventmesh/common/protocol/tcp/Package.java
=>
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/broker/model/TopicMetadata.java
(52%)
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/StandaloneConsumerAdaptor.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducer.java
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/java/org/apache/eventmesh/connector/standalone/producer/StandaloneProducerAdaptor.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-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.connector.ConnectorResourceService
(89%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.consumer.Consumer
(89%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-connector-plugin/eventmesh-connector-standalone/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.producer.Producer
(89%)
create mode 100644
eventmesh-connector-plugin/eventmesh-connector-standalone/src/test/java/org/apache/eventmesh/connector/standalone/broker/StandaloneBrokerTest.java
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.consumer.MeshMQPushConsumer
=> eventmesh-connector-plugin/gradle.properties (91%)
delete mode 100644 eventmesh-connector-rocketmq/build.gradle
delete mode 100644
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/MessagingAccessPointImpl.java
delete mode 100644
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/config/ClientConfiguration.java
delete mode 100644
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/PushConsumerImpl.java
delete mode 100644
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/consumer/RocketMQConsumerImpl.java
delete mode 100644
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/ProducerImpl.java
delete mode 100644
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/producer/RocketMQProducerImpl.java
delete mode 100644
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/promise/DefaultPromise.java
delete mode 100644
eventmesh-connector-rocketmq/src/main/java/org/apache/eventmesh/connector/rocketmq/utils/OMSUtil.java
delete mode 100644
eventmesh-connector-rocketmq/src/test/resources/META-INF/services/org.apache.io.openmessaging.MessagingAccessPoint
rename {eventmesh-test => eventmesh-examples}/bin/http_pub.sh (92%)
rename {eventmesh-test => eventmesh-examples}/bin/http_sub.sh (93%)
rename {eventmesh-test => eventmesh-examples}/bin/tcp_pub.sh (92%)
rename {eventmesh-test => eventmesh-examples}/bin/tcp_pub_broadcast.sh (93%)
rename {eventmesh-test => eventmesh-examples}/bin/tcp_sub.sh (92%)
rename {eventmesh-test => eventmesh-examples}/bin/tcp_sub_broadcast.sh (93%)
copy {eventmesh-runtime => eventmesh-examples}/build.gradle (50%)
rename {eventmesh-test => eventmesh-examples}/gradle.properties (100%)
create mode 100644
eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/cloudevents/AsyncPublishInstance.java
create mode 100644
eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/AsyncPublishInstance.java
create mode 100644
eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/AsyncSyncRequestInstance.java
create mode 100644
eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/pub/eventmeshmessage/SyncRequestInstance.java
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/http/demo/sub/SpringBootDemoApplication.java
(87%)
create mode 100644
eventmesh-examples/src/main/java/org/apache/eventmesh/http/demo/sub/controller/SubController.java
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/http/demo/sub/service/SubService.java
(57%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestCaseTopicSet.java
(100%)
create mode 100644
eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java
rename {eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo =>
eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents}/AsyncPublish.java
(69%)
create mode 100644
eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/cloudevents/SyncRequest.java
rename {eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo
=>
eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage}/AsyncPublish.java
(54%)
rename {eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo =>
eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage}/AsyncPublishBroadcast.java
(64%)
create mode 100644
eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/pub/eventmeshmessage/SyncRequest.java
copy {eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo =>
eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents}/AsyncSubscribe.java
(53%)
copy
eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo/AsyncSubscribeBroadcast.java
=>
eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/cloudevents/SyncResponse.java
(52%)
rename {eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo =>
eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage}/AsyncSubscribe.java
(55%)
rename {eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo =>
eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage}/AsyncSubscribeBroadcast.java
(61%)
rename {eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo =>
eventmesh-examples/src/main/java/org/apache/eventmesh/tcp/demo/sub/eventmeshmessage}/SyncResponse.java
(50%)
rename {eventmesh-test =>
eventmesh-examples}/src/main/java/org/apache/eventmesh/util/Utils.java (74%)
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-connector-api =>
eventmesh-protocol-plugin/eventmesh-protocol-api}/build.gradle (59%)
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-common/src/main/java/org/apache/eventmesh/common/protocol/SubcriptionType.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-api/src/main/java/org/apache/eventmesh/protocol/api/exception/ProtocolHandleException.java
(68%)
copy {eventmesh-connector-api =>
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents}/build.gradle (74%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=> eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/gradle.properties
(91%)
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/CloudEventsProtocolAdaptor.java
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/CloudEventsProtocolConstant.java
(83%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/http/SendMessageBatchProtocolResolver.java
(69%)
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/http/SendMessageBatchV2ProtocolResolver.java
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/http/SendMessageRequestProtocolResolver.java
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/main/java/org/apache/eventmesh/protocol/cloudevents/resolver/tcp/TcpMessageProtocolResolver.java
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/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-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-cloudevents/src/test/java/org/apache/eventmesh/protocol/cloudevents/CloudEventsProtocolAdaptorTest.java
(50%)
copy {eventmesh-connector-api =>
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage}/build.gradle (72%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=> eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/gradle.properties
(91%)
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/MeshMessageProtocolAdaptor.java
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/MeshMessageProtocolConstant.java
(82%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/http/SendMessageBatchProtocolResolver.java
(69%)
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/http/SendMessageBatchV2ProtocolResolver.java
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/http/SendMessageRequestProtocolResolver.java
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/java/org/apache/eventmesh/protocol/meshmessage/resolver/tcp/TcpMessageProtocolResolver.java
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.protocol.api.ProtocolAdaptor
(90%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-meshmessage/src/test/java/org/apache/eventmesh/protocol/meshmessage/MeshMessageProtocolAdaptorTest.java
(51%)
copy {eventmesh-connector-api =>
eventmesh-protocol-plugin/eventmesh-protocol-openmessage}/build.gradle (65%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=> eventmesh-protocol-plugin/eventmesh-protocol-openmessage/gradle.properties
(91%)
create mode 100644
eventmesh-protocol-plugin/eventmesh-protocol-openmessage/src/main/java/org/apache/eventmesh/protocol/openmessage/OpenMessageProtocolAdaptor.java
rename
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAction.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-openmessage/src/main/java/org/apache/eventmesh/protocol/openmessage/OpenMessageProtocolConstant.java
(83%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/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%)
rename
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/EventMeshAsyncConsumeContext.java
=>
eventmesh-protocol-plugin/eventmesh-protocol-openmessage/src/test/java/org/apache/eventmesh/protocol/openmessage/OpenMessageProtocolAdaptorTest.java
(50%)
copy {eventmesh-common => eventmesh-registry-plugin}/build.gradle (99%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
=> eventmesh-registry-plugin/eventmesh-registry-api/build.gradle (89%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.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-common/src/main/java/org/apache/eventmesh/common/protocol/SubcriptionType.java
=>
eventmesh-registry-plugin/eventmesh-registry-api/src/main/java/org/apache/eventmesh/api/registry/dto/EventMeshUnRegisterInfo.java
(60%)
rename eventmesh-runtime/conf/{rocketmq-client.properties => prometheus.yml}
(56%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/acl/Acl.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/admin/handler/QueryRecommendEventMeshHandler.java
rename
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/boot/{AbrstractHTTPServer.java
=> AbstractHTTPServer.java} (53%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/connector/ConnectorResource.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/rebalance/EventMeshRebalanceService.java
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
=>
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/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} (65%)
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
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/session/retry/RetryContext.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/task/RecommendTask.java
copy eventmesh-runtime/src/{test/java/client/hook/ReceiveMsgHook.java =>
main/java/org/apache/eventmesh/runtime/exporter/EventMeshExporter.java} (70%)
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/exporter/LogExporter.java
create mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/exporter/ZipkinExporter.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/main/java/org/apache/eventmesh/runtime/trace/AttributeKeys.java
create 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/trace/SpanKey.java
delete mode 100644
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/OMSUtil.java
rename eventmesh-runtime/src/test/java/{client =>
org/apache/eventmesh/runtime/client/api}/EventMeshClient.java (84%)
rename eventmesh-runtime/src/test/java/{client =>
org/apache/eventmesh/runtime/client/api}/PubClient.java (93%)
rename eventmesh-runtime/src/test/java/{client =>
org/apache/eventmesh/runtime/client/api}/SubClient.java (82%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/common/ClientConstants.java (95%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/common/ClientGlobal.java (97%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/common/Codec.java (99%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/common/MessageUtils.java (92%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/common/RequestContext.java (97%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/common/Server.java (97%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/common/TCPClient.java (94%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/common/UserAgentUtils.java (98%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/hook/ReceiveMsgHook.java (89%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/impl/EventMeshClientImpl.java (85%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/impl/PubClientImpl.java (90%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/client/impl/SubClientImpl.java (90%)
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
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/demo/AsyncPubClient.java (68%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/demo/AsyncSubClient.java (72%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/demo/BroadCastPubClient.java (75%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/demo/BroadCastSubClient.java (73%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/demo/CCPubClient.java (79%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/demo/CCSubClient.java (73%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/demo/CClientDemo.java (76%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/demo/SyncPubClient.java (73%)
rename eventmesh-runtime/src/test/java/{ =>
org/apache/eventmesh/runtime}/demo/SyncSubClient.java (71%)
copy
eventmesh-runtime/src/{main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=> test/java/org/apache/eventmesh/runtime/util/EventMeshUtilTest.java} (71%)
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/AbstractHttpClient.java
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/AbstractLiteClient.java
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/RemotingServer.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/conf/EventMeshHttpClientConfig.java
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/conf/LiteClientConfig.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/EventMeshHttpConsumer.java
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/consumer/LiteConsumer.java
rename eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/{http
=> model}/RequestParam.java (85%)
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/CloudEventProducer.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/EventMeshHttpProducer.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/EventMeshMessageProducer.java
copy
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/{RRCallback.java
=> EventMeshProtocolProducer.java} (56%)
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/LiteProducer.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/producer/OpenMessageProducer.java
rename
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/http/{http/HttpUtil.java
=> util/HttpUtils.java} (82%)
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/EventMeshClient.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/EventMeshTCPClient.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/EventMeshTCPClientFactory.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/EventMeshTCPPubClient.java
rename
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/{SimpleSubClient.java
=> EventMeshTCPSubClient.java} (51%)
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/EventMeshThreadFactoryImpl.java
copy
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/common/{ReceiveMsgHook.java
=> PropertyConst.java} (80%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=>
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/conf/EventMeshTCPClientConfig.java
(73%)
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/AbstractEventMeshTCPPubHandler.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/AbstractEventMeshTCPSubHandler.java
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/DefaultEventMeshClient.java
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/SimplePubClientImpl.java
delete mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/SimpleSubClientImpl.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPClient.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPPubClient.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/cloudevent/CloudEventTCPSubClient.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/eventmeshmessage/EventMeshMessageTCPClient.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/eventmeshmessage/EventMeshMessageTCPPubClient.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/eventmeshmessage/EventMeshMessageTCPSubClient.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/openmessage/OpenMessageTCPClient.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/openmessage/OpenMessageTCPPubClient.java
create mode 100644
eventmesh-sdk-java/src/main/java/org/apache/eventmesh/client/tcp/impl/openmessage/OpenMessageTCPSubClient.java
delete mode 100644
eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo/AsyncPublishBroadcast.java
delete mode 100644
eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo/AsyncSubscribe.java
delete mode 100644
eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo/AsyncSubscribeBroadcast.java
delete mode 100644
eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo/SyncRequest.java
delete mode 100644
eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/demo/SyncResponse.java
create mode 100644
eventmesh-sdk-java/src/test/java/org/apache/eventmesh/client/tcp/impl/EventMeshTCPClientFactoryTest.java
copy {eventmesh-common => eventmesh-security-plugin}/build.gradle (100%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
=> eventmesh-security-plugin/eventmesh-security-acl/build.gradle (81%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.consumer.MeshMQPushConsumer
=> eventmesh-security-plugin/eventmesh-security-acl/gradle.properties (91%)
create mode 100644
eventmesh-security-plugin/eventmesh-security-acl/src/main/java/org/apache/eventmesh/acl/impl/AclServiceImpl.java
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-security-plugin/eventmesh-security-acl/src/main/resources/META-INF/eventmesh/org.apache.eventmesh.api.acl.AclService
(91%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
=> eventmesh-security-plugin/eventmesh-security-api/build.gradle (89%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
=>
eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/acl/AclPropertyKeys.java
(67%)
rename
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/producer/MeshMQProducer.java
=>
eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/acl/AclService.java
(52%)
rename eventmesh-connector-api/build.gradle =>
eventmesh-security-plugin/eventmesh-security-api/src/main/java/org/apache/eventmesh/api/exception/AclException.java
(75%)
rename
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/AbstractContext.java
=> eventmesh-spi/build.gradle (81%)
rename
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.consumer.MeshMQPushConsumer
=> eventmesh-spi/gradle.properties (91%)
create mode 100644
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshExtensionFactory.java
copy
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubcriptionType.java
=>
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshExtensionType.java
(61%)
rename
eventmesh-common/src/main/java/org/apache/eventmesh/common/protocol/SubcriptionType.java
=> eventmesh-spi/src/main/java/org/apache/eventmesh/spi/EventMeshSPI.java (58%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=> eventmesh-spi/src/main/java/org/apache/eventmesh/spi/ExtensionException.java
(70%)
create mode 100644
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/loader/EventMeshUrlClassLoader.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/core/protocol/tcp/client/group/dispatch/DownstreamDispatchStrategy.java
=>
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/loader/ExtensionClassLoader.java
(57%)
create mode 100644
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/loader/JarExtensionClassLoader.java
create mode 100644
eventmesh-spi/src/main/java/org/apache/eventmesh/spi/loader/MetaInfExtensionClassLoader.java
create mode 100644
eventmesh-spi/src/test/java/org/apache/eventmesh/spi/EventMeshExtensionFactoryTest.java
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-spi/src/test/java/org/apache/eventmesh/spi/example/PrototypeExtension.java
(71%)
copy
eventmesh-runtime/src/main/java/org/apache/eventmesh/runtime/util/ValueComparator.java
=>
eventmesh-spi/src/test/java/org/apache/eventmesh/spi/example/SingletonExtension.java
(71%)
copy
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=>
eventmesh-spi/src/test/java/org/apache/eventmesh/spi/example/TestPrototypeExtension.java
(73%)
rename
eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/RRCallback.java
=>
eventmesh-spi/src/test/java/org/apache/eventmesh/spi/example/TestSingletonExtension.java
(73%)
copy
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-spi/src/test/resources/META-INF/eventmesh/org.apache.eventmesh.spi.example.TestPrototypeExtension
(91%)
rename
eventmesh-connector-rocketmq/src/main/resources/META-INF/services/org.apache.eventmesh.api.producer.MeshMQProducer
=>
eventmesh-spi/src/test/resources/META-INF/eventmesh/org.apache.eventmesh.spi.example.TestSingletonExtension
(91%)
delete mode 100644 eventmesh-test/build.gradle
delete mode 100644
eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/AsyncPublishInstance.java
delete mode 100644
eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/AsyncSyncRequestInstance.java
delete mode 100644
eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/SyncRequestInstance.java
delete mode 100644
eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/sub/controller/SubController.java
delete mode 100644
eventmesh-test/src/main/java/org/apache/eventmesh/tcp/common/EventMeshTestUtils.java
delete mode 100644
eventmesh-test/src/main/java/org/apache/eventmesh/tcp/demo/SyncRequest.java
delete mode 100644 gradle/wrapper/gradle-wrapper.jar
delete mode 100644 gradle/wrapper/gradle-wrapper.properties
create mode 100644 style/checkStyle.xml
delete mode 100644 style/codeStyle.xml
delete mode 100644 style/copyright/Apache.xml
create mode 100644 tools/third-party-dependencies/check-dependencies.sh
create mode 100644 tools/third-party-dependencies/known-dependencies.txt
create mode 100644 tools/third-party-licenses/LICENSE
create mode 100644 tools/third-party-licenses/licenses/LICENSE-assertj-core.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-checker-qual.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-cloudevents-api.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-cloudevents-core.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-cloudevents-json-jackson.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-commons-beanutils.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-commons-cli.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-commons-codec.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-commons-collections.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-commons-collections4.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-commons-digester.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-commons-lang3.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-commons-logging.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-commons-text.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-commons-validator.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-disruptor.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-dledger.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-error_prone_annotations.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-failureaccess.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-fastjson.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-guava.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-hamcrest-core.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-httpclient.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-httpcore.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-j2objc-annotations.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-jackson-annotations.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-jackson-core.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-jackson-databind.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-javassist.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-jcommander.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-jna.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-jsr305.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-junit.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-listenablefuture.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-log4j-api.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-log4j-core.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-log4j-slf4j-impl.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-logback-core.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-metrics-annotation.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-metrics-core.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-metrics-healthchecks.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-metrics-json.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-netty-all.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-netty-tcnative-boringssl-static.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-okhttp.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-okio.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-openmessaging-api.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-opentelemetry-api-metrics.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-opentelemetry-api.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-opentelemetry-context.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-opentelemetry-exporter-prometheus.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-opentelemetry-exporter-zipkin.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-opentelemetry-sdk-common.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-opentelemetry-sdk-metrics.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-opentelemetry-sdk-trace.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-opentelemetry-sdk.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-opentelemetry-semconv.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-rocketmq-acl.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-rocketmq-broker.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-rocketmq-client.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-rocketmq-common.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-rocketmq-filter.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-rocketmq-logging.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-rocketmq-namesrv.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-rocketmq-remoting.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-rocketmq-srvutil.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-rocketmq-store.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-rocketmq-test.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-rocketmq-tools.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-simpleclient.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-simpleclient_common.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-simpleclient_httpserver.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-slf4j-api.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-snakeyam.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-system-rules.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-truth.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-zipkin-reporter.txt
create mode 100644
tools/third-party-licenses/licenses/LICENSE-zipkin-sender-okhttp3.txt
create mode 100644 tools/third-party-licenses/licenses/LICENSE-zipkin.txt
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
