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
- Add some comments to module proxy, No code change
- [Enhancement] Fix util.getIP return 127.0.0.1 issue on 4.9.x
- [Enhancement] Increase timeout for broker notification requests to 3000 milliseconds
- [Enhancement] Remove getTimerCheckpoint() from BrokerController
- [Enhancement] massive memory allocation in the `parsePublishMessageQueues`
- [Feature] Priority Message
- added channel.isActive() to clientIsOffline adn relevant test case
- [Enhancement] Use the same connection to send the heartbeat for keepalive
- [Bug] PopReviveService may stuck on check if many messages change invisible in the same time.
- [Bug] Correct thread name prefix for file recycling executor in tiered store
- Docs
- Java not yet supported