apache / rocketmq
File Age & Freshness

File age measurements show the distribution of file ages (days since the first commit) and the file freshness (days since the latest commit).

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 1,488 files with 169,271 lines of code in files.
    • 1,404 files that are 366+ days old (163,451 lines of code)
    • 47 files that are 181-365 days old (2,790 lines of code)
    • 20 files that are 91-180 days old (2,017 lines of code)
    • 2 files that are 31-90 days old (27 lines of code)
    • 15 files that are 1-30 days old (986 lines of code)
96% | 1% | 1% | <1% | <1%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 1,488 files with 169,271 lines of code in files.
    • 1,143 files have been last changed 366+ days ago (73,383 lines of code)
    • 137 files have been last changed 181-365 days ago (24,946 lines of code)
    • 96 files have been last changed 91-180 days ago (21,578 lines of code)
    • 47 files have been last changed 31-90 days ago (19,247 lines of code)
    • 65 files have been last changed 1-30 days ago (30,117 lines of code)
43% | 14% | 12% | 11% | 17%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, md, xml, yaml, sh, cmd, properties, json, py, sql, bzl, gitignore, txt
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java96% | 1% | 1% | <1% | <1%
xml100% | 0% | 0% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
bzl100% | 0% | 0% | 0% | 0%
sql100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java42% | 14% | 12% | 11% | 18%
xml78% | 21% | 0% | 0% | 0%
py100% | 0% | 0% | 0% | 0%
bzl100% | 0% | 0% | 0% | 0%
sql100% | 0% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
broker89% | 5% | 4% | 0% | <1%
store98% | 1% | <1% | 0% | 0%
client97% | <1% | <1% | <1% | 2%
remoting98% | <1% | <1% | 0% | 0%
proxy99% | <1% | <1% | 0% | 0%
tools97% | 1% | <1% | 0% | 0%
common97% | 1% | <1% | <1% | 0%
tieredstore99% | 0% | <1% | 0% | 0%
controller100% | 0% | 0% | 0% | 0%
auth89% | 0% | 0% | 0% | 10%
example94% | 5% | 0% | 0% | 0%
filter100% | 0% | 0% | 0% | 0%
namesrv100% | 0% | 0% | 0% | 0%
openmessaging100% | 0% | 0% | 0% | 0%
container100% | 0% | 0% | 0% | 0%
style100% | 0% | 0% | 0% | 0%
dev100% | 0% | 0% | 0% | 0%
srvutil100% | 0% | 0% | 0% | 0%
distribution100% | 0% | 0% | 0% | 0%
bazel100% | 0% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
remoting69% | 8% | 7% | 12% | 2%
store30% | 22% | 13% | 22% | 11%
tools59% | 11% | 3% | 2% | 23%
proxy47% | 10% | 25% | 3% | 13%
broker20% | 13% | 13% | 13% | 39%
common47% | 13% | 13% | 8% | 16%
client24% | 20% | 19% | 13% | 22%
controller81% | 18% | 0% | 0% | 0%
filter87% | 0% | 0% | 12% | 0%
example72% | 26% | 0% | 1% | 0%
auth61% | 11% | 11% | 0% | 15%
namesrv94% | 2% | 0% | 2% | 0%
openmessaging88% | 11% | 0% | 0% | 0%
tieredstore21% | 16% | 21% | 14% | 26%
container70% | 0% | 18% | 10% | 0%
style100% | 0% | 0% | 0% | 0%
dev100% | 0% | 0% | 0% | 0%
distribution100% | 0% | 0% | 0% | 0%
bazel100% | 0% | 0% | 0% | 0%
srvutil55% | 0% | 44% | 0% | 0%
Oldest Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
MQClientAPIImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 3092 145 2016-12-27 2025-04-30 152 85 yukon@apache.org dingshuangxi888@gmail.com
AdminBrokerProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 2976 97 2016-12-27 2025-05-06 157 87 yukon@apache.org 707364882@qq.com
DefaultMessageStore.java
in store/src/main/java/org/apache/rocketmq/store
 2709 218 2016-12-27 2025-04-16 198 99 yukon@apache.org 707364882@qq.com
