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
- [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
- [Bug] Bug title 无法删除 PolicyType为Default 的 acl
- Set the consumer instanceName to "proxy_heartbeat_{port}" instead of default.
- [Enhancement] Enhancement title 实现了一个同时支持多instance的RocketMQ的starter组件,抽象了重复的binder代码
- Docs
- Java not yet supported