You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "guyinyou (via GitHub)" <gi...@apache.org> on 2023/09/04 03:02:47 UTC

[GitHub] [rocketmq] guyinyou opened a new issue, #7289: [Enhancement] Fixed asynchronous send backpressure capability

guyinyou opened a new issue, #7289:
URL: https://github.com/apache/rocketmq/issues/7289

   ### Before Creating the Enhancement Request
   
   - [X] I have confirmed that this should be classified as an enhancement rather than a bug/feature.
   
   
   ### Summary
   
   Fixed asynchronous send backpressure capability
   
   ### Motivation
   
   The semaphore should be released after sending the callback. Otherwise, it will not have the effect of back pressure.
   
   ### Describe the Solution You'd Like
   
   Release the semaphore in sendCallBack
   
   ### Describe Alternatives You've Considered
   
   After turning on backpressure, it can be sent asynchronously at the expected rate limit.
   
   ### Additional Context
   
   _No response_


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org


[GitHub] [rocketmq] RongtongJin closed issue #7289: [Enhancement] Fixed asynchronous send backpressure capability

Posted by "RongtongJin (via GitHub)" <gi...@apache.org>.
RongtongJin closed issue #7289: [Enhancement] Fixed asynchronous send backpressure capability
URL: https://github.com/apache/rocketmq/issues/7289


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org