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 #11323] fix(example): retry request when reply send fails in ResponseConsumer
- [Bug] openmessaging SimpleProducer prints "Send async message OK" for its synchronous send
- [Bug] Compaction topic example: updateTopic -o true but sample output shows order=false
- [Bug] DLedger quick-start failover hardcodes port 30931 as the Leader, but the Leader is elected dynamically
- [ISSUE #11327] fix(example): validate msgCount before starting producer
- [Enhancement] SemaphoreReleaseOnlyOnce lacks direct tests for its exactly-once release contract
- [Enhancement] ControllerClosure request-completion semantics lack direct tests
- [Enhancement] SyncStateInfo defensive-copy and epoch semantics lack direct tests
- [Enhancement] LogicExpression three-valued truth table and short-circuit behavior lack direct tests
- [Enhancement] FilterFactory duplicate-registration and unregister semantics lack tests
- Docs
- Java not yet supported