rocketmq
https://github.com/apache/rocketmq
Java
Mirror of Apache RocketMQ
Triage Issues!
When you volunteer to triage issues, you'll receive an email each day with a link to an open issue that needs help in this project. You'll also receive instructions on how to triage issues.
Triage Docs!
Receive a documented method or class from your favorite GitHub repos in your inbox every day. If you're really pro, receive undocumented methods or classes and supercharge your commit history.
Java not yet supported3 Subscribers
Add a CodeTriage badge to rocketmq
Help out
- Issues
- [ISSUE #3312] fix(client): honor consumeThreadMax for concurrent consumers
- [Bug] NameServer address update retains and mutates caller list
- [ISSUE #11246] fix(remoting): copy NameServer address list on update
- [Bug] Fix Lite topic consumer losing messages when notified before they are readable
- [Bug] Fix Lite topic ack re-dispatching the event while holding the pop lock
- [Bug] Async shutdown is not idempotent and empty/timed waits fail
- [ISSUE #11252] fix(common): make async shutdown idempotent and awaitable
- [Bug] Thread shutdown ignores finite waits and spins after caller interruption
- [ISSUE #11254] fix(common): honor thread shutdown timeout and interruption
- [Bug] Malformed hexadecimal identifiers are silently decoded
- Docs
- Java not yet supported