Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[Task List] Looking for Code Hero for Apache EventMesh #405

Closed
5 tasks
xwm1992 opened this issue Jun 29, 2021 · 2 comments · Fixed by #649 or #707
Closed
5 tasks

[Task List] Looking for Code Hero for Apache EventMesh #405

xwm1992 opened this issue Jun 29, 2021 · 2 comments · Fixed by #649 or #707
Labels
improvement Improve the mechanism or performance kind

Comments

@xwm1992
Copy link
Contributor

xwm1992 commented Jun 29, 2021

Welcome to participate bello tasks:

or you can find the issue from issue list that no one take it and you wish to contribute, thanks.

@xwm1992 xwm1992 added improvement Improve the mechanism or performance kind labels Jun 29, 2021
@xwm1992 xwm1992 pinned this issue Jun 29, 2021
xwm1992 pushed a commit that referenced this issue Jul 1, 2021
* code polish and fix typo

* merge remote 1.3.0
qqeasonchen pushed a commit that referenced this issue Jul 9, 2021
* modify the doc

* modify the doc
xwm1992 added a commit that referenced this issue Jul 12, 2021
* merge develop into 1.3.0 branch (#401)

* upgrade gradle to 6.8.3

* [ISSUE #265]rename wemq and access to eventmesh

* [ISSUE #265]rename proxy field to eventmesh

* merge conflict

* remove warn

* [ISSUE #265] Specification of code structure and file naming

* remove eventmesh-registry module

* enabled http/tcp monitor logs

* Update README.md

* Changed com.webank to org.apache

Changed 'eventmesh-connector-api' code package name to apache.

* issue #277:refactor eventmesh-common package with org.apache

* issue #277:rename package with org.apache

* Refactor 'eventmesh-connector-rocketmq' package name to org.apache

* Update README.zh-CN.md

* [ISSUE #282]Refactor 'eventmesh-starter' package name to org.apache

* Update codeStyle.xml

* Refactor 'eventmesh-test' package name to org.apache #283

* Refactor 'eventmesh-test' package name to org.apache #283

* Refactor 'eventmesh-test' package name to org.apache #283

* Refactor 'eventmesh-test' package name to org.apache #283

* Refactor 'eventmesh-test' package name to org.apache #283

* refactor runtime module package com.webank to org.apache

* refactor(eventmesh-sdk-java):rename to org.apache(#281)

* [ISSUE #281]refactor(eventmesh-sdk-java):rename to org.apache

* add licenses of apache for runtime module

* add NOTICE

* bugfix for event-mesh-test module

* change package name to org.apache

* format README.md

* change package name to org.apache

* fix ISSUE #296:add licenses in each source file under the eventmesh-sdk-java

* [ISSUE #294]add licenses in file under eventmesh-connector-rocketmq module

* [ISSUE #293]Lack of licenses in each source file under the eventmesh-connector-api module

* [ISSUE #298]Lack of licenses in each source file under the eventmesh-test module

* [ISSUE #297]Lack of licenses in each source file under the eventmesh-starter module

* Create .asf.yaml

* Update .asf.yaml

* Update .asf.yaml (#316)

* Update README.md

* Update .asf.yaml

* bugfix build.gradle tar task (#318)

Co-authored-by: jonyang(杨军) <[email protected]>

* [ISSUE #322] Rename package name "com.webank.eventmesh" to "org.apache.eventmesh" (#319)

* rename org.apache.runtime to com.webank.runtime

* rename com.webank.eventmesh to org.apache.eventmesh

* fix(docs): change the travis location

* Create DISCLAIMER-WIP

* Delete CNAME

* Delete _config.yml

* Delete package.json

* Add files via upload

* Add files via upload

* Delete eventmesh-multi-runtime.jpg

* Update README.md

* Update eventmesh-runtime-quickstart.md

* Update README.zh-CN.md

* Update eventmesh-runtime-quickstart.zh-CN.md

* [ISSUE #325]Update gradle configuration for publishing package to maven repository (#326)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* upgrade gradle to 7.0 and fix test bug. (#327)

* bugfix build.gradle tar task

* merge

* upgrade to gradle 7.0

* bugfix gradle task spotbugs

* bugfix eventmesh-connector-rocketmq testImplementation

* upgrade to gradle7.0

* refactor runtime module test and spotbugs error

* bugfix sign task

Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: jonyangx <[email protected]>

* remove unused files

Signed-off-by: qqeasonchen <[email protected]>

* update build.gradle and gradle.properties for publish to maven repository (#330)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* Update README.md

* Update README.zh-CN.md

* update quickstart md files for gradle version (#332)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* remove dead docs

Signed-off-by: qqeasonchen <[email protected]>

* [ISSUE #329]Missing Log4j dependency (#336)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE #329]Missing Log4j dependency

* [ISSUE #331] Fix dead links in docs (#334)

fixed #331

* Doc modification #328 (#335)

change vm params

* Update README.md

* [Issue #337] Fix Http Test Subscriber startup issue by moving the Thread.sleep into the child thread (#338)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

Co-authored-by: j00441484 <[email protected]>

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook (#343)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Address code review comment for Subscriber Demo App

Co-authored-by: j00441484 <[email protected]>

* [ISSUE #348] Setup automated workflows for greetings (#347)

* Setup automated workflows for greetings

* Remove '@apache/eventmesh-committers'

* Add LGTM Badges ISSUE#353 (#354)

LGTM is a variant analysis platform that automatically checks code for real CVEs and vulnerabilities. Learn more at https://lgtm.com/help/lgtm/about-lgtm .

Here are some alerts in our project reported by LGTM: https://lgtm.com/projects/g/apache/incubator-eventmesh/alerts/?mode=list

I'd like to add LGTM badges in the README.md, it makes easier for people who want to get alerts and then contribute to EventMesh.

* [ISSUE #355] Setup Github workflows for CodeQL scans (#356)

* Setup CodeQL scans

* disable autorun

* add a step for setting up JDK

* add codeql

* fix step Build

* fix strategy

* add events: schedule & workflow_dispatch

* [Issue #344] Fixing racing condition issue in SubscribeProcessor and UnSubscribeProcessor (#345)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #344] Fixing racing condition issue in SubscribeProcessor and UnSubscribeProcessor

* [Issue #344] Fix import statements

* [Issue #337] Address code review comment for Subscriber Demo App

* [Issue #344] Enhance client registration logic in SubscribeProcessor and UnsubscriberProcessor

* [Issue #344] Minor code clean up in SubscribeProcessor and UnsubscriberProcessor

* [Issue #344] Fix NullPointerException in ConsumerManager occurs during subscribe/unsunscribe iteration testing

* [Issue #344] Fix bugs in subscribe/unsunscribe code path

* [Issue #344] use client.pid instead of client.ip for client comparasion in UnSubscribeProcessor

Co-authored-by: j00441484 <[email protected]>

* update eventmesh-runtime.png (#358)

* update eventmesh-runtime.png

* [Issue #333] Support multiple load balance strategy in sdk (#342)

* Support multiple load balance strategy in sdk #333

* Fix ut

* add log

* update eventmesh-panels.png (#362)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

* update eventmesh-panels.png (#363)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

* Migrate CI to Github Actions and enable coverage report (#365)

* add: requirements for lightweight EventMesh SDK with CloudEvents (#370)

This commit only includes a brief introduction and requirements.
Design details can be followed up in a later commit.

Signed-off-by: Yuzhou Mao <[email protected]>

* Add files via upload

* Update README.md

* [Issue #368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer (#369)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Address code review comment for Subscriber Demo App

* [Issue #368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer

* [Issue #368] fix build issue

* [Issue #368] use try with resource statement for HttpClient

* [Issue #368] fix TLS1.1 and use TLS1.2 in HttpClient

Co-authored-by: j00441484 <[email protected]>

* [ISSUE #350]optimize flow control in downstreaming msg (#352)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* [ISSUE #380] Remove gitee-mirror.yml from Github workflows (#381)

* Update README.md

* [ISSUE #310] add github action for check license (#313)

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

* [ISSUE #310] Enable Github Actions for license check and fix license headers (#377)

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

* enable github actions for license check

* add necessary headers

* update badges

Co-authored-by: Lan Liang <[email protected]>

* [Issue #382] Fix java.lang.NumberFormatException when parsing Long (#383)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Address code review comment for Subscriber Demo App

* [Issue #368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer

* [Issue #368] fix build issue

* [Issue #368] use try with resource statement for HttpClient

* [Issue #368] fix TLS1.1 and use TLS1.2 in HttpClient

* [Issue #382] Fix java.lang.NumberFormatException when parsing Long

* [Issue #382] Fix java.lang.NumberFormatException when parsing Integer

Co-authored-by: j00441484 <[email protected]>

* [ISSUE #378] downstream broadcast msg asynchronously  (#379)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

closed #378

* [ISSUE #359] Split handler from controller (#359) (#360)

* [ISSUE #359] Split handler from controller (#359)

* add license header

* add ut

* [ISSUE #384] RedirectClientByIpPortHandlerTest.java doesn't have the Apache license header (#385)

close #384

* Update README.md

* Update README.zh-CN.md

* Update README.zh-CN.md

* Update README.zh-CN.md

* [Issue #386] fixing ConsumerGroup Queue Consumer Offset not synced up issue (#387)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Address code review comment for Subscriber Demo App

* [Issue #386] fixing ConsumerGroup Queuen Consumer Offset not synced up issue

* [Issue #386] adding license header to new file

* [Issue #386] Fix license header missing issue

Co-authored-by: j00441484 <[email protected]>

* [ISSUE #366 ] remove custom-format topic concept (#388)

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* [ISSUE #366] remove custom concept [dcn&&region] (#390)

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

close #366

* [ISSUE #391] Optimize interface design in eventmesh-connector-api (#392)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

* modify:remove unneccessary interface in eventmesh-connector-api

* modify:fix conflict

* modify:add license in EventMeshAction
close #391

* miss group name set for userAgent (#395)

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* bugfix : miss group set

* bugfix : miss group set

* [ISSUE #393]:perf topic name in test file (#394)

close #393

* support unsubscribe topics while delconsumer in http mode (#396)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

* [ISSUE #397]Remove subscription session failed error (#398)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

* [ISSUE #397]Remove subscription session failed error

* [ISSUE #397]Remove subscription session failed error
close #397

Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: MajorHe1 <[email protected]>
Co-authored-by: mike_xwm <[email protected]>
Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Heng Du <[email protected]>
Co-authored-by: Udesh Liyanaarachchi <>
Co-authored-by: keranbingaa <[email protected]>
Co-authored-by: sunxi <[email protected]>
Co-authored-by: sanchen <[email protected]>
Co-authored-by: surilli(李慧敏) <[email protected]>
Co-authored-by: Lan Liang <[email protected]>
Co-authored-by: zhangxiaopengmm <[email protected]>
Co-authored-by: nanoxiong <[email protected]>
Co-authored-by: chenyi19851209 <[email protected]>
Co-authored-by: yangjun <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: von gosling <[email protected]>
Co-authored-by: jonyangx <[email protected]>
Co-authored-by: ruanwenjun <[email protected]>
Co-authored-by: jinrongluo <[email protected]>
Co-authored-by: j00441484 <[email protected]>
Co-authored-by: Yuzhou Mao <[email protected]>
Co-authored-by: lrhkobe <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: Lan <[email protected]>

* [ISSUE #411] Enable CI workflows running on [0-9]+.[0-9]+.[0-9]+** branches (#413)

* [Issues #405]code polish and fix typo (#404)

* code polish and fix typo

* merge remote 1.3.0

* [ISSUE #374] Add unit test class. (#402)

* [ISSUE #374] add unit test for LiteMessage class.

* [ISSUE #374] add unit test for HttpCommand class.

* [ISSUE #374] add unit test for httpResponse method with REQ cmd type.

* [ISSUE-#374] Add unit test class. (#414)

* [ISSUE #374] add unit test for CommonConfiguration class.

* [ISSUE #374] add unit test for ConfigurationWraper class.

* [ISSUE #374] add unit test for Weight class.

* [ISSUE #374] add unit test for CommonConfiguration class.

* [ISSUE #367]Enhance SPI plugins (#419)

* [ISSUE #374] add unit test for http protocol header client class. (#420)

* fix typo (#423)

* [ISSUE #418]Refactor the plugin load code (#421)

* [ISSUE #418]Refactor the plugin load code

* fix ut

* [ISSUE #405]modify the doc (#424)

* modify the doc

* modify the doc

* Merege 1.3.0 to develop.

* Merege 1.3.0 to develop.

* Merge 1.3.0 to develop, fix check style problem.

Co-authored-by: wqliang <[email protected]>
Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: MajorHe1 <[email protected]>
Co-authored-by: mike_xwm <[email protected]>
Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Heng Du <[email protected]>
Co-authored-by: keranbingaa <[email protected]>
Co-authored-by: sunxi <[email protected]>
Co-authored-by: sanchen <[email protected]>
Co-authored-by: surilli(李慧敏) <[email protected]>
Co-authored-by: Lan Liang <[email protected]>
Co-authored-by: zhangxiaopengmm <[email protected]>
Co-authored-by: nanoxiong <[email protected]>
Co-authored-by: chenyi19851209 <[email protected]>
Co-authored-by: yangjun <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: von gosling <[email protected]>
Co-authored-by: jonyangx <[email protected]>
Co-authored-by: ruanwenjun <[email protected]>
Co-authored-by: jinrongluo <[email protected]>
Co-authored-by: j00441484 <[email protected]>
Co-authored-by: Yuzhou Mao <[email protected]>
Co-authored-by: lrhkobe <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: Lan <[email protected]>
Co-authored-by: YuDong Tang <[email protected]>
@xwm1992
Copy link
Contributor Author

xwm1992 commented Jul 12, 2021

jjz921024 pushed a commit to jjz921024/incubator-eventmesh that referenced this issue Jul 25, 2021
* merge develop into 1.3.0 branch (apache#401)

* upgrade gradle to 6.8.3

* [ISSUE apache#265]rename wemq and access to eventmesh

* [ISSUE apache#265]rename proxy field to eventmesh

* merge conflict

* remove warn

* [ISSUE apache#265] Specification of code structure and file naming

* remove eventmesh-registry module

* enabled http/tcp monitor logs

* Update README.md

* Changed com.webank to org.apache

Changed 'eventmesh-connector-api' code package name to apache.

* issue apache#277:refactor eventmesh-common package with org.apache

* issue apache#277:rename package with org.apache

* Refactor 'eventmesh-connector-rocketmq' package name to org.apache

* Update README.zh-CN.md

* [ISSUE apache#282]Refactor 'eventmesh-starter' package name to org.apache

* Update codeStyle.xml

* Refactor 'eventmesh-test' package name to org.apache apache#283

* Refactor 'eventmesh-test' package name to org.apache apache#283

* Refactor 'eventmesh-test' package name to org.apache apache#283

* Refactor 'eventmesh-test' package name to org.apache apache#283

* Refactor 'eventmesh-test' package name to org.apache apache#283

* refactor runtime module package com.webank to org.apache

* refactor(eventmesh-sdk-java):rename to org.apache(apache#281)

* [ISSUE apache#281]refactor(eventmesh-sdk-java):rename to org.apache

* add licenses of apache for runtime module

* add NOTICE

* bugfix for event-mesh-test module

* change package name to org.apache

* format README.md

* change package name to org.apache

* fix ISSUE apache#296:add licenses in each source file under the eventmesh-sdk-java

* [ISSUE apache#294]add licenses in file under eventmesh-connector-rocketmq module

* [ISSUE apache#293]Lack of licenses in each source file under the eventmesh-connector-api module

* [ISSUE apache#298]Lack of licenses in each source file under the eventmesh-test module

* [ISSUE apache#297]Lack of licenses in each source file under the eventmesh-starter module

* Create .asf.yaml

* Update .asf.yaml

* Update .asf.yaml (apache#316)

* Update README.md

* Update .asf.yaml

* bugfix build.gradle tar task (apache#318)

Co-authored-by: jonyang(杨军) <[email protected]>

* [ISSUE apache#322] Rename package name "com.webank.eventmesh" to "org.apache.eventmesh" (apache#319)

* rename org.apache.runtime to com.webank.runtime

* rename com.webank.eventmesh to org.apache.eventmesh

* fix(docs): change the travis location

* Create DISCLAIMER-WIP

* Delete CNAME

* Delete _config.yml

* Delete package.json

* Add files via upload

* Add files via upload

* Delete eventmesh-multi-runtime.jpg

* Update README.md

* Update eventmesh-runtime-quickstart.md

* Update README.zh-CN.md

* Update eventmesh-runtime-quickstart.zh-CN.md

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository (apache#326)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* upgrade gradle to 7.0 and fix test bug. (apache#327)

* bugfix build.gradle tar task

* merge

* upgrade to gradle 7.0

* bugfix gradle task spotbugs

* bugfix eventmesh-connector-rocketmq testImplementation

* upgrade to gradle7.0

* refactor runtime module test and spotbugs error

* bugfix sign task

Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: jonyangx <[email protected]>

* remove unused files

Signed-off-by: qqeasonchen <[email protected]>

* update build.gradle and gradle.properties for publish to maven repository (apache#330)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* Update README.md

* Update README.zh-CN.md

* update quickstart md files for gradle version (apache#332)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* remove dead docs

Signed-off-by: qqeasonchen <[email protected]>

* [ISSUE apache#329]Missing Log4j dependency (apache#336)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE apache#329]Missing Log4j dependency

* [ISSUE apache#331] Fix dead links in docs (apache#334)

fixed apache#331

* Doc modification apache#328 (apache#335)

change vm params

* Update README.md

* [Issue apache#337] Fix Http Test Subscriber startup issue by moving the Thread.sleep into the child thread (apache#338)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

Co-authored-by: j00441484 <[email protected]>

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook (apache#343)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Address code review comment for Subscriber Demo App

Co-authored-by: j00441484 <[email protected]>

* [ISSUE apache#348] Setup automated workflows for greetings (apache#347)

* Setup automated workflows for greetings

* Remove '@apache/eventmesh-committers'

* Add LGTM Badges ISSUE#353 (apache#354)

LGTM is a variant analysis platform that automatically checks code for real CVEs and vulnerabilities. Learn more at https://lgtm.com/help/lgtm/about-lgtm .

Here are some alerts in our project reported by LGTM: https://lgtm.com/projects/g/apache/incubator-eventmesh/alerts/?mode=list

I'd like to add LGTM badges in the README.md, it makes easier for people who want to get alerts and then contribute to EventMesh.

* [ISSUE apache#355] Setup Github workflows for CodeQL scans (apache#356)

* Setup CodeQL scans

* disable autorun

* add a step for setting up JDK

* add codeql

* fix step Build

* fix strategy

* add events: schedule & workflow_dispatch

* [Issue apache#344] Fixing racing condition issue in SubscribeProcessor and UnSubscribeProcessor (apache#345)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#344] Fixing racing condition issue in SubscribeProcessor and UnSubscribeProcessor

* [Issue apache#344] Fix import statements

* [Issue apache#337] Address code review comment for Subscriber Demo App

* [Issue apache#344] Enhance client registration logic in SubscribeProcessor and UnsubscriberProcessor

* [Issue apache#344] Minor code clean up in SubscribeProcessor and UnsubscriberProcessor

* [Issue apache#344] Fix NullPointerException in ConsumerManager occurs during subscribe/unsunscribe iteration testing

* [Issue apache#344] Fix bugs in subscribe/unsunscribe code path

* [Issue apache#344] use client.pid instead of client.ip for client comparasion in UnSubscribeProcessor

Co-authored-by: j00441484 <[email protected]>

* update eventmesh-runtime.png (apache#358)

* update eventmesh-runtime.png

* [Issue apache#333] Support multiple load balance strategy in sdk (apache#342)

* Support multiple load balance strategy in sdk apache#333

* Fix ut

* add log

* update eventmesh-panels.png (apache#362)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE apache#329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

* update eventmesh-panels.png (apache#363)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE apache#329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

* Migrate CI to Github Actions and enable coverage report (apache#365)

* add: requirements for lightweight EventMesh SDK with CloudEvents (apache#370)

This commit only includes a brief introduction and requirements.
Design details can be followed up in a later commit.

Signed-off-by: Yuzhou Mao <[email protected]>

* Add files via upload

* Update README.md

* [Issue apache#368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer (apache#369)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Address code review comment for Subscriber Demo App

* [Issue apache#368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer

* [Issue apache#368] fix build issue

* [Issue apache#368] use try with resource statement for HttpClient

* [Issue apache#368] fix TLS1.1 and use TLS1.2 in HttpClient

Co-authored-by: j00441484 <[email protected]>

* [ISSUE apache#350]optimize flow control in downstreaming msg (apache#352)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* [ISSUE apache#380] Remove gitee-mirror.yml from Github workflows (apache#381)

* Update README.md

* [ISSUE apache#310] add github action for check license (apache#313)

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

* [ISSUE apache#310] Enable Github Actions for license check and fix license headers (apache#377)

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

* enable github actions for license check

* add necessary headers

* update badges

Co-authored-by: Lan Liang <[email protected]>

* [Issue apache#382] Fix java.lang.NumberFormatException when parsing Long (apache#383)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Address code review comment for Subscriber Demo App

* [Issue apache#368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer

* [Issue apache#368] fix build issue

* [Issue apache#368] use try with resource statement for HttpClient

* [Issue apache#368] fix TLS1.1 and use TLS1.2 in HttpClient

* [Issue apache#382] Fix java.lang.NumberFormatException when parsing Long

* [Issue apache#382] Fix java.lang.NumberFormatException when parsing Integer

Co-authored-by: j00441484 <[email protected]>

* [ISSUE apache#378] downstream broadcast msg asynchronously  (apache#379)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

closed apache#378

* [ISSUE apache#359] Split handler from controller (apache#359) (apache#360)

* [ISSUE apache#359] Split handler from controller (apache#359)

* add license header

* add ut

* [ISSUE apache#384] RedirectClientByIpPortHandlerTest.java doesn't have the Apache license header (apache#385)

close apache#384

* Update README.md

* Update README.zh-CN.md

* Update README.zh-CN.md

* Update README.zh-CN.md

* [Issue apache#386] fixing ConsumerGroup Queue Consumer Offset not synced up issue (apache#387)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Address code review comment for Subscriber Demo App

* [Issue apache#386] fixing ConsumerGroup Queuen Consumer Offset not synced up issue

* [Issue apache#386] adding license header to new file

* [Issue apache#386] Fix license header missing issue

Co-authored-by: j00441484 <[email protected]>

* [ISSUE apache#366 ] remove custom-format topic concept (apache#388)

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* [ISSUE apache#366] remove custom concept [dcn&&region] (apache#390)

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

close apache#366

* [ISSUE apache#391] Optimize interface design in eventmesh-connector-api (apache#392)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

* modify:remove unneccessary interface in eventmesh-connector-api

* modify:fix conflict

* modify:add license in EventMeshAction
close apache#391

* miss group name set for userAgent (apache#395)

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* bugfix : miss group set

* bugfix : miss group set

* [ISSUE apache#393]:perf topic name in test file (apache#394)

close apache#393

* support unsubscribe topics while delconsumer in http mode (apache#396)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE apache#329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

* [ISSUE apache#397]Remove subscription session failed error (apache#398)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE apache#329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

* [ISSUE apache#397]Remove subscription session failed error

* [ISSUE apache#397]Remove subscription session failed error
close apache#397

Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: MajorHe1 <[email protected]>
Co-authored-by: mike_xwm <[email protected]>
Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Heng Du <[email protected]>
Co-authored-by: Udesh Liyanaarachchi <>
Co-authored-by: keranbingaa <[email protected]>
Co-authored-by: sunxi <[email protected]>
Co-authored-by: sanchen <[email protected]>
Co-authored-by: surilli(李慧敏) <[email protected]>
Co-authored-by: Lan Liang <[email protected]>
Co-authored-by: zhangxiaopengmm <[email protected]>
Co-authored-by: nanoxiong <[email protected]>
Co-authored-by: chenyi19851209 <[email protected]>
Co-authored-by: yangjun <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: von gosling <[email protected]>
Co-authored-by: jonyangx <[email protected]>
Co-authored-by: ruanwenjun <[email protected]>
Co-authored-by: jinrongluo <[email protected]>
Co-authored-by: j00441484 <[email protected]>
Co-authored-by: Yuzhou Mao <[email protected]>
Co-authored-by: lrhkobe <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: Lan <[email protected]>

* [ISSUE apache#411] Enable CI workflows running on [0-9]+.[0-9]+.[0-9]+** branches (apache#413)

* [Issues apache#405]code polish and fix typo (apache#404)

* code polish and fix typo

* merge remote 1.3.0

* [ISSUE apache#374] Add unit test class. (apache#402)

* [ISSUE apache#374] add unit test for LiteMessage class.

* [ISSUE apache#374] add unit test for HttpCommand class.

* [ISSUE apache#374] add unit test for httpResponse method with REQ cmd type.

* [ISSUE-apache#374] Add unit test class. (apache#414)

* [ISSUE apache#374] add unit test for CommonConfiguration class.

* [ISSUE apache#374] add unit test for ConfigurationWraper class.

* [ISSUE apache#374] add unit test for Weight class.

* [ISSUE apache#374] add unit test for CommonConfiguration class.

* [ISSUE apache#367]Enhance SPI plugins (apache#419)

* [ISSUE apache#374] add unit test for http protocol header client class. (apache#420)

* fix typo (apache#423)

* [ISSUE apache#418]Refactor the plugin load code (apache#421)

* [ISSUE apache#418]Refactor the plugin load code

* fix ut

* [ISSUE apache#405]modify the doc (apache#424)

* modify the doc

* modify the doc

* Merege 1.3.0 to develop.

* Merege 1.3.0 to develop.

* Merge 1.3.0 to develop, fix check style problem.

Co-authored-by: wqliang <[email protected]>
Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: MajorHe1 <[email protected]>
Co-authored-by: mike_xwm <[email protected]>
Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Heng Du <[email protected]>
Co-authored-by: keranbingaa <[email protected]>
Co-authored-by: sunxi <[email protected]>
Co-authored-by: sanchen <[email protected]>
Co-authored-by: surilli(李慧敏) <[email protected]>
Co-authored-by: Lan Liang <[email protected]>
Co-authored-by: zhangxiaopengmm <[email protected]>
Co-authored-by: nanoxiong <[email protected]>
Co-authored-by: chenyi19851209 <[email protected]>
Co-authored-by: yangjun <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: von gosling <[email protected]>
Co-authored-by: jonyangx <[email protected]>
Co-authored-by: ruanwenjun <[email protected]>
Co-authored-by: jinrongluo <[email protected]>
Co-authored-by: j00441484 <[email protected]>
Co-authored-by: Yuzhou Mao <[email protected]>
Co-authored-by: lrhkobe <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: Lan <[email protected]>
Co-authored-by: YuDong Tang <[email protected]>
xwm1992 pushed a commit that referenced this issue Sep 15, 2021
* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Address code review comment for Subscriber Demo App

* Fix subscriptionType typo

Co-authored-by: j00441484 <[email protected]>
@vongosling vongosling changed the title eventmesh code polish EventMesh code hero for improvment Oct 25, 2021
@vongosling vongosling changed the title EventMesh code hero for improvment Looking for code hero for Apache EventMesh Oct 25, 2021
xwm1992 added a commit to xwm1992/EventMesh that referenced this issue Dec 14, 2021
xwm1992 added a commit that referenced this issue Dec 14, 2021
* [ISSUE #405] remove some unused code
@xwm1992 xwm1992 changed the title Looking for code hero for Apache EventMesh [Enhancement]Looking for code hero for Apache EventMesh Dec 17, 2021
@xwm1992 xwm1992 changed the title [Enhancement]Looking for code hero for Apache EventMesh [Enhancement] Looking for code hero for Apache EventMesh Dec 17, 2021
@xwm1992 xwm1992 reopened this Dec 17, 2021
xwm1992 added a commit that referenced this issue Dec 24, 2021
* readme.md

* [ISSUE #563] SDK SUPPORT CLOUD EVENT (#575)

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

* SDK SUPPORT CLOUD EVENT

Co-authored-by: wangshaojie <[email protected]>

* [Feature #562] support cloudevents api in eventmesh-connector-api module (#578)

* [Feature #564] Support CloudEvents protocols for pub/sub in EventMesh-feature design

* support cloudevents api in eventmesh-connector-api module

* fix checkStyle

* fix checkStyle

* fix checkStyle

* 1.support LifeCycle.java
2.update Consumer and Producer

* fix remove the extra blank line

* connector support cloud event (#586)

Co-authored-by: wangshaojie <[email protected]>

* [Feature #562] Support CloudEvents for pub/sub in EventMesh runtime (#587)

* [Feature #564] Support CloudEvents protocols for pub/sub in EventMesh-feature design

* support cloudevents api in eventmesh-connector-api module

* fix checkStyle

* fix checkStyle

* fix checkStyle

* 1.support LifeCycle.java
2.update Consumer and Producer

* fix remove the extra blank line

* support cloudEvents

* support cloudEvents

* support cloudEvents

* support cloudEvents

* support cloudevents

* support cloudEvents

* support cloudEvents

* support cloudEvents

* [Feature #562] Implement CloudEvents protocol adaptor (#595)

* [Feature #564] Support CloudEvents protocols for pub/sub in EventMesh-feature design

* support cloudevents api in eventmesh-connector-api module

* fix checkStyle

* fix checkStyle

* fix checkStyle

* 1.support LifeCycle.java
2.update Consumer and Producer

* fix remove the extra blank line

* support cloudEvents

* Add files via upload

* Update README.md

* support cloudEvents

* support cloudEvents

* [ISSUE #580] Add checkstyle gradle plugin (#581)

* Add checkstyle gradle plugin, change plugin package

* skip check in ci

* support cloudEvents

* support cloudevents

* update wechat-official qr code

* update mesh-helper qr code

* Add files via upload

* update README.md

* update README.md

* Update .asf.yaml

* support cloudEvents

* support cloudEvents

* [ISSUE #588] Fix typo in README.md (#589)

close #588

* support cloudEvents

* [Bug #590] Consumer subscription topic is invalid (#590) (#592)

* [Bug #590] Consumer subscription topic is invalid (#590)

* [Bug #590] Consumer subscription topic is invalid (#590)

close #590

* support cloudEvents adaptor

* [Feature #562] Implement CloudEvents adaptor

Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Wenjun Ruan <[email protected]>
Co-authored-by: Nicholas Zhan <[email protected]>
Co-authored-by: hagsyn <[email protected]>

* [Feature #562] Implement EventMeshMessage protocol adaptor (#597)

* [Feature #564] Support CloudEvents protocols for pub/sub in EventMesh-feature design

* support cloudevents api in eventmesh-connector-api module

* fix checkStyle

* fix checkStyle

* fix checkStyle

* 1.support LifeCycle.java
2.update Consumer and Producer

* fix remove the extra blank line

* support cloudEvents

* Add files via upload

* Update README.md

* support cloudEvents

* support cloudEvents

* [ISSUE #580] Add checkstyle gradle plugin (#581)

* Add checkstyle gradle plugin, change plugin package

* skip check in ci

* support cloudEvents

* support cloudevents

* update wechat-official qr code

* update mesh-helper qr code

* Add files via upload

* update README.md

* update README.md

* Update .asf.yaml

* support cloudEvents

* support cloudEvents

* [ISSUE #588] Fix typo in README.md (#589)

close #588

* support cloudEvents

* [Bug #590] Consumer subscription topic is invalid (#590) (#592)

* [Bug #590] Consumer subscription topic is invalid (#590)

* [Bug #590] Consumer subscription topic is invalid (#590)

close #590

* support cloudEvents adaptor

* [Feature #562] Implement CloudEvents adaptor

* [Feature #562] Implement EventMeshMessage protocol adaptor

* supplement apache header

Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Wenjun Ruan <[email protected]>
Co-authored-by: Nicholas Zhan <[email protected]>
Co-authored-by: hagsyn <[email protected]>

* Remove some unused code (#591)

* Remove some unused code in sdk module

* Remove some unused code in sdk module

* fixed a wrong url in cn-doc (#585)

close #596

* resolve_exception->Consumer subscription topic is invalid #590 (#598)

close #590

* update Eventmeshmessage plugin (#599)

* [Feature #564] Support CloudEvents protocols for pub/sub in EventMesh-feature design

* support cloudevents api in eventmesh-connector-api module

* fix checkStyle

* fix checkStyle

* fix checkStyle

* 1.support LifeCycle.java
2.update Consumer and Producer

* fix remove the extra blank line

* support cloudEvents

* Add files via upload

* Update README.md

* support cloudEvents

* support cloudEvents

* [ISSUE #580] Add checkstyle gradle plugin (#581)

* Add checkstyle gradle plugin, change plugin package

* skip check in ci

* support cloudEvents

* support cloudevents

* update wechat-official qr code

* update mesh-helper qr code

* Add files via upload

* update README.md

* update README.md

* Update .asf.yaml

* support cloudEvents

* support cloudEvents

* [ISSUE #588] Fix typo in README.md (#589)

close #588

* support cloudEvents

* [Bug #590] Consumer subscription topic is invalid (#590) (#592)

* [Bug #590] Consumer subscription topic is invalid (#590)

* [Bug #590] Consumer subscription topic is invalid (#590)

close #590

* support cloudEvents adaptor

* [Feature #562] Implement CloudEvents adaptor

* [Feature #562] Implement EventMeshMessage protocol adaptor

* supplement apache header

* 1.update package name
2.support build.gradle and gradle.properties
3.support ProtocolTransportObject

Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Wenjun Ruan <[email protected]>
Co-authored-by: Nicholas Zhan <[email protected]>
Co-authored-by: hagsyn <[email protected]>

* Update eventmesh-store-quickstart.md

* Update README.md

* Add slack icon (#601)

* Add protocol producer in java sdk (#600)

* Add protocol producer in sdk

* Refactor callback handler

* Add tcp protocol client

* Change Tcp interface (#603)

* update http push request and adaptor (#606)

1.update http push request
2.update http in protocol adaptor

* update java sdk (#607)

* Fix standalone connector interface, fix example (#608)

* fix compile error (#609)

* update java sdk

* fix compile error

* Java sdk update (#610)

* update java sdk

* fix compile error

* fix sdk error

* Add EventMeshTCPClient, this client wrap the sub/sub client (#611)

* runtime update (#612)

* update java sdk

* fix compile error

* fix sdk error

* 1.remove the openmessage from connector-api
2.fix the standalone connector

* Java sdk update (#615)

* update java sdk

* fix compile error

* fix sdk error

1.remove the openmessage from connector-api
2.fix the standalone connector

* 1.fix the standalone connector
2.fix the sdk

* eventmesh-admin-rocketmq submodule and createTopic REST API (#530)

* eventmesh-admin-rocketmq submodule and createTopic draft API

* add license header

* change to /topicmanage

* fix build error

* fix some code check style issues

close #435 #346

* Fix some small issue (#616)

* eventmeshmessage protocol adaptor for tcp (#618)

1.fix the standalone connector
2.fix eventmeshmessage protocol adaptor for tcp

* remove openschema implementation from em project

* eventmesh message protocol for http pub/sub with standalone connector (#619)

1.fix eventmeshmessage protocol adaptor for http with standalone connector

* create topic command (#531)

* create topic command

* address review comments

* fix build and add createtopic method to standalone module

* fix build issue

* fix a few remaining code check issues

* fix test

close #346

* Java sdk update cloudevents pub/sub (#620)

1.cloudevents protocol tcp pub/sub for sdk

* Update README.md

* Change TCP Decoder and Encoder (#621)

* cloudevents protocol tcp pub/sub for sdk (#622)

1.cloudevents protocol tcp pub/sub for sdk

* cloudevents protocol tcp pub/sub for sdk (#623)

cloudevents protocol tcp pub/sub for sdk

* cloudevents protocol http pub/sub for sdk (#625)

cloudevents protocol http pub/sub for sdk

* cloudevents protocol pub/sub for http sdk (#627)

 fix cloudevents protocol pub/sub for http sdk

* Add AbstractEventMeshTCPSubHandler (#624)

* Add AbstractEventMeshTCPSubHandler

* cloudevents/eventmesh message protocol pub/sub for sdk in rocketmq-connector (#628)

* fix cloudevents/eventmesh message protocol pub/sub for sdk in rocketmq-connector

* cloudevents/eventmesh message protocol pub/sub for sdk in rocketmq-connector (#629)

* fix cloudevents/eventmesh message protocol pub/sub for sdk in rocketmq-connector

* Safely delete useless log4j dependencies

* Safely delete outdated metrics dependencies

* Sately delete useless collections4 dependency

* Safely delete useless commons dependencies

* Reback to the collections4, but let it not in api dependency

* Could not remove text for Safe Ramdom implementation

* Fix build error

* Add collection4

* Fix build error

* Revert "Safely delete outdated metrics dependencies"

This reverts commit 92287b0.

* Change to api dependency

* Remove doclint warnings

* Depracated checkstyle check error temporarily, we should remove it when we polish later

* sync request/response for sdk in rocketmq-connector (#634)

fix sync request/response for sdk in rocketmq-connector

* Update .asf.yaml

* Update .asf.yaml

* fix conflicts and update the code (#635)

* Add files via upload

* Update README.md

* [ISSUE #580] Add checkstyle gradle plugin (#581)

* Add checkstyle gradle plugin, change plugin package

* skip check in ci

* update wechat-official qr code

* update mesh-helper qr code

* Add files via upload

* update README.md

* update README.md

* Update .asf.yaml

* [ISSUE #588] Fix typo in README.md (#589)

close #588

* [Bug #590] Consumer subscription topic is invalid (#590) (#592)

* [Bug #590] Consumer subscription topic is invalid (#590)

* [Bug #590] Consumer subscription topic is invalid (#590)

close #590

* fixed a wrong url in cn-doc (#585)

close #596

* resolve_exception->Consumer subscription topic is invalid #590 (#598)

close #590

* Update eventmesh-store-quickstart.md

* Update README.md

* Add slack icon (#601)

* eventmesh-admin-rocketmq submodule and createTopic REST API (#530)

* eventmesh-admin-rocketmq submodule and createTopic draft API

* add license header

* change to /topicmanage

* fix build error

* fix some code check style issues

close #435 #346

* create topic command (#531)

* create topic command

* address review comments

* fix build and add createtopic method to standalone module

* fix build issue

* fix a few remaining code check issues

* fix test

close #346

* Update README.md

* Safely delete useless log4j dependencies

* Safely delete outdated metrics dependencies

* Sately delete useless collections4 dependency

* Safely delete useless commons dependencies

* Reback to the collections4, but let it not in api dependency

* Could not remove text for Safe Ramdom implementation

* Fix build error

* Add collection4

* Fix build error

* Revert "Safely delete outdated metrics dependencies"

This reverts commit 92287b0.

* Change to api dependency

* Remove doclint warnings

* Depracated checkstyle check error temporarily, we should remove it when we polish later

* Update .asf.yaml

* Update .asf.yaml

Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Wenjun Ruan <[email protected]>
Co-authored-by: Nicholas Zhan <[email protected]>
Co-authored-by: hagsyn <[email protected]>
Co-authored-by: sarihuangshanrong <[email protected]>
Co-authored-by: yuri <[email protected]>
Co-authored-by: vongosling <[email protected]>

* supply apache header

* Remove license name, add LICENSE file

* resolve conflict

* remove some not used in binary license

* set connector plugin to standalone

* Add license check shell

* Add jdk11 and otherOS in github ci

* Add comments

* resolve javadoc failed on jdk11

* Change skywalking uses repo to main

* GRPC producer publish API

* remove unused files

* remove unused plugin

* [ISSUE #630] RocketMQProducerImpl cannot load config properties from classpath (#631)

* Fix RocketMqConsumer cannot load properties in classpath
close #630

* [Bug #646] Missing the rocketmq message properties during protocol conversion (#647)

* [Bug #646] Missing the rocketmq message properties during protocol conversion

* fix checkstyle and gradle module dependency

* fix conflicts

close #646

* grpc publish with cloudevents

* [MINOR] Hide ctx in callback function and update contributing doc (#644)

1. Hide ctx in callback function
2. Resolve compile warning of loss spi
3. Update contributing doc
4.Remove codeql

* [ISSUE #405] remove some unused code (#649)

* [ISSUE #405] remove some unused code

* [Issue #417] grpc publish API

* [MINOR] Add third-part dependencies licenses (#650)

* [MINOR] supply the license and update the third party license file name (#653)

 [MINOR] supply the license and update the third party license file name

* [ISSUE #340]Add http trace http point (#527)

* tracing in AbstractHTTPServer

* add licence

* the span exporter

* design docs

* fix the error on text

* delete the useless dependence

* remove the unused code

* fix the different spanExporter

* change the class name

* fix gradle -build problem

* design docs improve

* fix the gradle.build error problem

* fixed

* unsure fix

* fix the path name

* fix check error

* format code

* add javadoc

* checkstyle fix

* unversioned files

* put context into channel in advance

* Update quick start docs (#656)

* [MINOR] Upgrade log4j version to 2.16.0 (#654)

* Update log4j version

* [MINOR] update the license and add the third party license files (#657)

* [MINOR] update the license and add the third party license files

* [ISSUE #604]Improve the rebalance algorithm (#605)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

* modify:remove unneccessary interface in eventmesh-connector-api

* modify:fix conflict

* modify:add license in EventMeshAction

* modify:fix ack problem

* modify:fix exception handle when exception occured in EventMeshTcpMessageDispatcher

* modify:fix log print

* modify: fix issue#496,ClassCastException

* modify: improve rebalance algorithm

close #604

* [Feature #547] Create and upload 1.3.0-snapshot docker image (#659)

* [Feature #547] Create and upload 1.3.0-snapshot docker image

* grpc consumer work

* [MINOR] Add third-part dependencies licenses (#650)

* [MINOR] supply the license and update the third party license file name (#653)

 [MINOR] supply the license and update the third party license file name

* [ISSUE #340]Add http trace http point (#527)

* tracing in AbstractHTTPServer

* add licence

* the span exporter

* design docs

* fix the error on text

* delete the useless dependence

* remove the unused code

* fix the different spanExporter

* change the class name

* fix gradle -build problem

* design docs improve

* fix the gradle.build error problem

* fixed

* unsure fix

* fix the path name

* fix check error

* format code

* add javadoc

* checkstyle fix

* unversioned files

* put context into channel in advance

* Update quick start docs (#656)

* [MINOR] Upgrade log4j version to 2.16.0 (#654)

* Update log4j version

* [MINOR] update the license and add the third party license files (#657)

* [MINOR] update the license and add the third party license files

* [ISSUE #604]Improve the rebalance algorithm (#605)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

* modify:remove unneccessary interface in eventmesh-connector-api

* modify:fix conflict

* modify:add license in EventMeshAction

* modify:fix ack problem

* modify:fix exception handle when exception occured in EventMeshTcpMessageDispatcher

* modify:fix log print

* modify: fix issue#496,ClassCastException

* modify: improve rebalance algorithm

close #604

* [Feature #547] Create and upload 1.3.0-snapshot docker image (#659)

* [Feature #547] Create and upload 1.3.0-snapshot docker image

* merge from develop

* GRPC producer publish API

* grpc publish with cloudevents

* Adding grpc publish and subscribe API examples

* grpc consumer api testing and bug fixing

* minor enhancement to grpc consumer

Co-authored-by: xwm1992 <[email protected]>
Co-authored-by: wangshaojie4039 <[email protected]>
Co-authored-by: wangshaojie <[email protected]>
Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Wenjun Ruan <[email protected]>
Co-authored-by: Nicholas Zhan <[email protected]>
Co-authored-by: hagsyn <[email protected]>
Co-authored-by: sarihuangshanrong <[email protected]>
Co-authored-by: yuri <[email protected]>
Co-authored-by: vongosling <[email protected]>
Co-authored-by: ZePeng Chen <[email protected]>
Co-authored-by: lrhkobe <[email protected]>
xwm1992 added a commit to xwm1992/EventMesh that referenced this issue Dec 27, 2021
* merge develop into 1.3.0 branch (apache#401)

* upgrade gradle to 6.8.3

* [ISSUE apache#265]rename wemq and access to eventmesh

* [ISSUE apache#265]rename proxy field to eventmesh

* merge conflict

* remove warn

* [ISSUE apache#265] Specification of code structure and file naming

* remove eventmesh-registry module

* enabled http/tcp monitor logs

* Update README.md

* Changed com.webank to org.apache

Changed 'eventmesh-connector-api' code package name to apache.

* issue apache#277:refactor eventmesh-common package with org.apache

* issue apache#277:rename package with org.apache

* Refactor 'eventmesh-connector-rocketmq' package name to org.apache

* Update README.zh-CN.md

* [ISSUE apache#282]Refactor 'eventmesh-starter' package name to org.apache

* Update codeStyle.xml

* Refactor 'eventmesh-test' package name to org.apache apache#283

* Refactor 'eventmesh-test' package name to org.apache apache#283

* Refactor 'eventmesh-test' package name to org.apache apache#283

* Refactor 'eventmesh-test' package name to org.apache apache#283

* Refactor 'eventmesh-test' package name to org.apache apache#283

* refactor runtime module package com.webank to org.apache

* refactor(eventmesh-sdk-java):rename to org.apache(apache#281)

* [ISSUE apache#281]refactor(eventmesh-sdk-java):rename to org.apache

* add licenses of apache for runtime module

* add NOTICE

* bugfix for event-mesh-test module

* change package name to org.apache

* format README.md

* change package name to org.apache

* fix ISSUE apache#296:add licenses in each source file under the eventmesh-sdk-java

* [ISSUE apache#294]add licenses in file under eventmesh-connector-rocketmq module

* [ISSUE apache#293]Lack of licenses in each source file under the eventmesh-connector-api module

* [ISSUE apache#298]Lack of licenses in each source file under the eventmesh-test module

* [ISSUE apache#297]Lack of licenses in each source file under the eventmesh-starter module

* Create .asf.yaml

* Update .asf.yaml

* Update .asf.yaml (apache#316)

* Update README.md

* Update .asf.yaml

* bugfix build.gradle tar task (apache#318)

Co-authored-by: jonyang(杨军) <[email protected]>

* [ISSUE apache#322] Rename package name "com.webank.eventmesh" to "org.apache.eventmesh" (apache#319)

* rename org.apache.runtime to com.webank.runtime

* rename com.webank.eventmesh to org.apache.eventmesh

* fix(docs): change the travis location

* Create DISCLAIMER-WIP

* Delete CNAME

* Delete _config.yml

* Delete package.json

* Add files via upload

* Add files via upload

* Delete eventmesh-multi-runtime.jpg

* Update README.md

* Update eventmesh-runtime-quickstart.md

* Update README.zh-CN.md

* Update eventmesh-runtime-quickstart.zh-CN.md

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository (apache#326)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* upgrade gradle to 7.0 and fix test bug. (apache#327)

* bugfix build.gradle tar task

* merge

* upgrade to gradle 7.0

* bugfix gradle task spotbugs

* bugfix eventmesh-connector-rocketmq testImplementation

* upgrade to gradle7.0

* refactor runtime module test and spotbugs error

* bugfix sign task

Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: jonyangx <[email protected]>

* remove unused files

Signed-off-by: qqeasonchen <[email protected]>

* update build.gradle and gradle.properties for publish to maven repository (apache#330)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* Update README.md

* Update README.zh-CN.md

* update quickstart md files for gradle version (apache#332)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* remove dead docs

Signed-off-by: qqeasonchen <[email protected]>

* [ISSUE apache#329]Missing Log4j dependency (apache#336)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE apache#329]Missing Log4j dependency

* [ISSUE apache#331] Fix dead links in docs (apache#334)

fixed apache#331

* Doc modification apache#328 (apache#335)

change vm params

* Update README.md

* [Issue apache#337] Fix Http Test Subscriber startup issue by moving the Thread.sleep into the child thread (apache#338)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

Co-authored-by: j00441484 <[email protected]>

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook (apache#343)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Address code review comment for Subscriber Demo App

Co-authored-by: j00441484 <[email protected]>

* [ISSUE apache#348] Setup automated workflows for greetings (apache#347)

* Setup automated workflows for greetings

* Remove '@apache/eventmesh-committers'

* Add LGTM Badges ISSUE#353 (apache#354)

LGTM is a variant analysis platform that automatically checks code for real CVEs and vulnerabilities. Learn more at https://lgtm.com/help/lgtm/about-lgtm .

Here are some alerts in our project reported by LGTM: https://lgtm.com/projects/g/apache/incubator-eventmesh/alerts/?mode=list

I'd like to add LGTM badges in the README.md, it makes easier for people who want to get alerts and then contribute to EventMesh.

* [ISSUE apache#355] Setup Github workflows for CodeQL scans (apache#356)

* Setup CodeQL scans

* disable autorun

* add a step for setting up JDK

* add codeql

* fix step Build

* fix strategy

* add events: schedule & workflow_dispatch

* [Issue apache#344] Fixing racing condition issue in SubscribeProcessor and UnSubscribeProcessor (apache#345)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#344] Fixing racing condition issue in SubscribeProcessor and UnSubscribeProcessor

* [Issue apache#344] Fix import statements

* [Issue apache#337] Address code review comment for Subscriber Demo App

* [Issue apache#344] Enhance client registration logic in SubscribeProcessor and UnsubscriberProcessor

* [Issue apache#344] Minor code clean up in SubscribeProcessor and UnsubscriberProcessor

* [Issue apache#344] Fix NullPointerException in ConsumerManager occurs during subscribe/unsunscribe iteration testing

* [Issue apache#344] Fix bugs in subscribe/unsunscribe code path

* [Issue apache#344] use client.pid instead of client.ip for client comparasion in UnSubscribeProcessor

Co-authored-by: j00441484 <[email protected]>

* update eventmesh-runtime.png (apache#358)

* update eventmesh-runtime.png

* [Issue apache#333] Support multiple load balance strategy in sdk (apache#342)

* Support multiple load balance strategy in sdk apache#333

* Fix ut

* add log

* update eventmesh-panels.png (apache#362)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE apache#329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

* update eventmesh-panels.png (apache#363)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE apache#329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

* Migrate CI to Github Actions and enable coverage report (apache#365)

* add: requirements for lightweight EventMesh SDK with CloudEvents (apache#370)

This commit only includes a brief introduction and requirements.
Design details can be followed up in a later commit.

Signed-off-by: Yuzhou Mao <[email protected]>

* Add files via upload

* Update README.md

* [Issue apache#368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer (apache#369)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Address code review comment for Subscriber Demo App

* [Issue apache#368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer

* [Issue apache#368] fix build issue

* [Issue apache#368] use try with resource statement for HttpClient

* [Issue apache#368] fix TLS1.1 and use TLS1.2 in HttpClient

Co-authored-by: j00441484 <[email protected]>

* [ISSUE apache#350]optimize flow control in downstreaming msg (apache#352)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* [ISSUE apache#380] Remove gitee-mirror.yml from Github workflows (apache#381)

* Update README.md

* [ISSUE apache#310] add github action for check license (apache#313)

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

* [ISSUE apache#310] Enable Github Actions for license check and fix license headers (apache#377)

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

* enable github actions for license check

* add necessary headers

* update badges

Co-authored-by: Lan Liang <[email protected]>

* [Issue apache#382] Fix java.lang.NumberFormatException when parsing Long (apache#383)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Address code review comment for Subscriber Demo App

* [Issue apache#368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer

* [Issue apache#368] fix build issue

* [Issue apache#368] use try with resource statement for HttpClient

* [Issue apache#368] fix TLS1.1 and use TLS1.2 in HttpClient

* [Issue apache#382] Fix java.lang.NumberFormatException when parsing Long

* [Issue apache#382] Fix java.lang.NumberFormatException when parsing Integer

Co-authored-by: j00441484 <[email protected]>

* [ISSUE apache#378] downstream broadcast msg asynchronously  (apache#379)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

closed apache#378

* [ISSUE apache#359] Split handler from controller (apache#359) (apache#360)

* [ISSUE apache#359] Split handler from controller (apache#359)

* add license header

* add ut

* [ISSUE apache#384] RedirectClientByIpPortHandlerTest.java doesn't have the Apache license header (apache#385)

close apache#384

* Update README.md

* Update README.zh-CN.md

* Update README.zh-CN.md

* Update README.zh-CN.md

* [Issue apache#386] fixing ConsumerGroup Queue Consumer Offset not synced up issue (apache#387)

* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Address code review comment for Subscriber Demo App

* [Issue apache#386] fixing ConsumerGroup Queuen Consumer Offset not synced up issue

* [Issue apache#386] adding license header to new file

* [Issue apache#386] Fix license header missing issue

Co-authored-by: j00441484 <[email protected]>

* [ISSUE apache#366 ] remove custom-format topic concept (apache#388)

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* [ISSUE apache#366] remove custom concept [dcn&&region] (apache#390)

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

close apache#366

* [ISSUE apache#391] Optimize interface design in eventmesh-connector-api (apache#392)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

* modify:remove unneccessary interface in eventmesh-connector-api

* modify:fix conflict

* modify:add license in EventMeshAction
close apache#391

* miss group name set for userAgent (apache#395)

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* bugfix : miss group set

* bugfix : miss group set

* [ISSUE apache#393]:perf topic name in test file (apache#394)

close apache#393

* support unsubscribe topics while delconsumer in http mode (apache#396)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE apache#329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

* [ISSUE apache#397]Remove subscription session failed error (apache#398)

* [ISSUE apache#325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE apache#329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

* [ISSUE apache#397]Remove subscription session failed error

* [ISSUE apache#397]Remove subscription session failed error
close apache#397

Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: MajorHe1 <[email protected]>
Co-authored-by: mike_xwm <[email protected]>
Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Heng Du <[email protected]>
Co-authored-by: Udesh Liyanaarachchi <>
Co-authored-by: keranbingaa <[email protected]>
Co-authored-by: sunxi <[email protected]>
Co-authored-by: sanchen <[email protected]>
Co-authored-by: surilli(李慧敏) <[email protected]>
Co-authored-by: Lan Liang <[email protected]>
Co-authored-by: zhangxiaopengmm <[email protected]>
Co-authored-by: nanoxiong <[email protected]>
Co-authored-by: chenyi19851209 <[email protected]>
Co-authored-by: yangjun <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: von gosling <[email protected]>
Co-authored-by: jonyangx <[email protected]>
Co-authored-by: ruanwenjun <[email protected]>
Co-authored-by: jinrongluo <[email protected]>
Co-authored-by: j00441484 <[email protected]>
Co-authored-by: Yuzhou Mao <[email protected]>
Co-authored-by: lrhkobe <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: Lan <[email protected]>

* [ISSUE apache#411] Enable CI workflows running on [0-9]+.[0-9]+.[0-9]+** branches (apache#413)

* [Issues apache#405]code polish and fix typo (apache#404)

* code polish and fix typo

* merge remote 1.3.0

* [ISSUE apache#374] Add unit test class. (apache#402)

* [ISSUE apache#374] add unit test for LiteMessage class.

* [ISSUE apache#374] add unit test for HttpCommand class.

* [ISSUE apache#374] add unit test for httpResponse method with REQ cmd type.

* [ISSUE-apache#374] Add unit test class. (apache#414)

* [ISSUE apache#374] add unit test for CommonConfiguration class.

* [ISSUE apache#374] add unit test for ConfigurationWraper class.

* [ISSUE apache#374] add unit test for Weight class.

* [ISSUE apache#374] add unit test for CommonConfiguration class.

* [ISSUE apache#367]Enhance SPI plugins (apache#419)

* [ISSUE apache#374] add unit test for http protocol header client class. (apache#420)

* fix typo (apache#423)

* [ISSUE apache#418]Refactor the plugin load code (apache#421)

* [ISSUE apache#418]Refactor the plugin load code

* fix ut

* [ISSUE apache#405]modify the doc (apache#424)

* modify the doc

* modify the doc

* Merege 1.3.0 to develop.

* Merege 1.3.0 to develop.

* Merge 1.3.0 to develop, fix check style problem.

Co-authored-by: wqliang <[email protected]>
Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: MajorHe1 <[email protected]>
Co-authored-by: mike_xwm <[email protected]>
Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Heng Du <[email protected]>
Co-authored-by: keranbingaa <[email protected]>
Co-authored-by: sunxi <[email protected]>
Co-authored-by: sanchen <[email protected]>
Co-authored-by: surilli(李慧敏) <[email protected]>
Co-authored-by: Lan Liang <[email protected]>
Co-authored-by: zhangxiaopengmm <[email protected]>
Co-authored-by: nanoxiong <[email protected]>
Co-authored-by: chenyi19851209 <[email protected]>
Co-authored-by: yangjun <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: von gosling <[email protected]>
Co-authored-by: jonyangx <[email protected]>
Co-authored-by: ruanwenjun <[email protected]>
Co-authored-by: jinrongluo <[email protected]>
Co-authored-by: j00441484 <[email protected]>
Co-authored-by: Yuzhou Mao <[email protected]>
Co-authored-by: lrhkobe <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: Lan <[email protected]>
Co-authored-by: YuDong Tang <[email protected]>
xwm1992 pushed a commit to xwm1992/EventMesh that referenced this issue Dec 27, 2021
* [Issue apache#337] Fix HttpSubscriber startup issue

* [Issue apache#337] test commit

* [Issue apache#337] revert test commit

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue apache#337] Address code review comment for Subscriber Demo App

* Fix subscriptionType typo

Co-authored-by: j00441484 <[email protected]>
xwm1992 added a commit to xwm1992/EventMesh that referenced this issue Dec 27, 2021
xwm1992 pushed a commit that referenced this issue Jan 4, 2022
[Minor #405] update cloudevents examples
@qqeasonchen qqeasonchen changed the title [Enhancement] Looking for code hero for Apache EventMesh [Task List] Looking for Code Hero for Apache EventMesh Jan 7, 2022
@xwm1992 xwm1992 linked a pull request Jan 10, 2022 that will close this issue
xwm1992 pushed a commit that referenced this issue Jan 10, 2022
@qqeasonchen qqeasonchen reopened this Jan 10, 2022
xwm1992 added a commit that referenced this issue Apr 7, 2022
* update project version to 1.3.0-RELEASE

* Delete gradle/wrapper directory

* update docs

* update Dockerfile and build.gradle

* update build.gradle

* update Dockerfile path

* Update .asf.yaml

disabled protected branch

(cherry picked from commit 4b60e37)

* Update .asf.yaml

(cherry picked from commit a051d06)

* [Infra] trigger branch protection change

(cherry picked from commit d9a9a5b)

* [Infra] retrigger .asf.yaml protections

(cherry picked from commit 8e5a196)

* update some docs

Signed-off-by: qqeasonchen <[email protected]>
(cherry picked from commit faf1fc1)

* update Dockerfile path

(cherry picked from commit 2790b78)

* Update java sdk docs (#663)


(cherry picked from commit 56b665b)

* Add files via upload

add pluggable-protocols.png

(cherry picked from commit ce62aa0)

* [Infra] retrigger .asf.yaml protections

(cherry picked from commit 8e5a196)

* Update .asf.yaml

make the master branch under the protected

* [ISSUE #670] fix checkstyle check fail (#680)

fix checkstyle check fail

* [MINOR] Fixed redundant boxing operations (#684)

* [MINOR] new Runnable() can be replaced with lambda (#685)

* gradle

* Anonymous new Runnable() can be replaced with lambda

* Anonymous new Runnable() can be replaced with lambda

* add logger print exception

* [MINOR] ConfigurationWrapper class adds thread pool shutdown (#683)

* gradle

* ConfigurationWrapper class adds thread pool shutdown

* [ISSUE #677] Translate readme files from English to Chinese (#678)

* translate English to Chinese
close #677

* [ISSUE #405]update cloudevents examples (#688)

[Minor #405] update cloudevents examples

* Bump gradle version to 7.3.3 Support Java17 build

* [ISSUE #690]Remove extra code style check job in CI (#691)

Close ISSUE #690.

* Update intro.md (#693)

* Add files via upload (#694)

* [ISSUE #692]Change the default merge strategy to squash (#695)

* Change the default merge strategy to squash
close #692

* [ISSUE #673] update eventmesh-runtime-quickstart-with-docker.md en & cn (#698)

* update eventmesh-runtime-quickstart-with-docker.md en & cn
close #673

* [MINOR] Change Tar and Zip name (#699)

* [Issue #702] Fix Slack Join link (#705)

close #702

* Updated Notice file to 2022 (#704)

* add instruction docs of trace and metrics in eventmesh (#706)

* [ISSUE #405]Fix args typo in examples (#707)

fixed #405

* [ISSUE #696] Add metrics plugin (#709)

1. Add Metrics plugin module
2. Implement opentelemetry metrics module
related issue #696

* [ISSUE #713] Fix trace bug (#712)

* add docs

* change default spanExporter to span

* [Issue #533] Adding design doc for EventMesh Workflow

* [Issue #553] Adding design doc for EventMesh Workflow (#714)

* [Issue #553] update the design doc.

* small updates to doc

Signed-off-by: Tihomir Surdilovic <[email protected]>

* small update

Signed-off-by: Tihomir Surdilovic <[email protected]>

* adding asyncapi type to event defs

Signed-off-by: Tihomir Surdilovic <[email protected]>

* Remove unnecessary call toString (#719)

* [Issue #553] add workflow diagram to the design doc

* Update intro.md (#722)

* Update roadmap.md (#721)

* Missed exception cause (#724)

close #727

* [ISSUE #726] Remove the misleading annotation (#725)

close #726

* [ISSUE #729] Bump netty version (#730)

* Bump netty version
close #729

* [ISSUE #732] Binary package failed to execute (#733)

close #732

* [Issue #735] log4j 2.17.1 (#736)

* log4j 2.17.1

* Update known-dependencies.txt

* Update LICENSE

* fix item mislabeled as MIT when they are ASL

* fix log4j urls https://logging.apache.org/log4j/2.x/log4j-slf4j-impl/license.html

* [MINOR] Remove the unnecessary boxing (#731)

* Use archiveBaseName and archiveVersion to optimize gradle zip task (#728)

* Add environment and version selector in bug_report.yml (#734)

* Fix bug report template (#741)

* add eventmesh-admin-rocketmq into rootProject

* [ISSUE #737] Add Netty license (#738)

close #737

* [Issue #750] junit should only be used in tests (#751)

* junit should only be used in tests

add back assertj

revert assertj changes

build issues

centralise junit dependency

Update build.gradle

* junit 4.12 has a CVE

close #750

* [Issue #752] upgrade httpclient (#753)

* upgrade httpclient

* commons-codec transitive dependency upgrade

close #752

* [Issue-754] upgrade guava (#757)

* upgrade guava

* [Issue #758] validate subscriber Url (#759)

* [Issue #758] validate subscriber Url

* [Issue #758] fix build issue

* [Issue #758] fix checkstyle issue

* [Issue #758] fix license check issue
close #758

* [Issue #655] Adding send message constraints for message size and batch size (#760)

* [Issue #655] Adding send message constraints for message size and batch size

* [MINOR] Fix plugin cannot load properties from classpath (#763)

* [MINOR] Fix plugin cannot load properties from classpath

* Fix callback warning

* [MINOR] Remove unused field in example (#766)

* [MINOR] Allow run script in other directory (#765)

* [MINOR] Fix the hardcode ip address (#767)

* [Issue #768] fix issue in update HTTP subscriber (#769)

* [Issue #768] fix issue in update HTTP subscriber

* [Issue #769] use Serialization to deep clone object and adding equals method to SubscriptionItem

* [Issue #768] fix build checkstyle issue

close #768

* update checkstyle.xml (#773)

add suppresswarnings filter

* Rebase the grpc branch to master branch (#771)

* [Issue #417] Grpc Transport Protocol support (#710)

Grpc Transport Protocol support

* [Issue #417] Create getting started instructions for Grpc transport procotol

* [Issue #417] update Grpc Message Model name to SimpleMessage

* [Issue #417] more update Grpc Message Model name to SimpleMessage

* [Issue #718] Fix readme file and protobuf file based on review comments

* [Issue #745] fix the ack bugs and cloudevent message resolver

* [Issue #744] update SDK API message model

* [Issue #744] fix the gRPC Consumer SubscribeStream Message handler

* [Issue #744] Grpc Request-Reply API support

* [Issue #744] Bug fix for Grpc Request-Reply API support

* [Issue #744] minor fix for Grpc request-Reply API

* [Issue #744] fix infinte message loop in Grpc CloudEvent request-Reply API

* [Issue #744] Fix Grpc subscribe-unsubscribe bug

* [Issue #744] Fix Data models in Grpc Request-Reply API

* [Issue #744] Code optimization for Grpc Request-Reply API

* [Issue #417] support Grpc broadcast async publish

* [Issue #718] add synchronized calls for grpc streamObserver

* supply apache header

* add checkstyle ignore for grpc

* fix checkstyle error

* fix javax.annotation.generated compile error

* fix javax.annotation.generated compile error

* supply dependencies licenses

* update known-dependencies.txt

* update known-dependencies.txt

Co-authored-by: jinrongluo <[email protected]>

* [Issue #774] Optimize the object property description of eventmesh client (#775)

* modify: add group field in UserAgent, delete ProducerGroup and ConsumerGroup field

* modify: fix checksyle error

* modify: fix checksyle error in ClientGroupWrapper.java

close #774

* Update roadmap.md (#779)

* [Issue #780] Modify the define level  of EventListener from Topic to Consumer (#781)

* modify: add group field in UserAgent, delete ProducerGroup and ConsumerGroup field

* modify: fix checksyle error

* modify: fix checksyle error in ClientGroupWrapper.java

* modify: move EventListner in the level of Consumer instead of binding with topic in EventMesh

* modify: fix the eventListener level problem in grpc protocal

* modify: fix the eventListener problem in test case

close #780

* [ISSUE #786] remove eventmesh-sdk-java model redundant code (#789)

Co-authored-by: lucky-lsr <[email protected]>
close #786

* Update roadmap.md (#791)

* [ISSUE #783] clean useless code in runtime module (#787)

* [ISSUE #783] clean useless code in runtime module

* format code

close #783

* [ISSUE #696] Add trace plugin (#749)

* add docs

* add trace plugin

* fix ConfigurationWrapperTest error

* fix checkstyle

* fix checkstyle

* [ISSUE #784] Fix words misspell, optimize admin http method code (#792)

close #784

* [Issue #658] Eventmesh Http Support CloudEvents Webhook spec (#772)

* [Issue #658] support CloudEvents Webhook spec

* [Issue #658] create auth-http-basic security module

* [Issue #658] create auth-http-basic security module

* [Issue #658] code refactor for CloudEvents Webhook

* [Issue #658] fix build checkstyles

* [Issue #658] fix javadoc build issue

* [Issue #658] fix javadoc build issue in eventmesh-security-auth-http-basic

* [Issue #658] adding more log to the WebhookUtil

* [Issue #658] address PR review comments.

* [Issue #658] fixed checkstyles issue

Co-authored-by: mike_xwm <[email protected]>

* [ISSUE #782] delete invalid code in eventmesh-connector-plugin module (#793)

* [ISSUE #795] Fix doc eventmesh-runtime-quickstart-with-docker.md (#798)

close #795

* [Enhancement] Some suggestions for eventmesh-examples (#794)

* remove invalid code

* read config from file

* extract constants

* format code

close #794

* [Enhancement] compile project with junit error (#802)

Co-authored-by: ylong <[email protected]>
close #796

* [Enhancement] Run CI on all branch (#805)

* [MINOR] sort dependencise before check (#808)

* [ISSUE #806] code optimization and delete invalid code in eventmesh-e… (#807)

* [ISSUE #806] code optimization and delete invalid code in eventmesh-examples module

* use ExampleConstants to hold constants in examples
* delete invalid code

* [ISSUE #806] code optimization and delete invalid code in eventmesh-examples module

Motivation
Code style consistency in log msg

Co-authored-by: fengyongshe <[email protected]>

close #806

Co-authored-by: xwm1992 <[email protected]>
Co-authored-by: Daniel Gruno <[email protected]>
Co-authored-by: qqeasonchen <[email protected]>
Co-authored-by: Wenjun Ruan <[email protected]>
Co-authored-by: yangjun <[email protected]>
Co-authored-by: 李晓双 Li Xiao Shuang <[email protected]>
Co-authored-by: Shoothzj <[email protected]>
Co-authored-by: Junjie Zhou <[email protected]>
Co-authored-by: ZePeng Chen <[email protected]>
Co-authored-by: jinrongluo <[email protected]>
Co-authored-by: Tihomir Surdilovic <[email protected]>
Co-authored-by: PJ Fanning <[email protected]>
Co-authored-by: wqliang <[email protected]>
Co-authored-by: lrhkobe <[email protected]>
Co-authored-by: lucky-lsr <[email protected]>
Co-authored-by: sarihuangshanrong <[email protected]>
Co-authored-by: TownChen <[email protected]>
Co-authored-by: AhahaGe <[email protected]>
Co-authored-by: SpiritZhang <[email protected]>
Co-authored-by: like <[email protected]>
Co-authored-by: [email protected] <[email protected]>
Co-authored-by: fengyongshe <[email protected]>
xwm1992 added a commit that referenced this issue Aug 4, 2022
* merge develop into 1.3.0 branch (#401)

* upgrade gradle to 6.8.3

* [ISSUE #265]rename wemq and access to eventmesh

* [ISSUE #265]rename proxy field to eventmesh

* merge conflict

* remove warn

* [ISSUE #265] Specification of code structure and file naming

* remove eventmesh-registry module

* enabled http/tcp monitor logs

* Update README.md

* Changed com.webank to org.apache

Changed 'eventmesh-connector-api' code package name to apache.

* issue #277:refactor eventmesh-common package with org.apache

* issue #277:rename package with org.apache

* Refactor 'eventmesh-connector-rocketmq' package name to org.apache

* Update README.zh-CN.md

* [ISSUE #282]Refactor 'eventmesh-starter' package name to org.apache

* Update codeStyle.xml

* Refactor 'eventmesh-test' package name to org.apache #283

* Refactor 'eventmesh-test' package name to org.apache #283

* Refactor 'eventmesh-test' package name to org.apache #283

* Refactor 'eventmesh-test' package name to org.apache #283

* Refactor 'eventmesh-test' package name to org.apache #283

* refactor runtime module package com.webank to org.apache

* refactor(eventmesh-sdk-java):rename to org.apache(#281)

* [ISSUE #281]refactor(eventmesh-sdk-java):rename to org.apache

* add licenses of apache for runtime module

* add NOTICE

* bugfix for event-mesh-test module

* change package name to org.apache

* format README.md

* change package name to org.apache

* fix ISSUE #296:add licenses in each source file under the eventmesh-sdk-java

* [ISSUE #294]add licenses in file under eventmesh-connector-rocketmq module

* [ISSUE #293]Lack of licenses in each source file under the eventmesh-connector-api module

* [ISSUE #298]Lack of licenses in each source file under the eventmesh-test module

* [ISSUE #297]Lack of licenses in each source file under the eventmesh-starter module

* Create .asf.yaml

* Update .asf.yaml

* Update .asf.yaml (#316)

* Update README.md

* Update .asf.yaml

* bugfix build.gradle tar task (#318)

Co-authored-by: jonyang(杨军) <[email protected]>

* [ISSUE #322] Rename package name "com.webank.eventmesh" to "org.apache.eventmesh" (#319)

* rename org.apache.runtime to com.webank.runtime

* rename com.webank.eventmesh to org.apache.eventmesh

* fix(docs): change the travis location

* Create DISCLAIMER-WIP

* Delete CNAME

* Delete _config.yml

* Delete package.json

* Add files via upload

* Add files via upload

* Delete eventmesh-multi-runtime.jpg

* Update README.md

* Update eventmesh-runtime-quickstart.md

* Update README.zh-CN.md

* Update eventmesh-runtime-quickstart.zh-CN.md

* [ISSUE #325]Update gradle configuration for publishing package to maven repository (#326)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* upgrade gradle to 7.0 and fix test bug. (#327)

* bugfix build.gradle tar task

* merge

* upgrade to gradle 7.0

* bugfix gradle task spotbugs

* bugfix eventmesh-connector-rocketmq testImplementation

* upgrade to gradle7.0

* refactor runtime module test and spotbugs error

* bugfix sign task

Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: jonyangx <[email protected]>

* remove unused files

Signed-off-by: qqeasonchen <[email protected]>

* update build.gradle and gradle.properties for publish to maven repository (#330)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* Update README.md

* Update README.zh-CN.md

* update quickstart md files for gradle version (#332)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* remove dead docs

Signed-off-by: qqeasonchen <[email protected]>

* [ISSUE #329]Missing Log4j dependency (#336)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE #329]Missing Log4j dependency

* [ISSUE #331] Fix dead links in docs (#334)

fixed #331

* Doc modification #328 (#335)

change vm params

* Update README.md

* [Issue #337] Fix Http Test Subscriber startup issue by moving the Thread.sleep into the child thread (#338)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

Co-authored-by: j00441484 <[email protected]>

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook (#343)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Address code review comment for Subscriber Demo App

Co-authored-by: j00441484 <[email protected]>

* [ISSUE #348] Setup automated workflows for greetings (#347)

* Setup automated workflows for greetings

* Remove '@apache/eventmesh-committers'

* Add LGTM Badges ISSUE#353 (#354)

LGTM is a variant analysis platform that automatically checks code for real CVEs and vulnerabilities. Learn more at https://lgtm.com/help/lgtm/about-lgtm .

Here are some alerts in our project reported by LGTM: https://lgtm.com/projects/g/apache/incubator-eventmesh/alerts/?mode=list

I'd like to add LGTM badges in the README.md, it makes easier for people who want to get alerts and then contribute to EventMesh.

* [ISSUE #355] Setup Github workflows for CodeQL scans (#356)

* Setup CodeQL scans

* disable autorun

* add a step for setting up JDK

* add codeql

* fix step Build

* fix strategy

* add events: schedule & workflow_dispatch

* [Issue #344] Fixing racing condition issue in SubscribeProcessor and UnSubscribeProcessor (#345)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #344] Fixing racing condition issue in SubscribeProcessor and UnSubscribeProcessor

* [Issue #344] Fix import statements

* [Issue #337] Address code review comment for Subscriber Demo App

* [Issue #344] Enhance client registration logic in SubscribeProcessor and UnsubscriberProcessor

* [Issue #344] Minor code clean up in SubscribeProcessor and UnsubscriberProcessor

* [Issue #344] Fix NullPointerException in ConsumerManager occurs during subscribe/unsunscribe iteration testing

* [Issue #344] Fix bugs in subscribe/unsunscribe code path

* [Issue #344] use client.pid instead of client.ip for client comparasion in UnSubscribeProcessor

Co-authored-by: j00441484 <[email protected]>

* update eventmesh-runtime.png (#358)

* update eventmesh-runtime.png

* [Issue #333] Support multiple load balance strategy in sdk (#342)

* Support multiple load balance strategy in sdk #333

* Fix ut

* add log

* update eventmesh-panels.png (#362)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

* update eventmesh-panels.png (#363)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

* Migrate CI to Github Actions and enable coverage report (#365)

* add: requirements for lightweight EventMesh SDK with CloudEvents (#370)

This commit only includes a brief introduction and requirements.
Design details can be followed up in a later commit.

Signed-off-by: Yuzhou Mao <[email protected]>

* Add files via upload

* Update README.md

* [Issue #368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer (#369)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Address code review comment for Subscriber Demo App

* [Issue #368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer

* [Issue #368] fix build issue

* [Issue #368] use try with resource statement for HttpClient

* [Issue #368] fix TLS1.1 and use TLS1.2 in HttpClient

Co-authored-by: j00441484 <[email protected]>

* [ISSUE #350]optimize flow control in downstreaming msg (#352)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* [ISSUE #380] Remove gitee-mirror.yml from Github workflows (#381)

* Update README.md

* [ISSUE #310] add github action for check license (#313)

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

* [ISSUE #310] Enable Github Actions for license check and fix license headers (#377)

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

* enable github actions for license check

* add necessary headers

* update badges

Co-authored-by: Lan Liang <[email protected]>

* [Issue #382] Fix java.lang.NumberFormatException when parsing Long (#383)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Address code review comment for Subscriber Demo App

* [Issue #368] Fix Racing condition and memory leak issue in EventMesh SDK LiteConsumer and LiteProducer

* [Issue #368] fix build issue

* [Issue #368] use try with resource statement for HttpClient

* [Issue #368] fix TLS1.1 and use TLS1.2 in HttpClient

* [Issue #382] Fix java.lang.NumberFormatException when parsing Long

* [Issue #382] Fix java.lang.NumberFormatException when parsing Integer

Co-authored-by: j00441484 <[email protected]>

* [ISSUE #378] downstream broadcast msg asynchronously  (#379)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

closed #378

* [ISSUE #359] Split handler from controller (#359) (#360)

* [ISSUE #359] Split handler from controller (#359)

* add license header

* add ut

* [ISSUE #384] RedirectClientByIpPortHandlerTest.java doesn't have the Apache license header (#385)

close #384

* Update README.md

* Update README.zh-CN.md

* Update README.zh-CN.md

* Update README.zh-CN.md

* [Issue #386] fixing ConsumerGroup Queue Consumer Offset not synced up issue (#387)

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Address code review comment for Subscriber Demo App

* [Issue #386] fixing ConsumerGroup Queuen Consumer Offset not synced up issue

* [Issue #386] adding license header to new file

* [Issue #386] Fix license header missing issue

Co-authored-by: j00441484 <[email protected]>

* [ISSUE #366 ] remove custom-format topic concept (#388)

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* [ISSUE #366] remove custom concept [dcn&&region] (#390)

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

close #366

* [ISSUE #391] Optimize interface design in eventmesh-connector-api (#392)

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

* modify:remove unneccessary interface in eventmesh-connector-api

* modify:fix conflict

* modify:add license in EventMeshAction
close #391

* miss group name set for userAgent (#395)

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* bugfix : miss group set

* bugfix : miss group set

* [ISSUE #393]:perf topic name in test file (#394)

close #393

* support unsubscribe topics while delconsumer in http mode (#396)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

* [ISSUE #397]Remove subscription session failed error (#398)

* [ISSUE #325]Update gradle configuration for publishing package to maven repository

* update build.gradle

* update build.gradle and gradle.properties

* update build.gradle and gradle.properties for publish to maven repository

* * update gradle version for instructions
* fix: dist task exception

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

* [ISSUE #397]Remove subscription session failed error

* [ISSUE #397]Remove subscription session failed error
close #397

Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: MajorHe1 <[email protected]>
Co-authored-by: mike_xwm <[email protected]>
Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Heng Du <[email protected]>
Co-authored-by: Udesh Liyanaarachchi <>
Co-authored-by: keranbingaa <[email protected]>
Co-authored-by: sunxi <[email protected]>
Co-authored-by: sanchen <[email protected]>
Co-authored-by: surilli(李慧敏) <[email protected]>
Co-authored-by: Lan Liang <[email protected]>
Co-authored-by: zhangxiaopengmm <[email protected]>
Co-authored-by: nanoxiong <[email protected]>
Co-authored-by: chenyi19851209 <[email protected]>
Co-authored-by: yangjun <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: von gosling <[email protected]>
Co-authored-by: jonyangx <[email protected]>
Co-authored-by: ruanwenjun <[email protected]>
Co-authored-by: jinrongluo <[email protected]>
Co-authored-by: j00441484 <[email protected]>
Co-authored-by: Yuzhou Mao <[email protected]>
Co-authored-by: lrhkobe <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: Lan <[email protected]>

* [ISSUE #411] Enable CI workflows running on [0-9]+.[0-9]+.[0-9]+** branches (#413)

* [Issues #405]code polish and fix typo (#404)

* code polish and fix typo

* merge remote 1.3.0

* [ISSUE #374] Add unit test class. (#402)

* [ISSUE #374] add unit test for LiteMessage class.

* [ISSUE #374] add unit test for HttpCommand class.

* [ISSUE #374] add unit test for httpResponse method with REQ cmd type.

* [ISSUE-#374] Add unit test class. (#414)

* [ISSUE #374] add unit test for CommonConfiguration class.

* [ISSUE #374] add unit test for ConfigurationWraper class.

* [ISSUE #374] add unit test for Weight class.

* [ISSUE #374] add unit test for CommonConfiguration class.

* [ISSUE #367]Enhance SPI plugins (#419)

* [ISSUE #374] add unit test for http protocol header client class. (#420)

* fix typo (#423)

* [ISSUE #418]Refactor the plugin load code (#421)

* [ISSUE #418]Refactor the plugin load code

* fix ut

* [ISSUE #405]modify the doc (#424)

* modify the doc

* modify the doc

* Merege 1.3.0 to develop.

* Merege 1.3.0 to develop.

* Merge 1.3.0 to develop, fix check style problem.

Co-authored-by: wqliang <[email protected]>
Co-authored-by: jonyang(杨军) <[email protected]>
Co-authored-by: MajorHe1 <[email protected]>
Co-authored-by: mike_xwm <[email protected]>
Co-authored-by: Eason Chen <[email protected]>
Co-authored-by: Heng Du <[email protected]>
Co-authored-by: keranbingaa <[email protected]>
Co-authored-by: sunxi <[email protected]>
Co-authored-by: sanchen <[email protected]>
Co-authored-by: surilli(李慧敏) <[email protected]>
Co-authored-by: Lan Liang <[email protected]>
Co-authored-by: zhangxiaopengmm <[email protected]>
Co-authored-by: nanoxiong <[email protected]>
Co-authored-by: chenyi19851209 <[email protected]>
Co-authored-by: yangjun <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: von gosling <[email protected]>
Co-authored-by: jonyangx <[email protected]>
Co-authored-by: ruanwenjun <[email protected]>
Co-authored-by: jinrongluo <[email protected]>
Co-authored-by: j00441484 <[email protected]>
Co-authored-by: Yuzhou Mao <[email protected]>
Co-authored-by: lrhkobe <[email protected]>
Co-authored-by: Steve Yurong Su <[email protected]>
Co-authored-by: Lan <[email protected]>
Co-authored-by: YuDong Tang <[email protected]>
xwm1992 pushed a commit that referenced this issue Aug 4, 2022
* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Enhance Http Demo Subscriber by using ExecutorService, CountDownLatch and PreDestroy hook

* [Issue #337] Address code review comment for Subscriber Demo App

* Fix subscriptionType typo

Co-authored-by: j00441484 <[email protected]>
xwm1992 added a commit that referenced this issue Aug 4, 2022
* [ISSUE #405] remove some unused code
xwm1992 pushed a commit that referenced this issue Aug 4, 2022
[Minor #405] update cloudevents examples
@xwm1992 xwm1992 closed this as completed in e7edf59 Aug 4, 2022
@xwm1992 xwm1992 reopened this Aug 9, 2022
@qqeasonchen qqeasonchen unpinned this issue May 6, 2023
@Pil0tXia
Copy link
Member

Superseded by #3873

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
improvement Improve the mechanism or performance kind
Projects
None yet
Development

Successfully merging a pull request may close this issue.

3 participants