The GitHub Actions job "Build" on rocketmq-clients.git/master has succeeded.
Run started by GitHub user RongtongJin (triggered by RongtongJin).

Head commit for run:
6c96a836affe75f1f2f1fe9fe6856aff161e6322 / zhaohai 
<[email protected]>
feat(nodejs): add consumer-side rate limiting via semaphore backpressure (#1386)

Add src/util/Semaphore.ts and apply it to ProcessQueue, bounding in-flight
consumption by consumeConcurrentlyMax (default 32). The receive loop
pauses while all semaphore permits are taken, providing per-queue
consumption backpressure; the setting is parsed from broker-side settings
when present.

Report URL: https://github.com/apache/rocketmq-clients/actions/runs/37876693675

With regards,
GitHub Actions via GitBox

Reply via email to