-
Notifications
You must be signed in to change notification settings - Fork 642
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
[Issue #523] Adding Flow control RateLimiter support in Http Message Send Processor #524
Conversation
merged from upstream
…ice, CountDownLatch and PreDestroy hook
# Conflicts: # eventmesh-test/src/main/java/org/apache/eventmesh/http/demo/sub/service/SubService.java
…ice, CountDownLatch and PreDestroy hook
…age send processors
@@ -39,7 +39,8 @@ | |||
EVENTMESH_SUBSCRIBE_ERR(17, "eventMesh subscribe err"), | |||
EVENTMESH_UNSUBSCRIBE_ERR(18, "eventMesh unsubscribe err"), | |||
EVENTMESH_HEARTBEAT_ERR(19, "eventMesh heartbeat err"), | |||
EVENTMESH_ACL_ERR(20, "eventMesh acl err"); | |||
EVENTMESH_ACL_ERR(20, "eventMesh acl err"), | |||
EVENTMESH_HTTP_MES_SEND_OVER_LIMIT_ERR(20, "eventMesh http msg send over the limit, "); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
this code 20 isn't right
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Thanks @xwm1992 I fix the error code to make it as 21.
Adding new commit to this PR
Codecov Report
@@ Coverage Diff @@
## develop #524 +/- ##
=============================================
- Coverage 11.03% 10.99% -0.04%
Complexity 376 376
=============================================
Files 257 257
Lines 12157 12191 +34
Branches 1032 1036 +4
=============================================
Hits 1341 1341
- Misses 10701 10735 +34
Partials 115 115
Continue to review full report at Codecov.
|
…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 <jin.rong.luo@huawei.com>
…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 <jin.rong.luo@huawei.com>
Issue #523 Adding Flow control RateLimiter support in Http Message Send Processor
Motivation
In Eventmesh runtime, there is flow control using RateLimiter in TCP MessageTransfer processor, and HTTP Batch Message send processor. However flow control is missing in Http MessageSend (Sync & Async) procrssors.
I have implemented RateLimiter for Http Message Send processors, and would like to contribute.
Modifications
Adding RateLimiter to Http Message Send Processor.
Using property file to set the rate limit