BrokerController.java
in broker/src/main/java/org/apache/rocketmq/broker
 2119 177 2016-12-27 2025-04-30 188 87 yukon@apache.org dingshuangxi888@gmail.com
CommitLog.java
in store/src/main/java/org/apache/rocketmq/store
 1970 114 2016-12-27 2025-04-01 135 83 yukon@apache.org ymwneu@126.com
DefaultMQAdminExtImpl.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 1791 142 2016-12-27 2025-04-30 111 64 yukon@apache.org dingshuangxi888@gmail.com
DefaultMQProducerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/producer
 1578 100 2016-12-27 2025-03-10 132 87 yukon@apache.org gaoyf@users.noreply.github.com
BrokerConfig.java
in common/src/main/java/org/apache/rocketmq/common
 1424 399 2016-12-27 2025-04-30 141 63 yukon@apache.org dingshuangxi888@gmail.com
MessageStoreConfig.java
in store/src/main/java/org/apache/rocketmq/store/config
 1348 364 2016-12-27 2024-12-05 102 64 yukon@apache.org jamiechen.778@gmail.com
DefaultMQPushConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 1325 87 2016-12-27 2024-12-15 87 56 yukon@apache.org mxsm@apache.org
BrokerOuterAPI.java
in broker/src/main/java/org/apache/rocketmq/broker/out
 1271 63 2016-12-27 2024-08-02 85 46 yukon@apache.org imzs@foxmail.com
MQClientInstance.java
in client/src/main/java/org/apache/rocketmq/client/impl/factory
 1183 68 2016-12-27 2025-04-11 114 72 yukon@apache.org ymwneu@126.com
RouteInfoManager.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo
 1071 66 2016-12-27 2024-03-18 74 48 yukon@apache.org 64068328+caizhaomin1@users....
NettyRemotingClient.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 1064 60 2016-12-27 2025-02-25 100 60 yukon@apache.org xinzhuxiansheng@126.com
ConsumeQueue.java
in store/src/main/java/org/apache/rocketmq/store
 979 57 2016-12-27 2024-10-23 72 46 yukon@apache.org lizhanhui@apache.org
DefaultMQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 820 143 2016-12-27 2025-04-30 88 54 yukon@apache.org dingshuangxi888@gmail.com
PullMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 769 16 2016-12-27 2025-04-01 59 37 yukon@apache.org ymwneu@126.com
DefaultMQProducer.java
in client/src/main/java/org/apache/rocketmq/client/producer
 741 118 2016-12-27 2025-03-10 97 61 yukon@apache.org gaoyf@users.noreply.github.com
MappedFileQueue.java
in store/src/main/java/org/apache/rocketmq/store
 739 51 2016-12-27 2023-12-20 46 29 yukon@apache.org 43713766+evanmi@users.norep...
DefaultMQPullConsumerImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 724 70 2016-12-27 2024-11-29 62 47 yukon@apache.org wuxingcan.wxc@alibaba-inc.com
BrokerStatsManager.java
in store/src/main/java/org/apache/rocketmq/store/stats
 698 66 2016-12-27 2025-04-02 40 24 yukon@apache.org ymwneu@126.com
NettyRemotingServer.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 658 59 2016-12-27 2025-02-24 73 43 yukon@apache.org zsjperiod@foxmail.com
RebalanceImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 651 27 2016-12-27 2024-12-25 48 34 yukon@apache.org 125714719+3424672656@users....
UtilAll.java
in common/src/main/java/org/apache/rocketmq/common
 638 52 2016-12-27 2024-08-15 73 51 yukon@apache.org 58294989+zekai-li@users.nor...
MQVersion.java
in common/src/main/java/org/apache/rocketmq/common
 633 2 2016-12-27 2025-05-06 61 26 yukon@apache.org 707364882@qq.com
TopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/topic
 624 41 2016-12-27 2025-02-26 68 42 yukon@apache.org 2573259572@qq.com
SendMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 593 12 2016-12-27 2024-12-09 97 59 yukon@apache.org imzs@foxmail.com
DefaultRequestProcessor.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/processor
 566 30 2016-12-27 2024-01-29 59 35 yukon@apache.org ljbmxsm@gmail.com
MessageDecoder.java
in common/src/main/java/org/apache/rocketmq/common/message
 565 22 2016-12-27 2024-12-05 58 41 yukon@apache.org lizhanhui@apache.org
NettyRemotingAbstract.java
in remoting/src/main/java/org/apache/rocketmq/remoting/netty
 552 27 2016-12-27 2025-02-24 73 46 yukon@apache.org zsjperiod@foxmail.com
StoreStatsService.java
in store/src/main/java/org/apache/rocketmq/store
 536 42 2016-12-27 2022-11-24 34 21 yukon@apache.org yangkun.ayk@gmail.com
RemotingCommand.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol
 511 62 2016-12-27 2024-11-20 43 28 yukon@apache.org 707364882@qq.com
AbstractSendMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 495 18 2016-12-27 2025-04-09 55 37 yukon@apache.org ymwneu@126.com
DefaultMQPushConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 486 102 2016-12-27 2024-08-30 72 37 yukon@apache.org 845238369@qq.com
ConsumeMessageOrderlyService.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 485 25 2016-12-27 2024-05-16 60 41 yukon@apache.org 65004897+willhow-gao@users....
MixAll.java
in common/src/main/java/org/apache/rocketmq/common
 473 38 2016-12-27 2025-04-01 96 66 yukon@apache.org ymwneu@126.com
ClientConfig.java
in client/src/main/java/org/apache/rocketmq/client
 414 71 2016-12-27 2024-07-29 61 41 yukon@apache.org 43874697+letletme@users.nor...
MQAdminImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 404 22 2016-12-27 2024-08-30 48 34 yukon@apache.org jinrongtong16@mails.ucas.ac.cn
TransactionProducer.java
in example/src/main/java/org/apache/rocketmq/example/benchmark
 399 17 2016-12-27 2024-01-12 35 26 yukon@apache.org zhouxiang.zzx@alibaba-inc.com
ProcessQueue.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 388 32 2016-12-27 2024-12-05 38 28 yukon@apache.org lizhanhui@apache.org
ConsumeMessageConcurrentlyService.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 386 21 2016-12-27 2024-05-07 51 36 yukon@apache.org jjhfen00@163.com
Producer.java
in example/src/main/java/org/apache/rocketmq/example/benchmark
 369 11 2016-12-27 2024-05-23 40 27 yukon@apache.org 1109939087@qq.com
ConsumerOffsetManager.java
in broker/src/main/java/org/apache/rocketmq/broker/offset
 357 30 2016-12-27 2025-04-28 32 20 yukon@apache.org 707364882@qq.com
ConsumerManager.java
in broker/src/main/java/org/apache/rocketmq/broker/client
 355 24 2016-12-27 2025-04-23 31 20 yukon@apache.org 1174533476@qq.com
DefaultMQPullConsumer.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 337 65 2016-12-27 2024-11-29 45 31 yukon@apache.org wuxingcan.wxc@alibaba-inc.com
MQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 322 - 2016-12-27 2025-04-30 79 48 yukon@apache.org dingshuangxi888@gmail.com
SubscriptionGroupManager.java
in broker/src/main/java/org/apache/rocketmq/broker/subscription
 321 35 2016-12-27 2025-04-01 32 21 yukon@apache.org ymwneu@126.com
IndexService.java
in store/src/main/java/org/apache/rocketmq/store/index
 321 15 2016-12-27 2025-03-26 23 15 yukon@apache.org 53215912+yangxiaohui-coll@u...
PullAPIWrapper.java
in client/src/main/java/org/apache/rocketmq/client/impl/consumer
 319 16 2016-12-27 2024-01-12 43 31 yukon@apache.org zhouxiang.zzx@alibaba-inc.com
ConsumerProgressSubCommand.java
in tools/src/main/java/org/apache/rocketmq/tools/command/consumer
 309 23 2016-12-27 2024-08-30 34 23 yukon@apache.org jinrongtong16@mails.ucas.ac.cn
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
transaction.sql
in broker/src/main/resources
 4 - 2016-12-27 2016-12-27 1 1 yukon@apache.org yukon@apache.org
MessageListener.java
in client/src/main/java/org/apache/rocketmq/client/consumer/listener
 3 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
MQAdminExtInner.java
in client/src/main/java/org/apache/rocketmq/client/admin
 3 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
NamesrvUtil.java
in common/src/main/java/org/apache/rocketmq/common/namesrv
 4 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
CommandCustomHeader.java
in remoting/src/main/java/org/apache/rocketmq/remoting
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingCommandType.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ConsumeConcurrentlyStatus.java
in client/src/main/java/org/apache/rocketmq/client/consumer/listener
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
PullTaskCallback.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
PullCallback.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
FilterMessageHook.java
in client/src/main/java/org/apache/rocketmq/client/hook
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
FlushDiskType.java
in store/src/main/java/org/apache/rocketmq/store/config
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
MessageFilter.java
in common/src/main/java/org/apache/rocketmq/common/filter
 5 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
CommunicationMode.java
in client/src/main/java/org/apache/rocketmq/client/impl
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
LocalTransactionState.java
in client/src/main/java/org/apache/rocketmq/client/producer
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ReadOffsetType.java
in client/src/main/java/org/apache/rocketmq/client/consumer/store
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
CheckForbiddenHook.java
in client/src/main/java/org/apache/rocketmq/client/hook
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ConsumeMessageHook.java
in client/src/main/java/org/apache/rocketmq/client/hook
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
SendMessageHook.java
in client/src/main/java/org/apache/rocketmq/client/hook
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
BrokerRole.java
in store/src/main/java/org/apache/rocketmq/store/config
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ConsumeMessageHook.java
in broker/src/main/java/org/apache/rocketmq/broker/mqtrace
 6 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
Apache.xml
in style/copyright
 6 - 2016-12-28 2016-12-29 2 1 yukon@apache.org yukon@apache.org
SystemClock.java
in common/src/main/java/org/apache/rocketmq/common
 6 1 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
Operand.java
in common/src/main/java/org/apache/rocketmq/common/filter/impl
 6 1 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingTooMuchRequestException.java
in remoting/src/main/java/org/apache/rocketmq/remoting/exception
 7 1 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
MessageQueueSelector.java
in client/src/main/java/org/apache/rocketmq/client/producer
 7 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
SendStatus.java
in client/src/main/java/org/apache/rocketmq/client/producer
 7 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
PullStatus.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 7 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ServiceState.java
in common/src/main/java/org/apache/rocketmq/common
 7 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingSysResponseCode.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol
 8 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ConsumeReturnType.java
in client/src/main/java/org/apache/rocketmq/client/consumer/listener
 8 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RunningStats.java
in common/src/main/java/org/apache/rocketmq/common/running
 8 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
Type.java
in common/src/main/java/org/apache/rocketmq/common/filter/impl
 8 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ConsumeOrderlyStatus.java
in client/src/main/java/org/apache/rocketmq/client/consumer/listener
 9 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingCommandException.java
in remoting/src/main/java/org/apache/rocketmq/remoting/exception
 10 2 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingSendRequestException.java
in remoting/src/main/java/org/apache/rocketmq/remoting/exception
 10 2 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingException.java
in remoting/src/main/java/org/apache/rocketmq/remoting/exception
 10 2 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
FilterContext.java
in common/src/main/java/org/apache/rocketmq/common/filter
 10 2 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
CFNotNull.java
in remoting/src/main/java/org/apache/rocketmq/remoting/annotation
 11 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
CFNullable.java
in remoting/src/main/java/org/apache/rocketmq/remoting/annotation
 11 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ImportantField.java
in common/src/main/java/org/apache/rocketmq/common/annotation
 11 - 2016-12-27 2016-12-29 2 1 yukon@apache.org yukon@apache.org
KVConfigSerializeWrapper.java
in namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig
 12 1 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
TransactionSendResult.java
in client/src/main/java/org/apache/rocketmq/client/producer
 12 3 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
AllocateMessageQueueStrategy.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 12 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ConsumeFromWhere.java
in common/src/main/java/org/apache/rocketmq/common/consumer
 12 - 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
RemotingTimeoutException.java
in remoting/src/main/java/org/apache/rocketmq/remoting/exception
 13 3 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
Op.java
in common/src/main/java/org/apache/rocketmq/common/filter/impl
 13 3 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
ChannelUtil.java
in common/src/main/java/org/apache/rocketmq/common/utils
 14 1 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
PullTaskContext.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 17 4 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
BrokerConfigSingleton.java
in common/src/main/java/org/apache/rocketmq/common
 18 2 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
SelectMessageQueueByMachineRoom.java
in client/src/main/java/org/apache/rocketmq/client/producer/selector
 19 3 2016-12-27 2016-12-29 3 1 yukon@apache.org yukon@apache.org
Most Recently Created Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
AclUtils.java
in client/src/main/java/org/apache/rocketmq/acl/common
 229 20 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
SessionCredentials.java
in client/src/main/java/org/apache/rocketmq/acl/common
 122 15 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
PlainAccessResource.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 116 27 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
PlainPermissionManager.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 110 5 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
PlainAccessConfig.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 86 17 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
PlainAccessData.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 68 14 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AclSigner.java
in client/src/main/java/org/apache/rocketmq/acl/common
 63 6 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AclException.java
in client/src/main/java/org/apache/rocketmq/acl/common
 39 9 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AclClientRPCHook.java
in client/src/main/java/org/apache/rocketmq/acl/common
 33 5 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
Permission.java
in client/src/main/java/org/apache/rocketmq/acl/common
 25 1 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AclConfig.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 25 5 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AclConstants.java
in client/src/main/java/org/apache/rocketmq/acl/common
 10 - 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
SigningAlgorithm.java
in client/src/main/java/org/apache/rocketmq/acl/common
 6 - 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AccessResource.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 3 - 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
ClientChannelAttributeHelper.java
in broker/src/main/java/org/apache/rocketmq/broker/client
 51 6 2025-04-11 2025-04-11 1 1 ymwneu@126.com ymwneu@126.com
NotifyResult.java
in client/src/main/java/org/apache/rocketmq/client/consumer
 23 4 2025-03-03 2025-03-03 1 1 wuxingcan.wxc@alibaba-inc.com wuxingcan.wxc@alibaba-inc.com
ObjectCreator.java
in common/src/main/java/org/apache/rocketmq/common
 4 - 2025-02-24 2025-02-24 1 1 zsjperiod@foxmail.com zsjperiod@foxmail.com
ExportRocksDBConfigToJsonRequestHeader.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header
 69 9 2025-01-14 2025-02-05 2 1 wuxingcan.wxc@alibaba-inc.com wuxingcan.wxc@alibaba-inc.com
GroupCommitContext.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common
 40 7 2024-12-25 2024-12-25 1 1 15001782969@163.com 15001782969@163.com
PopConsumerService.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 599 25 2024-12-20 2025-05-06 7 3 707364882@qq.com 707364882@qq.com
PopConsumerCache.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 242 25 2024-12-20 2024-12-20 1 1 707364882@qq.com 707364882@qq.com
PopConsumerRecord.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 146 25 2024-12-20 2025-05-06 3 2 707364882@qq.com 707364882@qq.com
PopConsumerRocksdbStore.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 129 8 2024-12-20 2025-01-08 3 1 707364882@qq.com 707364882@qq.com
PopConsumerContext.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 125 20 2024-12-20 2025-03-15 2 1 707364882@qq.com 707364882@qq.com
ExportPopRecordCommand.java
in tools/src/main/java/org/apache/rocketmq/tools/command/export
 82 5 2024-12-20 2024-12-20 1 1 707364882@qq.com 707364882@qq.com
PopConsumerLockService.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 69 9 2024-12-20 2024-12-20 1 1 707364882@qq.com 707364882@qq.com
PopConsumerKVStore.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 10 - 2024-12-20 2025-01-08 2 1 707364882@qq.com 707364882@qq.com
RecallMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 157 5 2024-12-09 2024-12-27 2 1 imzs@foxmail.com imzs@foxmail.com
RecallMessageHandle.java
in common/src/main/java/org/apache/rocketmq/common/producer
 59 8 2024-12-09 2024-12-09 1 1 imzs@foxmail.com imzs@foxmail.com
DefaultRecallMessageTraceHook.java
in client/src/main/java/org/apache/rocketmq/client/trace/hook
 57 3 2024-12-09 2024-12-09 1 1 imzs@foxmail.com imzs@foxmail.com
RecallMessageRequestHeader.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header
 50 8 2024-12-09 2024-12-09 1 1 imzs@foxmail.com imzs@foxmail.com
RecallMessageActivity.java
in proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer
 39 2 2024-12-09 2024-12-09 1 1 imzs@foxmail.com imzs@foxmail.com
RecallMessageActivity.java
in proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity
 31 2 2024-12-09 2024-12-09 1 1 imzs@foxmail.com imzs@foxmail.com
RecallMessageResponseHeader.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header
 17 3 2024-12-09 2024-12-09 1 1 imzs@foxmail.com imzs@foxmail.com
RocksGroupCommitService.java
in store/src/main/java/org/apache/rocketmq/store/queue
 68 6 2024-12-02 2024-12-02 1 1 lizhanhui@apache.org lizhanhui@apache.org
PopCommandCallback.java
in broker/src/main/java/org/apache/rocketmq/broker/longpolling
 24 2 2024-11-20 2024-11-20 1 1 707364882@qq.com 707364882@qq.com
CommandCallback.java
in remoting/src/main/java/org/apache/rocketmq/remoting
 4 - 2024-11-20 2024-11-20 1 1 707364882@qq.com 707364882@qq.com
CheckRocksdbCqWriteResult.java
in common/src/main/java/org/apache/rocketmq/common
 30 5 2024-10-29 2024-10-29 1 1 43874697+letletme@users.nor... 43874697+letletme@users.nor...
ConsumerOffsetManagerV2.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v2
 320 14 2024-10-28 2024-12-02 3 1 lizhanhui@apache.org lizhanhui@apache.org
RocksDBSubscriptionGroupManager.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v1
 208 20 2024-10-28 2025-05-06 6 6 lizhanhui@apache.org 707364882@qq.com
ConfigStorage.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v2
 191 13 2024-10-28 2024-12-02 4 1 lizhanhui@apache.org lizhanhui@apache.org
TopicConfigManagerV2.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v2
 145 11 2024-10-28 2024-12-02 3 1 lizhanhui@apache.org lizhanhui@apache.org
SubscriptionGroupManagerV2.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v2
 142 10 2024-10-28 2024-12-02 4 1 lizhanhui@apache.org lizhanhui@apache.org
RocksDBConsumerOffsetManager.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v1
 132 14 2024-10-28 2025-05-06 5 5 lizhanhui@apache.org 707364882@qq.com
RocksDBTopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v1
 128 14 2024-10-28 2025-05-06 5 5 lizhanhui@apache.org 707364882@qq.com
ConfigHelper.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v2
 93 5 2024-10-28 2024-12-02 2 1 lizhanhui@apache.org lizhanhui@apache.org
RocksDBLmqTopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v1
 34 5 2024-10-28 2024-10-28 1 1 lizhanhui@apache.org lizhanhui@apache.org
RocksDBLmqSubscriptionGroupManager.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v1
 33 4 2024-10-28 2024-10-28 1 1 lizhanhui@apache.org lizhanhui@apache.org
SerializationType.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v2
 22 2 2024-10-28 2024-10-28 1 1 lizhanhui@apache.org lizhanhui@apache.org
TableId.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v2
 15 1 2024-10-28 2024-10-28 1 1 lizhanhui@apache.org lizhanhui@apache.org
Most Recently Changed Files (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
AdminBrokerProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 2976 97 2016-12-27 2025-05-06 157 87 yukon@apache.org 707364882@qq.com
PopMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 943 36 2021-03-09 2025-05-06 74 34 ayanamist@gmail.com 707364882@qq.com
PopBufferMergeService.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 769 48 2021-03-09 2025-05-06 30 20 ayanamist@gmail.com 707364882@qq.com
MQVersion.java
in common/src/main/java/org/apache/rocketmq/common
 633 2 2016-12-27 2025-05-06 61 26 yukon@apache.org 707364882@qq.com
PopReviveService.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 624 22 2021-03-09 2025-05-06 47 26 ayanamist@gmail.com 707364882@qq.com
PopConsumerService.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 599 25 2024-12-20 2025-05-06 7 3 707364882@qq.com 707364882@qq.com
ConsumerOrderInfoManager.java
in broker/src/main/java/org/apache/rocketmq/broker/offset
 484 45 2021-03-09 2025-05-06 18 12 ayanamist@gmail.com 707364882@qq.com
AckMessageProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 416 13 2021-03-09 2025-05-06 31 18 ayanamist@gmail.com 707364882@qq.com
IndexStoreService.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index
 367 17 2023-11-21 2025-05-06 8 3 707364882@qq.com 707364882@qq.com
ChangeInvisibleTimeProcessor.java
in broker/src/main/java/org/apache/rocketmq/broker/processor
 307 10 2021-03-09 2025-05-06 26 19 ayanamist@gmail.com 707364882@qq.com
FlatAppendFile.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 227 21 2024-03-18 2025-05-06 6 2 707364882@qq.com 707364882@qq.com
RocksDBSubscriptionGroupManager.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v1
 208 20 2024-10-28 2025-05-06 6 6 lizhanhui@apache.org 707364882@qq.com
TransactionMetrics.java
in broker/src/main/java/org/apache/rocketmq/broker/transaction
 207 25 2024-01-22 2025-05-06 3 3 juntao.jjt@alibaba-inc.com 707364882@qq.com
TopicQueueMappingManager.java
in broker/src/main/java/org/apache/rocketmq/broker/topic
 204 13 2021-11-06 2025-05-06 12 9 dongeforever@apache.org 707364882@qq.com
PopCheckPoint.java
in store/src/main/java/org/apache/rocketmq/store/pop
 148 31 2021-03-09 2025-05-06 15 11 ayanamist@gmail.com 707364882@qq.com
PopConsumerRecord.java
in broker/src/main/java/org/apache/rocketmq/broker/pop
 146 25 2024-12-20 2025-05-06 3 2 707364882@qq.com 707364882@qq.com
RocksDBConsumerOffsetManager.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v1
 132 14 2024-10-28 2025-05-06 5 5 lizhanhui@apache.org 707364882@qq.com
RocksDBTopicConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker/config/v1
 128 14 2024-10-28 2025-05-06 5 5 lizhanhui@apache.org 707364882@qq.com
RocksDBConfigManager.java
in broker/src/main/java/org/apache/rocketmq/broker
 116 14 2024-08-23 2025-05-06 4 3 43874697+letletme@users.nor... 707364882@qq.com
MQClientAPIImpl.java
in client/src/main/java/org/apache/rocketmq/client/impl
 3092 145 2016-12-27 2025-04-30 152 85 yukon@apache.org dingshuangxi888@gmail.com
BrokerController.java
in broker/src/main/java/org/apache/rocketmq/broker
 2119 177 2016-12-27 2025-04-30 188 87 yukon@apache.org dingshuangxi888@gmail.com
DefaultMQAdminExtImpl.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 1791 142 2016-12-27 2025-04-30 111 64 yukon@apache.org dingshuangxi888@gmail.com
BrokerConfig.java
in common/src/main/java/org/apache/rocketmq/common
 1424 399 2016-12-27 2025-04-30 141 63 yukon@apache.org dingshuangxi888@gmail.com
ProxyConfig.java
in proxy/src/main/java/org/apache/rocketmq/proxy/config
 1136 305 2022-03-16 2025-04-30 60 23 jixiang.jjx@alibaba-inc.com dingshuangxi888@gmail.com
DefaultMQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 820 143 2016-12-27 2025-04-30 88 54 yukon@apache.org dingshuangxi888@gmail.com
AsyncTraceDispatcher.java
in client/src/main/java/org/apache/rocketmq/client/trace
 351 29 2018-12-28 2025-04-30 61 50 dongeforever@apache.org wuxingcan.wxc@alibaba-inc.com
MQAdminExt.java
in tools/src/main/java/org/apache/rocketmq/tools/admin
 322 - 2016-12-27 2025-04-30 79 48 yukon@apache.org dingshuangxi888@gmail.com
RemotingProtocolServer.java
in proxy/src/main/java/org/apache/rocketmq/proxy/remoting
 320 14 2022-11-08 2025-04-30 14 10 kaiyi.lk@alibaba-inc.com dingshuangxi888@gmail.com
MQAdminStartup.java
in tools/src/main/java/org/apache/rocketmq/tools/command
 280 6 2016-12-27 2025-04-30 94 53 yukon@apache.org dingshuangxi888@gmail.com
AclUtils.java
in client/src/main/java/org/apache/rocketmq/acl/common
 229 20 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
ProxyStartup.java
in proxy/src/main/java/org/apache/rocketmq/proxy
 194 11 2022-03-11 2025-04-30 35 16 jixiang.jjx@alibaba-inc.com dingshuangxi888@gmail.com
AuthMigrator.java
in auth/src/main/java/org/apache/rocketmq/auth/migration
 191 9 2024-03-18 2025-04-30 3 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
RequestCode.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol
 161 - 2022-11-11 2025-04-30 19 17 admin@lv5.moe dingshuangxi888@gmail.com
SessionCredentials.java
in client/src/main/java/org/apache/rocketmq/acl/common
 122 15 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
PlainAccessResource.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 116 27 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
PlainPermissionManager.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 110 5 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
PlainAccessConfig.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 86 17 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
GrpcServerBuilder.java
in proxy/src/main/java/org/apache/rocketmq/proxy/grpc
 77 8 2022-04-27 2025-04-30 23 17 kaiyi.lk@alibaba-inc.com dingshuangxi888@gmail.com
PlainAccessData.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 68 14 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
ResponseCode.java
in remoting/src/main/java/org/apache/rocketmq/remoting/protocol
 64 - 2022-11-11 2025-04-30 9 8 admin@lv5.moe dingshuangxi888@gmail.com
AclSigner.java
in client/src/main/java/org/apache/rocketmq/acl/common
 63 6 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AuthenticationPipeline.java
in proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline
 40 3 2022-11-17 2025-04-30 5 4 zhouxiang.zzx@alibaba-inc.com dingshuangxi888@gmail.com
AclException.java
in client/src/main/java/org/apache/rocketmq/acl/common
 39 9 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AclClientRPCHook.java
in client/src/main/java/org/apache/rocketmq/acl/common
 33 5 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
Permission.java
in client/src/main/java/org/apache/rocketmq/acl/common
 25 1 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AclConfig.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 25 5 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AclConstants.java
in client/src/main/java/org/apache/rocketmq/acl/common
 10 - 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
SigningAlgorithm.java
in client/src/main/java/org/apache/rocketmq/acl/common
 6 - 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
AccessResource.java
in auth/src/main/java/org/apache/rocketmq/auth/migration/v1
 3 - 2025-04-30 2025-04-30 1 1 dingshuangxi888@gmail.com dingshuangxi888@gmail.com
FlatMessageFile.java
in tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file
 354 38 2024-03-18 2025-04-29 7 4 707364882@qq.com 707364882@qq.com