Skip to content
New issue

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

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

Already on GitHub? Sign in to your account

merg branch 1.2.0 release to master #403

Merged
merged 239 commits into from
Jun 29, 2021
Merged

merg branch 1.2.0 release to master #403

merged 239 commits into from
Jun 29, 2021

Conversation

xwm1992
Copy link
Contributor

@xwm1992 xwm1992 commented Jun 29, 2021

No description provided.

iNanos and others added 30 commits November 13, 2020 12:14
add  static website for the project so that people can learn more about EventMesh.
2.change runtime and connector dependency
2.modify eventmesh-runtime imported classes from eventmesh-common
� Conflicts:
�	eventmesh-connector-defibus/src/main/java/connector/defibus/consumer/DeFiBusConsumerImpl.java
�	eventmesh-connector-defibus/src/main/java/connector/defibus/producer/DeFiBusProducerImpl.java
�	eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/MQConsumerWrapper.java
�	eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/impl/MeshMQConsumer.java
�	eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/impl/MeshMQProducer.java
�	eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/impl/RocketMQConsumerImpl.java
�	eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/impl/RocketMQProducerImpl.java
2.modify eventmesh-runtime imported classes from eventmesh-common
2.modify eventmesh-runtime imported classes from eventmesh-common
[ISSUE #176] Support Spi for extended implementation to accommodate a variety of MQ
Move defibus dependency from eventmesh-runtime to eventmesh-connector-defibus
…to 1.2.0

� Conflicts:
�	eventmesh-common/build.gradle
�	eventmesh-connector-api/build.gradle
�	eventmesh-connector-api/src/main/java/com/webank/api/consumer/MeshMQPushConsumer.java
�	eventmesh-connector-api/src/main/java/com/webank/eventmesh/api/producer/MeshMQProducer.java
�	eventmesh-connector-defibus/build.gradle
�	eventmesh-connector-defibus/src/main/java/com/webank/eventmesh/connector/defibus/producer/DeFiBusProducerImpl.java
�	eventmesh-runtime/build.gradle
�	eventmesh-runtime/src/main/java/com/webank/runtime/core/plugin/MQProducerWrapper.java
�	eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/group/ClientGroupWrapper.java
�	eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/session/push/DownStreamMsgContext.java
�	eventmesh-runtime/src/main/java/com/webank/runtime/core/protocol/tcp/client/task/MessageTransferTask.java
�	eventmesh-runtime/src/main/java/com/webank/runtime/util/ProxyUtil.java
�	eventmesh-runtime/src/main/java/com/webank/runtime/util/RemotingHelper.java
…tor-rocketmq

2.modify http processor
3.modify http subscribe
Move rocketmq dependency from eventmesh-runtime to eventmesh-connector-rocketmq
xwm1992 and others added 24 commits April 25, 2021 15:51
Co-authored-by: jonyang(杨军) <[email protected]>
…e.eventmesh" (#319)

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

* rename com.webank.eventmesh to org.apache.eventmesh
…en repository (#326)

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

* update build.gradle

* update build.gradle and gradle.properties
* 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]>
Signed-off-by: qqeasonchen <[email protected]>
Signed-off-by: qqeasonchen <[email protected]>
* update build.gradle and gradle.properties for publish to maven repository (#330)

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

* update build.gradle

* update build.gradle and gradle.properties

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

* Update README.md

* Update README.zh-CN.md

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

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* remove dead docs

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

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

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* [ISSUE #329]Missing Log4j dependency

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

fixed #331

* Doc modification #328 (#335)

change vm params

* Update README.md

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

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

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

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

* Setup automated workflows for greetings

* Remove '@apache/eventmesh-committers'

* Add LGTM Badges ISSUE#353 (#354)

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

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

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

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

* Setup CodeQL scans

* disable autorun

* add a step for setting up JDK

* add codeql

* fix step Build

* fix strategy

* add events: schedule & workflow_dispatch

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

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

* [Issue #344] Fix import statements

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

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

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

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

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

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

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

* update eventmesh-runtime.png (#358)

* update eventmesh-runtime.png

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

* Support multiple load balance strategy in sdk #333

* Fix ut

* add log

* update eventmesh-panels.png (#362)

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

* update eventmesh-panels.png (#363)

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

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

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

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

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

* Add files via upload

* Update README.md

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

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

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

* [Issue #368] fix build issue

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

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

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

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

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

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

* Update README.md

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

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

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

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

* enable github actions for license check

* add necessary headers

* update badges

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

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

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

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

* [Issue #368] fix build issue

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

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

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

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

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

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

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

closed #378

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

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

* add license header

* add ut

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

close #384

* Update README.md

* Update README.zh-CN.md

* Update README.zh-CN.md

* Update README.zh-CN.md

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

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

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

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

* [Issue #386] Fix license header missing issue

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

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

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

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

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

close #366

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

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

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

* modify:fix conflict

* modify:add license in EventMeshAction
close #391

* miss group name set for userAgent (#395)

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* bugfix : miss group set

* bugfix : miss group set

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

close #393

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

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

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

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

* [ISSUE #397]Remove subscription session failed error

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

* 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 build.gradle and gradle.properties for publish to maven repository (#330)

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

* update build.gradle

* update build.gradle and gradle.properties

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

* Update README.md

* Update README.zh-CN.md

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

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* remove dead docs

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

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

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* [ISSUE #329]Missing Log4j dependency

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

fixed #331

* Doc modification #328 (#335)

change vm params

* Update README.md

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

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

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

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

* Setup automated workflows for greetings

* Remove '@apache/eventmesh-committers'

* Add LGTM Badges ISSUE#353 (#354)

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

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

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

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

* Setup CodeQL scans

* disable autorun

* add a step for setting up JDK

* add codeql

* fix step Build

* fix strategy

* add events: schedule & workflow_dispatch

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

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

* [Issue #344] Fix import statements

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

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

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

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

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

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

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

* update eventmesh-runtime.png (#358)

* update eventmesh-runtime.png

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

* Support multiple load balance strategy in sdk #333

* Fix ut

* add log

* update eventmesh-panels.png (#362)

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

* update eventmesh-panels.png (#363)

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* update eventmesh-panels.png

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

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

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

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

* Add files via upload

* Update README.md

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

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

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

* [Issue #368] fix build issue

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

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

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

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

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

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

* Update README.md

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

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

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

* add github action for check license

* fix syntax and name ci for Check license

* fix github action branch typo

* enable github actions for license check

* add necessary headers

* update badges

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

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

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

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

* [Issue #368] fix build issue

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

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

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

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

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

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

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

closed #378

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

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

* add license header

* add ut

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

close #384

* Update README.md

* Update README.zh-CN.md

* Update README.zh-CN.md

* Update README.zh-CN.md

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

* [Issue #337] Fix HttpSubscriber startup issue

* [Issue #337] test commit

* [Issue #337] revert test commit

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

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

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

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

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

* [Issue #386] Fix license header missing issue

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

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

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

* remove custom-format topic concept

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

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

close #366

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

* modify:optimize flow control in downstreaming msg

* modify:optimize stategy of selecting session in downstream msg

* modify:optimize msg downstream,msg store in session

* modify:fix bug:not a @sharable handler

* modify:downstream broadcast msg asynchronously

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

* modify:fix conflict

* modify:add license in EventMeshAction
close #391

* miss group name set for userAgent (#395)

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* remove custom concept{dcn}

* bugfix : miss group set

* bugfix : miss group set

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

close #393

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

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

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

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

* update build.gradle

* update build.gradle and gradle.properties

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

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

* [ISSUE #329]Missing Log4j dependency

* update eventmesh-runtime.png

* support unsubscribe topics while delconsumer in http mode

* [ISSUE #397]Remove subscription session failed error

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

* 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]>
Copy link
Contributor

@MajorHe1 MajorHe1 left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

Copy link
Contributor

@keranbingaa keranbingaa left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

ACK

@wqliang wqliang self-requested a review June 29, 2021 06:38
Copy link
Contributor

@wqliang wqliang left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

LGTM

@xwm1992 xwm1992 merged commit e4cff57 into master Jun 29, 2021
@xwm1992 xwm1992 deleted the 1.2.0-release branch August 10, 2021 03:35
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.