Http.demo Subscriber is not working in EventMesh-test project #337
Labels
bug
Something isn't working
Comments
jinrongluo
pushed a commit
to jinrongluo/incubator-eventmesh
that referenced
this issue
May 10, 2021
|
I have a fix for this issue, the PR is here |
jinrongluo
added a commit
to jinrongluo/incubator-eventmesh
that referenced
this issue
May 10, 2021
jinrongluo
added a commit
to jinrongluo/incubator-eventmesh
that referenced
this issue
May 10, 2021
xwm1992
pushed a commit
that referenced
this issue
May 11, 2021
…ead.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]>
@jinrongluo Please refer to the modification suggestion of vongosling and put forward another pull request to modify this problem, thank you |
jinrongluo
added a commit
to jinrongluo/incubator-eventmesh
that referenced
this issue
May 11, 2021
…ice, CountDownLatch and PreDestroy hook
jinrongluo
added a commit
to jinrongluo/incubator-eventmesh
that referenced
this issue
May 11, 2021
…ice, CountDownLatch and PreDestroy hook
Hi @xwm1992 I have created new PR to address the comment above. Thanks. PR - #343 |
jinrongluo
added a commit
to jinrongluo/incubator-eventmesh
that referenced
this issue
May 12, 2021
xwm1992
pushed a commit
that referenced
this issue
May 14, 2021
…ountDownLatch 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]>
xwm1992
pushed a commit
that referenced
this issue
May 19, 2021
…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]>
xwm1992
pushed a commit
that referenced
this issue
May 31, 2021
…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]>
xwm1992
pushed a commit
that referenced
this issue
Jun 9, 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 * [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]>
xwm1992
pushed a commit
that referenced
this issue
Jun 16, 2021
… 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]>
xwm1992
added a commit
that referenced
this issue
Jun 26, 2021
* 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&®ion] (#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 * update 1.2.0-release branch code Co-authored-by: Eason Chen <[email protected]> Co-authored-by: Steve Yurong Su <[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: Lan Liang <[email protected]> Co-authored-by: nanoxiong <[email protected]> Co-authored-by: keranbingaa <[email protected]>
xwm1992
added a commit
that referenced
this issue
Jun 28, 2021
* 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&®ion] (#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 * update 1.2.0-release branch code * update 1.2.0-release branch code Co-authored-by: Eason Chen <[email protected]> Co-authored-by: Steve Yurong Su <[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: Lan Liang <[email protected]> Co-authored-by: nanoxiong <[email protected]> Co-authored-by: keranbingaa <[email protected]>
xwm1992
added a commit
that referenced
this issue
Jun 28, 2021
* 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&®ion] (#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]>
xwm1992
added a commit
that referenced
this issue
Jun 29, 2021
* Update gitee-mirror.yml * [issue #176]Support Spi for extended implementation to accommodate a variety of MQ * update moudles * event mesh project architecture adjustment * update rocketmq plugin impl * update rocketmq plugin impl remove unused code * fix configurationWraper miss load * update RocketMQConsumerImpl and PushConsumerImpl supply get defaultPushConsumer * update RocketMQProducerImpl and MQProducerWrapper supply get defaultMQProducer * 1.add module eventmesh-connector-api 2.change runtime and connector dependency * modify:add defibus plugin * 1.support rocketmq-connector plugin 2.modify eventmesh-runtime imported classes from eventmesh-common * 1.modify MQConsumerWrapper import ProxyConstants * 1.support rocketmq-connector plugin 2.modify eventmesh-runtime imported classes from eventmesh-common * 1.support rocketmq-connector plugin 2.modify eventmesh-runtime imported classes from eventmesh-common * gradle config modify * eventmesh-api modify * eventmesh-connector-defibus modify:rename package, plugin impl * eventmesh-runtime modify,delete rocketmq dependency * 1.move rocketmq dependency from eventmesh-runtime to eventmesh-connector-rocketmq 2.modify http processor * 1.move rocketmq dependency from eventmesh-runtime to eventmesh-connector-rocketmq 2.modify http processor 3.modify http subscribe * 1.update connector-rocketmq version 2.change the directory structure 3.add starter module * 1.change starter version * 1.update root module version * 1.eventmesh-api modify methodName 2.eventmesh-connector modify relative method impl 3.attribute store place modify in msgConvert * remove dependency of eventmesh-common * move defibus-client config from eventmesh-runtime to defibus plugin * move rocketmq-client config from eventmesh-runtime to rocketmq plugin * 1.fix manual ack problem 2.adjust runtime config file * 1.modify test tcp sdk demo * 1.update eventmesh-rocketmq access_driver url 2.add ProxyConsumer * fix rr reply bug,rollback delete config file in eventmesh-common * 1.support http sub * 1.modify http sub * 1.support http sub and SubscribeProcessor * 1.support http sub 2.support http subscription manage 3.support http heartBeat manage * 1.update eventmesh-runtime start.sh * 1.modify HeartBeatProcessor error retcode * 1.modify .md files under the instructions 2.modify eventmesh structure pictures 3.add protocol.md * 1.modify docs\cn README.md * 1.modify eventmesh README.md 2.modify eventmesh structure pictures * 1.modify eventmesh README.md update protocol and roadmap * Bump ini from 1.3.5 to 1.3.8 Bumps [ini](https://github.com/isaacs/ini) from 1.3.5 to 1.3.8. - [Release notes](https://github.com/isaacs/ini/releases) - [Commits](npm/ini@v1.3.5...v1.3.8) Signed-off-by: dependabot[bot] <[email protected]> * 1.modify protocol.zh-CN.md 2.modify README.md, README.zh-CN.md * 1.modify structure picture 2.fix Constants http time out value * 1.modify roadMap * 1.bug fix:fix consumer missing bizNo * 1.bug fix: fix rocketmq consumer missing bizNo * [ISSUE #211]Rocketmq-connector throw nullpointer exception * [ISSUE #212]For multiple listening instances, only the last started instance can receive messages * [ISSUE #212]For multiple listening instances, only the last started instance can receive messages * [ISSUE #216]EventMesh ProxyTcpRetryer throws NumberFormatException * [ISSUE #201]Could we support running eventmesh in docker * [ISSUE #222]When onChange is NEW, eventMesh occurred NullPointException * Format the style in the contributor guide. Format the style in the contributor guide. * [ISSUE #226]eventMesh-rocketmq-connector tcp pub throw operation time out exception * 1.update eventmesh-define.png 2.update eventmesh-runtime-quickstart.md and supply project-structure.png * Bump prismjs from 1.22.0 to 1.23.0 Bumps [prismjs](https://github.com/PrismJS/prism) from 1.22.0 to 1.23.0. - [Release notes](https://github.com/PrismJS/prism/releases) - [Changelog](https://github.com/PrismJS/prism/blob/master/CHANGELOG.md) - [Commits](PrismJS/prism@v1.22.0...v1.23.0) Signed-off-by: dependabot[bot] <[email protected]> * update eventmesh-runtime.png * 1.update .md files 2.update eventmesh-panels.png project-structure.png * update .md files * update README.md * update .md files * update README.md * update RoadMap * Update README.md * Update README.md * Update README.md * Update README.md * Update README.md * [ISSUE #237]Remove eventmesh-defibus-connector and normalize code and file naming * add english protocol document of eventmesh-runtime * update protocol document of eventmesh-runtime * update README.md * Bump elliptic from 6.5.3 to 6.5.4 Bumps [elliptic](https://github.com/indutny/elliptic) from 6.5.3 to 6.5.4. - [Release notes](https://github.com/indutny/elliptic/releases) - [Commits](indutny/elliptic@v6.5.3...v6.5.4) Signed-off-by: dependabot[bot] <[email protected]> * [ISSUE #219]Supply detail information or read.me for eventmesh running in docker * update eventmesh-runtime-quickstart.zh-CN.md * [ISSUE #219]Supply detail information or read.me for eventmesh running in docker * update quickstart.md * upgrade gradle to 6.8.3 * Update README.md * update eventmesh-runtime.png and quickstart.zh-CN * [ISSUE #256]Upgrade Openmessaging-api to 2.2.1-pubsub version * 1.update Constants 2.remove unused files BytesMessageImpl.java and SendResultImpl.java * Bump y18n from 4.0.0 to 4.0.1 Bumps [y18n](https://github.com/yargs/y18n) from 4.0.0 to 4.0.1. - [Release notes](https://github.com/yargs/y18n/releases) - [Changelog](https://github.com/yargs/y18n/blob/master/CHANGELOG.md) - [Commits](https://github.com/yargs/y18n/commits) Signed-off-by: dependabot[bot] <[email protected]> * supply not supportedOperation for consumerImpl * [ISSUE #261]remove module eventmesh-registry * [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]> * prepare to release 1.2.0 Signed-off-by: qqeasonchen <[email protected]> * update 1.2.0-release branch code (#399) * 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&®ion] (#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 * update 1.2.0-release branch code Co-authored-by: Eason Chen <[email protected]> Co-authored-by: Steve Yurong Su <[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: Lan Liang <[email protected]> Co-authored-by: nanoxiong <[email protected]> Co-authored-by: keranbingaa <[email protected]> * update 1.2.0-release branch code (#400) * 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&®ion] (#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 * update 1.2.0-release branch code * update 1.2.0-release branch code Co-authored-by: Eason Chen <[email protected]> Co-authored-by: Steve Yurong Su <[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: Lan Liang <[email protected]> Co-authored-by: nanoxiong <[email protected]> Co-authored-by: keranbingaa <[email protected]> Co-authored-by: nanoxiong <[email protected]> Co-authored-by: qqeasonchen <[email protected]> Co-authored-by: lrhkobe <[email protected]> Co-authored-by: lrhkobe <[email protected]> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: MajorHe1 <[email protected]> Co-authored-by: keranbingaa <[email protected]> Co-authored-by: wqliang <[email protected]> Co-authored-by: dinglei <[email protected]> Co-authored-by: jonyang(杨军) <[email protected]> Co-authored-by: wqliang <[email protected]> Co-authored-by: MajorHe1 <[email protected]> Co-authored-by: Heng Du <[email protected]> Co-authored-by: Udesh Liyanaarachchi <> 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: 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: Steve Yurong Su <[email protected]> Co-authored-by: Lan <[email protected]>
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&®ion] (#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]>
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&®ion] (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]>
xwm1992
pushed a commit
that referenced
this issue
Sep 27, 2021
…Send Processor (#524) * [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 #523 adding FlowControl Ratelimiter support for Http message send processors * [Issue #523] Fixing the Eventmesh ratelimit error return code. Co-authored-by: j00441484 <[email protected]>
xwm1992
pushed a commit
that referenced
this issue
Sep 30, 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 * [Issue #528] enhance Retry support for HTTP and TCP processors. * [Issue #528] fixing checkstyle issue * [Issue #528] Fix taskExecuteTime in TCP ClientGroupWrapper UpStreamMsgContext Co-authored-by: j00441484 <[email protected]>
xwm1992
pushed a commit
that referenced
this issue
Oct 13, 2021
…code (#555) * [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 #554] Removing hardcoded username and password in the project code Co-authored-by: j00441484 <[email protected]>
qqeasonchen
pushed a commit
that referenced
this issue
Oct 19, 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 * [Issue #554] removing hardcoded username and password Co-authored-by: j00441484 <[email protected]>
qqeasonchen
pushed a commit
that referenced
this issue
Nov 22, 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 * adding license headers * adding grpc build file * [Issue#417] update settings.gradle * [Issue#417] fix grpc generated code styles * [Issue#417] fix grpc generated code styles * [Issue#417] fix grpc generated code styles * [Issue#417] fix grpc generated code styles and license issue * [Issue#417] fix license issue * [Issue #417] ignore checkstyle for generated files * [Issue #417] adding allow licensed for grpc protobuf Co-authored-by: j00441484 <[email protected]>
xwm1992
pushed a commit
to xwm1992/EventMesh
that referenced
this issue
Dec 27, 2021
…ced 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]>
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&®ion] (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
pushed a commit
to xwm1992/EventMesh
that referenced
this issue
Dec 27, 2021
…ssage Send Processor (apache#524) * [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#523 adding FlowControl Ratelimiter support for Http message send processors * [Issue apache#523] Fixing the Eventmesh ratelimit error return code. Co-authored-by: j00441484 <[email protected]>
xwm1992
pushed a commit
to xwm1992/EventMesh
that referenced
this issue
Dec 27, 2021
…apache#529) * [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#528] enhance Retry support for HTTP and TCP processors. * [Issue apache#528] fixing checkstyle issue * [Issue apache#528] Fix taskExecuteTime in TCP ClientGroupWrapper UpStreamMsgContext Co-authored-by: j00441484 <[email protected]>
xwm1992
pushed a commit
to xwm1992/EventMesh
that referenced
this issue
Dec 27, 2021
…oject code (apache#555) * [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#554] Removing hardcoded username and password in the project code Co-authored-by: j00441484 <[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 * [Issue apache#554] removing hardcoded username and password Co-authored-by: j00441484 <[email protected]>
jinrongluo
added a commit
to jinrongluo/incubator-eventmesh
that referenced
this issue
Jan 11, 2022
* [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 * adding license headers * adding grpc build file * [Issue#417] update settings.gradle * [Issue#417] fix grpc generated code styles * [Issue#417] fix grpc generated code styles * [Issue#417] fix grpc generated code styles * [Issue#417] fix grpc generated code styles and license issue * [Issue#417] fix license issue * [Issue apache#417] ignore checkstyle for generated files * [Issue apache#417] adding allow licensed for grpc protobuf Co-authored-by: j00441484 <[email protected]>
xwm1992
pushed a commit
that referenced
this issue
Aug 4, 2022
…ead.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]>
xwm1992
pushed a commit
that referenced
this issue
Aug 4, 2022
…ountDownLatch 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]>
xwm1992
pushed a commit
that referenced
this issue
Aug 4, 2022
…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]>
xwm1992
pushed a commit
that referenced
this issue
Aug 4, 2022
…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]>
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 * [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]>
xwm1992
pushed a commit
that referenced
this issue
Aug 4, 2022
… 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]>
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&®ion] (#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
pushed a commit
that referenced
this issue
Aug 4, 2022
…Send Processor (#524) * [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 #523 adding FlowControl Ratelimiter support for Http message send processors * [Issue #523] Fixing the Eventmesh ratelimit error return code. Co-authored-by: j00441484 <[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 * [Issue #528] enhance Retry support for HTTP and TCP processors. * [Issue #528] fixing checkstyle issue * [Issue #528] Fix taskExecuteTime in TCP ClientGroupWrapper UpStreamMsgContext Co-authored-by: j00441484 <[email protected]>
xwm1992
pushed a commit
that referenced
this issue
Aug 4, 2022
…code (#555) * [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 #554] Removing hardcoded username and password in the project code Co-authored-by: j00441484 <[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 * [Issue #554] removing hardcoded username and password Co-authored-by: j00441484 <[email protected]>
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Http.demo Http Subscriber (SubService) is not working. When the Async Http Producer (AsyncPublishInstance) publishes a message to EventMesh runtime, This Subscriber is not able to consume it.
Steps to reproduce this issue in JAVA IDE Intellij:
Import eventmesh project to Intellij and build the project.
Start up EventMesh runtime from eventmesh-starter project's StartUp class
Start up Http Subscriber Test Application, from eventmesh-test project: org.apache.eventmesh.http.demo.sub.SpringBootDemoApplication.java
Start up Http Async Producer Test Application, from eventmesh-test project:
org.apache.eventmesh.http.demo.AsyncPublishInstance.java
Observe the logs of Http Subscriber, it is not getting the published message from Eventmesh, Expecting log is
"=======receive message======= {message}"
I saw this error message in the EventMesh runtime. Which indicates the subscriber endpoint (http://10.48.244.96:8088/sub/test) is not available.
The text was updated successfully, but these errors were encountered: