apache / rocketmq-mqtt
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 153 files with 11,907 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 4 files changed 21-50 times (976 lines of code)
    • 68 files changed 6-20 times (6,699 lines of code)
    • 81 files changed 1-5 times (4,232 lines of code)
0% | 0% | 8% | 56% | 35%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 153 files with 11,907 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 1 file changed by 11-25 contributors (90 lines of code)
    • 48 files changed by 6-10 contributors (5,767 lines of code)
    • 96 files changed by 2-5 contributors (5,372 lines of code)
    • 8 files changed by 1 contributor (678 lines of code)
0% | <1% | 48% | 45% | 5%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
java, xml, sh, txt, gitignore, md, proto, json, yml, yaml
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 8% | 57% | 33%
proto0% | 0% | 0% | 100% | 0%
xml0% | 0% | 0% | 5% | 94%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
mqtt-cs0% | 0% | 22% | 46% | 30%
mqtt-ds0% | 0% | 0% | 81% | 18%
mqtt-common0% | 0% | 0% | 69% | 30%
mqtt-meta0% | 0% | 0% | 54% | 45%
mqtt-example0% | 0% | 0% | 63% | 36%
mqtt-exporter0% | 0% | 0% | 21% | 78%
distribution0% | 0% | 0% | 13% | 86%
style0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
SessionLoopImpl.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
 552 24 2022-03-08 2023-02-03 28 8 jinrongtong5@163.com pingw002@gmail.com
MqttConnectHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 90 2 2022-03-08 2023-02-03 22 11 jinrongtong5@163.com pingw002@gmail.com
DefaultChannelManager.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
 192 8 2022-03-08 2023-02-03 22 8 jinrongtong5@163.com pingw002@gmail.com
MqttSubscribeHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 142 4 2022-03-08 2023-02-03 21 10 jinrongtong5@163.com pingw002@gmail.com
MqttServer.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter
 130 4 2022-03-08 2023-02-03 16 10 jinrongtong5@163.com pingw002@gmail.com
Constants.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 27 - 2022-03-08 2023-02-03 14 9 jinrongtong5@163.com pingw002@gmail.com
MqttPubRecHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 33 2 2022-03-08 2023-02-03 14 9 jinrongtong5@163.com pingw002@gmail.com
MqttPublishHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 76 4 2022-03-08 2023-02-03 14 9 jinrongtong5@163.com pingw002@gmail.com
Message.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 209 33 2022-03-08 2023-02-03 14 8 jinrongtong5@163.com pingw002@gmail.com
MqttConsumer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
 74 3 2022-03-08 2023-02-03 13 7 jinrongtong5@163.com pingw002@gmail.com
MqttProducer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
 84 3 2022-03-08 2023-02-03 13 7 jinrongtong5@163.com pingw002@gmail.com
ServiceConf.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/config
 107 22 2022-03-08 2023-02-03 13 7 jinrongtong5@163.com pingw002@gmail.com
TopicUtils.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
 132 16 2022-03-08 2023-02-03 13 9 jinrongtong5@163.com pingw002@gmail.com
ConnectConf.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config
 163 41 2022-03-08 2023-02-03 13 7 jinrongtong5@163.com pingw002@gmail.com
LmqQueueStoreManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store
 403 15 2022-03-08 2023-02-03 13 7 jinrongtong5@163.com pingw002@gmail.com
MqttPingHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 25 2 2022-03-08 2023-02-03 12 8 jinrongtong5@163.com pingw002@gmail.com
MqttUnSubscribeHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 57 2 2022-03-08 2023-02-03 12 8 jinrongtong5@163.com pingw002@gmail.com
proto
request.proto
in mqtt-common/src/main/proto
 58 - 2022-07-08 2023-02-03 12 5 dongyuan.pdy@alibaba-inc.com pingw002@gmail.com
RetainedPersistManagerImpl.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
 60 3 2022-08-01 2023-02-03 12 3 278580633@qq.com pingw002@gmail.com
PublishProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor
 75 1 2022-03-08 2023-02-03 12 6 jinrongtong5@163.com pingw002@gmail.com
Session.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session
 415 39 2022-03-08 2023-02-03 12 8 jinrongtong5@163.com pingw002@gmail.com
Subscription.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 73 16 2022-03-08 2023-02-03 11 8 jinrongtong5@163.com pingw002@gmail.com
PushAction.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
 175 8 2022-03-08 2023-02-03 11 6 jinrongtong5@163.com pingw002@gmail.com
SubscriptionPersistManager.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade
 12 - 2022-04-18 2023-02-03 10 4 pingw002@gmail.com pingw002@gmail.com
MqttPubRelHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 27 2 2022-03-08 2023-02-03 10 7 jinrongtong5@163.com pingw002@gmail.com
SubscribeProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor
 49 1 2022-03-08 2022-07-07 10 6 jinrongtong5@163.com 875713197@qq.com
MqttRaftServer.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft
 228 12 2022-10-21 2023-02-03 10 2 pingw002@gmail.com pingw002@gmail.com
Trie.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 265 17 2022-03-08 2023-02-03 10 7 jinrongtong5@163.com pingw002@gmail.com
UnSubscribeProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor
 45 1 2022-03-08 2022-06-30 9 6 jinrongtong5@163.com 875713197@qq.com
RetainedMsgStateProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor
 144 6 2022-10-21 2023-02-03 9 3 pingw002@gmail.com pingw002@gmail.com
BackedFileOutputStream.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http
 172 16 2022-04-01 2023-02-01 9 5 643422162@qq.com pingw002@gmail.com
MqttPacketDispatcher.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt
 182 4 2022-03-08 2022-05-30 9 7 jinrongtong5@163.com 641234230@qq.com
UpstreamProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream
 10 - 2022-03-08 2023-02-03 8 5 jinrongtong5@163.com pingw002@gmail.com
MqttPubCompHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 34 2 2022-03-08 2022-05-30 8 6 jinrongtong5@163.com 641234230@qq.com
RocketMQConsumer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
 34 2 2022-03-08 2023-02-03 8 6 jinrongtong5@163.com pingw002@gmail.com
MqProducer.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
 34 6 2022-03-08 2022-05-30 8 7 jinrongtong5@163.com 641234230@qq.com
ConnectHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
 35 3 2022-03-08 2022-06-30 8 7 jinrongtong5@163.com 875713197@qq.com
MqttPubAckHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 35 2 2022-03-08 2022-05-30 8 6 jinrongtong5@163.com 641234230@qq.com
MqPullConsumer.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
 40 6 2022-03-08 2022-05-30 8 7 jinrongtong5@163.com 641234230@qq.com
MqFactory.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
 53 8 2022-03-08 2022-05-30 8 7 jinrongtong5@163.com 641234230@qq.com
MqConsumer.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
 57 7 2022-03-08 2022-05-30 8 7 jinrongtong5@163.com 641234230@qq.com
MqttMsgId.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
 58 4 2022-03-08 2022-05-30 8 6 jinrongtong5@163.com 641234230@qq.com
RocketMQProducer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
 73 6 2022-03-08 2023-02-03 8 6 jinrongtong5@163.com pingw002@gmail.com
WillMsgStateProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor
 76 4 2023-01-03 2023-02-03 8 2 dongyuanpan0@gmail.com pingw002@gmail.com
MessageUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
 113 5 2022-03-08 2023-02-03 8 5 jinrongtong5@163.com pingw002@gmail.com
InFlyCache.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
 137 17 2022-03-08 2022-05-30 8 7 jinrongtong5@163.com 641234230@qq.com
RetryDriver.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
 288 15 2022-03-08 2022-05-30 8 6 jinrongtong5@163.com 641234230@qq.com
RetainedPersistManager.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade
 10 - 2022-08-01 2023-02-03 7 2 278580633@qq.com pingw002@gmail.com
Startup.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter
 12 1 2022-03-08 2022-05-30 7 5 jinrongtong5@163.com 641234230@qq.com
SessionLoop.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
 20 - 2022-03-08 2023-02-03 7 6 jinrongtong5@163.com pingw002@gmail.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
MqttConnectHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 90 2 2022-03-08 2023-02-03 22 11 jinrongtong5@163.com pingw002@gmail.com
MqttSubscribeHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 142 4 2022-03-08 2023-02-03 21 10 jinrongtong5@163.com pingw002@gmail.com
MqttServer.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter
 130 4 2022-03-08 2023-02-03 16 10 jinrongtong5@163.com pingw002@gmail.com
MqttPubRecHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 33 2 2022-03-08 2023-02-03 14 9 jinrongtong5@163.com pingw002@gmail.com
MqttPublishHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 76 4 2022-03-08 2023-02-03 14 9 jinrongtong5@163.com pingw002@gmail.com
Constants.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 27 - 2022-03-08 2023-02-03 14 9 jinrongtong5@163.com pingw002@gmail.com
TopicUtils.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
 132 16 2022-03-08 2023-02-03 13 9 jinrongtong5@163.com pingw002@gmail.com
SessionLoopImpl.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
 552 24 2022-03-08 2023-02-03 28 8 jinrongtong5@163.com pingw002@gmail.com
DefaultChannelManager.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
 192 8 2022-03-08 2023-02-03 22 8 jinrongtong5@163.com pingw002@gmail.com
Message.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 209 33 2022-03-08 2023-02-03 14 8 jinrongtong5@163.com pingw002@gmail.com
MqttUnSubscribeHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 57 2 2022-03-08 2023-02-03 12 8 jinrongtong5@163.com pingw002@gmail.com
MqttPingHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 25 2 2022-03-08 2023-02-03 12 8 jinrongtong5@163.com pingw002@gmail.com
Session.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session
 415 39 2022-03-08 2023-02-03 12 8 jinrongtong5@163.com pingw002@gmail.com
Subscription.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 73 16 2022-03-08 2023-02-03 11 8 jinrongtong5@163.com pingw002@gmail.com
ServiceConf.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/config
 107 22 2022-03-08 2023-02-03 13 7 jinrongtong5@163.com pingw002@gmail.com
LmqQueueStoreManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store
 403 15 2022-03-08 2023-02-03 13 7 jinrongtong5@163.com pingw002@gmail.com
MqttConsumer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
 74 3 2022-03-08 2023-02-03 13 7 jinrongtong5@163.com pingw002@gmail.com
MqttProducer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
 84 3 2022-03-08 2023-02-03 13 7 jinrongtong5@163.com pingw002@gmail.com
ConnectConf.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config
 163 41 2022-03-08 2023-02-03 13 7 jinrongtong5@163.com pingw002@gmail.com
MqttPubRelHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 27 2 2022-03-08 2023-02-03 10 7 jinrongtong5@163.com pingw002@gmail.com
Trie.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 265 17 2022-03-08 2023-02-03 10 7 jinrongtong5@163.com pingw002@gmail.com
MqttPacketDispatcher.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt
 182 4 2022-03-08 2022-05-30 9 7 jinrongtong5@163.com 641234230@qq.com
MqProducer.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
 34 6 2022-03-08 2022-05-30 8 7 jinrongtong5@163.com 641234230@qq.com
MqConsumer.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
 57 7 2022-03-08 2022-05-30 8 7 jinrongtong5@163.com 641234230@qq.com
MqPullConsumer.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
 40 6 2022-03-08 2022-05-30 8 7 jinrongtong5@163.com 641234230@qq.com
MqFactory.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
 53 8 2022-03-08 2022-05-30 8 7 jinrongtong5@163.com 641234230@qq.com
ConnectHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
 35 3 2022-03-08 2022-06-30 8 7 jinrongtong5@163.com 875713197@qq.com
InFlyCache.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
 137 17 2022-03-08 2022-05-30 8 7 jinrongtong5@163.com 641234230@qq.com
PublishProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor
 75 1 2022-03-08 2023-02-03 12 6 jinrongtong5@163.com pingw002@gmail.com
PushAction.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
 175 8 2022-03-08 2023-02-03 11 6 jinrongtong5@163.com pingw002@gmail.com
SubscribeProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor
 49 1 2022-03-08 2022-07-07 10 6 jinrongtong5@163.com 875713197@qq.com
UnSubscribeProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor
 45 1 2022-03-08 2022-06-30 9 6 jinrongtong5@163.com 875713197@qq.com
RocketMQProducer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
 73 6 2022-03-08 2023-02-03 8 6 jinrongtong5@163.com pingw002@gmail.com
RocketMQConsumer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
 34 2 2022-03-08 2023-02-03 8 6 jinrongtong5@163.com pingw002@gmail.com
MqttPubAckHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 35 2 2022-03-08 2022-05-30 8 6 jinrongtong5@163.com 641234230@qq.com
MqttPubCompHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
 34 2 2022-03-08 2022-05-30 8 6 jinrongtong5@163.com 641234230@qq.com
MqttMsgId.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
 58 4 2022-03-08 2022-05-30 8 6 jinrongtong5@163.com 641234230@qq.com
RetryDriver.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
 288 15 2022-03-08 2022-05-30 8 6 jinrongtong5@163.com 641234230@qq.com
LmqOffsetStoreManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store
 125 3 2022-03-08 2023-02-03 7 6 jinrongtong5@163.com pingw002@gmail.com
WebSocketServerHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ws
 91 5 2022-03-08 2023-02-03 7 6 jinrongtong5@163.com pingw002@gmail.com
SessionLoop.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
 20 - 2022-03-08 2023-02-03 7 6 jinrongtong5@163.com pingw002@gmail.com
NotifyManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify
 246 10 2022-03-08 2022-04-18 6 6 jinrongtong5@163.com pingw002@gmail.com
ServiceConfListener.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/config
 47 1 2022-03-08 2022-05-30 6 6 jinrongtong5@163.com 641234230@qq.com
FirstTopicManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
 137 7 2022-03-08 2022-05-30 6 6 jinrongtong5@163.com 641234230@qq.com
MqAdmin.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
 28 5 2022-03-08 2022-05-30 6 6 jinrongtong5@163.com 641234230@qq.com
ConnectProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor
 14 1 2022-03-08 2022-05-30 6 6 jinrongtong5@163.com 641234230@qq.com
StatUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
 383 27 2022-03-08 2022-05-30 6 6 jinrongtong5@163.com 641234230@qq.com
NamespaceUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
 32 7 2022-03-08 2022-05-30 6 6 jinrongtong5@163.com 641234230@qq.com
SslFactory.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ssl
 54 2 2022-06-11 2022-10-21 4 6 782773117@qq.com dongyuanpan0@gmail.com
proto
request.proto
in mqtt-common/src/main/proto
 58 - 2022-07-08 2023-02-03 12 5 dongyuan.pdy@alibaba-inc.com pingw002@gmail.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
WillLoop.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
 190 5 2023-02-01 2023-02-03 2 1 pingw002@gmail.com pingw002@gmail.com
RocksDBSnapshot.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/rocksdb
 130 7 2023-01-29 2023-02-03 3 1 pingw002@gmail.com pingw002@gmail.com
RocksDBEngine.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/rocksdb
 86 13 2023-01-29 2023-02-03 3 1 pingw002@gmail.com pingw002@gmail.com
IpUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta
 86 5 2023-01-29 2023-02-03 3 1 pingw002@gmail.com pingw002@gmail.com
MqttWillRetainProducer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
 80 3 2023-01-29 2023-02-03 3 1 pingw002@gmail.com pingw002@gmail.com
MqttWillRetainConsumer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
 73 3 2023-01-29 2023-02-03 3 1 pingw002@gmail.com pingw002@gmail.com
RaftUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta
 26 2 2023-01-29 2023-02-03 3 1 pingw002@gmail.com pingw002@gmail.com
Constants.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta
 7 - 2023-01-29 2023-02-03 3 1 pingw002@gmail.com pingw002@gmail.com
MqttHTTPServer.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http
 335 35 2022-04-01 2022-04-18 2 2 643422162@qq.com pingw002@gmail.com
MqttRaftServer.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft
 228 12 2022-10-21 2023-02-03 10 2 pingw002@gmail.com pingw002@gmail.com
RetainedMsgClient.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
 159 4 2023-01-03 2023-02-03 6 2 dongyuanpan0@gmail.com pingw002@gmail.com
WillMsgClient.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
 148 6 2023-01-03 2023-02-03 6 2 dongyuanpan0@gmail.com pingw002@gmail.com
MqttMetricsCollector.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector
 139 14 2022-04-01 2022-04-18 3 2 643422162@qq.com pingw002@gmail.com
StateProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor
 136 5 2022-10-21 2023-02-03 6 2 pingw002@gmail.com pingw002@gmail.com
126 - 2022-03-09 2022-03-10 2 2 643422162@qq.com libya_003@163.com
AbstractRpcProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc
 120 4 2022-10-31 2023-02-03 5 2 dongyuanpan0@gmail.com pingw002@gmail.com
MqttStateMachine.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft
 113 9 2022-10-21 2023-02-03 7 2 pingw002@gmail.com pingw002@gmail.com
DiskUtils.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util
 107 7 2022-10-21 2023-02-03 2 2 pingw002@gmail.com pingw002@gmail.com
MqttClosure.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft
 104 22 2022-10-21 2023-02-03 2 2 pingw002@gmail.com pingw002@gmail.com
MetaConf.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config
 102 24 2022-10-21 2023-02-03 6 2 pingw002@gmail.com pingw002@gmail.com
MetaRpcClient.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
 88 6 2023-01-03 2023-02-03 5 2 dongyuanpan0@gmail.com pingw002@gmail.com
84 - 2022-03-09 2022-03-10 2 2 643422162@qq.com libya_003@163.com
WillMsgStateProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor
 76 4 2023-01-03 2023-02-03 8 2 dongyuanpan0@gmail.com pingw002@gmail.com
WillMsgPersistManagerImpl.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
 74 5 2023-01-03 2023-02-03 3 2 dongyuanpan0@gmail.com pingw002@gmail.com
logback.xml
in distribution/conf
 68 - 2022-08-26 2022-10-21 2 2 pingw002@gmail.com dongyuanpan0@gmail.com
MqttMetricsInfo.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector
 62 5 2022-04-01 2022-04-18 3 2 643422162@qq.com pingw002@gmail.com
release.xml
in distribution
 48 - 2022-08-26 2023-02-03 5 2 pingw002@gmail.com pingw002@gmail.com
MetaConfListener.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config
 47 1 2022-10-21 2023-02-03 2 2 pingw002@gmail.com pingw002@gmail.com
profiles_settings.xml
in style/copyright
 47 - 2022-03-09 2022-03-10 2 2 643422162@qq.com libya_003@163.com
MetricsBuilderFactory.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector
 39 4 2022-04-01 2022-04-18 2 2 643422162@qq.com pingw002@gmail.com
ExporterServer.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter
 30 2 2022-04-01 2022-04-18 3 2 643422162@qq.com pingw002@gmail.com
MqttExporter.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter
 30 3 2022-04-01 2022-04-18 3 2 643422162@qq.com pingw002@gmail.com
MqttReadRpcProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc
 24 3 2022-10-31 2023-02-03 5 2 dongyuanpan0@gmail.com pingw002@gmail.com
spring.xml
in distribution/conf
 21 - 2022-08-26 2023-02-03 6 2 pingw002@gmail.com pingw002@gmail.com
MqttWriteRpcProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc
 19 3 2022-10-31 2023-02-03 3 2 dongyuanpan0@gmail.com pingw002@gmail.com
SpringUtil.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util
 18 4 2022-10-21 2023-02-03 2 2 pingw002@gmail.com pingw002@gmail.com
SubSystem.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector
 18 2 2022-04-01 2022-04-18 2 2 643422162@qq.com pingw002@gmail.com
ChannelDecodeException.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
 17 5 2022-04-11 2022-04-18 2 2 aliensb@live.com pingw002@gmail.com
meta_spring.xml
in distribution/conf
 16 - 2022-10-31 2023-02-03 3 2 dongyuanpan0@gmail.com pingw002@gmail.com
WebSocketEncoder.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ws
 14 1 2022-04-18 2022-04-19 2 2 xyong.ac@gmail.com pingw002@gmail.com
Startup.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/starter
 12 1 2022-10-21 2023-02-03 4 2 pingw002@gmail.com pingw002@gmail.com
PrometheusException.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/exception
 12 3 2022-04-01 2022-04-18 2 2 643422162@qq.com pingw002@gmail.com
RetainedPersistManager.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade
 10 - 2022-08-01 2023-02-03 7 2 278580633@qq.com pingw002@gmail.com
WillMsgPersistManager.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade
 10 - 2023-01-03 2023-02-03 3 2 dongyuanpan0@gmail.com pingw002@gmail.com
FailoverClosure.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft
 7 - 2022-10-21 2023-02-03 2 2 pingw002@gmail.com pingw002@gmail.com
Apache.xml
in style/copyright
 6 - 2022-03-09 2022-03-10 2 2 643422162@qq.com libya_003@163.com
RetainedMsgStateProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor
 144 6 2022-10-21 2023-02-03 9 3 pingw002@gmail.com pingw002@gmail.com
RetainedPersistManagerImpl.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
 60 3 2022-08-01 2023-02-03 12 3 278580633@qq.com pingw002@gmail.com
WillMessage.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 47 9 2022-06-06 2023-02-03 6 3 875713197@qq.com pingw002@gmail.com
SpringUtils.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
 19 2 2022-04-18 2022-05-30 6 3 pingw002@gmail.com 641234230@qq.com
Correlations

File Size vs. Number of Changes: 154 points

distribution/conf/meta_spring.xml x: 16 lines of code y: 3 # changes distribution/conf/spring.xml x: 21 lines of code y: 6 # changes distribution/release.xml x: 48 lines of code y: 5 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/RetainedPersistManager.java x: 10 lines of code y: 7 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/SubscriptionPersistManager.java x: 12 lines of code y: 10 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/WillMsgPersistManager.java x: 10 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook/AbstractUpstreamHook.java x: 42 lines of code y: 7 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta/Constants.java x: 7 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta/IpUtil.java x: 86 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta/RaftUtil.java x: 26 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Constants.java x: 27 lines of code y: 14 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Message.java x: 209 lines of code y: 14 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Subscription.java x: 73 lines of code y: 11 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Trie.java x: 265 lines of code y: 10 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/WillMessage.java x: 47 lines of code y: 6 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/MessageUtil.java x: 113 lines of code y: 8 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/TopicUtils.java x: 132 lines of code y: 13 # changes mqtt-common/src/main/proto/request.proto x: 58 lines of code y: 12 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/DefaultChannelManager.java x: 192 lines of code y: 22 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConf.java x: 163 lines of code y: 13 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/facotry/MqttMessageFactory.java x: 73 lines of code y: 5 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttConnectHandler.java x: 90 lines of code y: 22 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPingHandler.java x: 25 lines of code y: 12 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPubRecHandler.java x: 33 lines of code y: 14 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPubRelHandler.java x: 27 lines of code y: 10 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPublishHandler.java x: 76 lines of code y: 14 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttSubscribeHandler.java x: 142 lines of code y: 21 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttUnSubscribeHandler.java x: 57 lines of code y: 12 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ws/WebSocketServerHandler.java x: 91 lines of code y: 7 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java x: 415 lines of code y: 12 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/PushAction.java x: 175 lines of code y: 11 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoop.java x: 20 lines of code y: 7 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java x: 552 lines of code y: 28 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java x: 190 lines of code y: 2 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java x: 130 lines of code y: 16 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/config/ServiceConf.java x: 107 lines of code y: 13 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/MetaRpcClient.java x: 88 lines of code y: 5 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java x: 159 lines of code y: 6 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedPersistManagerImpl.java x: 60 lines of code y: 12 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java x: 148 lines of code y: 6 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java x: 74 lines of code y: 3 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store/LmqOffsetStoreManager.java x: 125 lines of code y: 7 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store/LmqQueueStoreManager.java x: 403 lines of code y: 13 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/UpstreamProcessor.java x: 10 lines of code y: 8 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/UpstreamProcessorManager.java x: 55 lines of code y: 7 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/PublishProcessor.java x: 75 lines of code y: 12 # changes mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttConsumer.java x: 74 lines of code y: 13 # changes mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttProducer.java x: 84 lines of code y: 13 # changes mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainConsumer.java x: 73 lines of code y: 3 # changes mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainProducer.java x: 80 lines of code y: 3 # changes mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/RocketMQConsumer.java x: 34 lines of code y: 8 # changes mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/RocketMQProducer.java x: 73 lines of code y: 8 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConf.java x: 102 lines of code y: 6 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConfListener.java x: 47 lines of code y: 2 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/FailoverClosure.java x: 7 lines of code y: 2 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttClosure.java x: 104 lines of code y: 2 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java x: 228 lines of code y: 10 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttStateMachine.java x: 113 lines of code y: 7 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java x: 144 lines of code y: 9 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/StateProcessor.java x: 136 lines of code y: 6 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/WillMsgStateProcessor.java x: 76 lines of code y: 8 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc/AbstractRpcProcessor.java x: 120 lines of code y: 5 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc/MqttReadRpcProcessor.java x: 24 lines of code y: 5 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc/MqttWriteRpcProcessor.java x: 19 lines of code y: 3 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/rocksdb/RocksDBSnapshot.java x: 130 lines of code y: 3 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/starter/Startup.java x: 12 lines of code y: 4 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util/DiskUtils.java x: 107 lines of code y: 2 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util/SpringUtil.java x: 18 lines of code y: 2 # changes mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http/BackedFileOutputStream.java x: 172 lines of code y: 9 # changes distribution/conf/logback.xml x: 68 lines of code y: 2 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ssl/SslFactory.java x: 54 lines of code y: 4 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/SubscribeProcessor.java x: 49 lines of code y: 10 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/ConnectHandler.java x: 35 lines of code y: 8 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/UnSubscribeProcessor.java x: 45 lines of code y: 9 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/NamespaceUtil.java x: 32 lines of code y: 6 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/SpringUtils.java x: 19 lines of code y: 6 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/StatUtil.java x: 383 lines of code y: 6 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/MqttPacketDispatcher.java x: 182 lines of code y: 9 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/MqttPacketHandler.java x: 8 lines of code y: 6 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttDisconnectHandler.java x: 22 lines of code y: 6 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/InFlyCache.java x: 137 lines of code y: 8 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/MqttMsgId.java x: 58 lines of code y: 8 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/RetryDriver.java x: 288 lines of code y: 8 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/Startup.java x: 12 lines of code y: 7 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/FirstTopicManager.java x: 137 lines of code y: 6 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq/MqAdmin.java x: 28 lines of code y: 6 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq/MqConsumer.java x: 57 lines of code y: 8 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq/MqFactory.java x: 53 lines of code y: 8 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq/MqPullConsumer.java x: 40 lines of code y: 8 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/ConnectProcessor.java x: 14 lines of code y: 6 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ws/WebSocketEncoder.java x: 14 lines of code y: 2 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/ChannelDecodeException.java x: 17 lines of code y: 2 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConfListener.java x: 47 lines of code y: 5 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java x: 295 lines of code y: 5 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/match/MatchAction.java x: 124 lines of code y: 5 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/ExporterServer.java x: 30 lines of code y: 3 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WildcardManager.java x: 105 lines of code y: 6 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java x: 246 lines of code y: 6 # changes mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/MetricsBuilderFactory.java x: 39 lines of code y: 2 # changes mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/MqttMetricsCollector.java x: 139 lines of code y: 3 # changes mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/MqttMetricsInfo.java x: 62 lines of code y: 3 # changes mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/exception/PrometheusException.java x: 12 lines of code y: 2 # changes mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http/MqttHTTPServer.java x: 335 lines of code y: 2 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/ChannelInfo.java x: 190 lines of code y: 4 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/LmqQueueStore.java x: 17 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/AuthManager.java x: 6 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook/Hook.java x: 5 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook/UpstreamHookManager.java x: 8 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MessageEvent.java x: 47 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MqttMessageUpContext.java x: 31 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MqttTopic.java x: 21 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/PullResult.java x: 34 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java x: 77 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/QueueOffset.java x: 40 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Remark.java x: 11 lines of code y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/RpcHeader.java x: 4 lines of code y: 3 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/ChannelManager.java x: 9 lines of code y: 3 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/rpc/RpcPacketDispatcher.java x: 55 lines of code y: 3 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ws/WebsocketEncoder.java x: 14 lines of code y: 3 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/notify/MessageNotifyAction.java x: 59 lines of code y: 3 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/RpcServer.java x: 37 lines of code y: 3 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/auth/AuthManagerSample.java x: 67 lines of code y: 3 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/MetaPersistManagerSample.java x: 96 lines of code y: 3 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyRetryManager.java x: 69 lines of code y: 3 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/BaseProcessor.java x: 15 lines of code y: 3 # changes style/copyright/Apache.xml x: 6 lines of code y: 2 # changes style/rmq_checkstyle.xml x: 84 lines of code y: 2 # changes style/rmq_codeStyle.xml x: 126 lines of code y: 2 # changes
28.0
# changes
  min: 2.0
  average: 6.16
  25th percentile: 3.0
  median: 5.0
  75th percentile: 8.0
  max: 28.0
0 552.0
lines of code
min: 4.0 | average: 77.41 | 25th percentile: 18.0 | median: 47.0 | 75th percentile: 104.25 | max: 552.0

Number of Contributors vs. Number of Changes: 154 points

distribution/conf/meta_spring.xml x: 2 # contributors y: 3 # changes distribution/conf/spring.xml x: 2 # contributors y: 6 # changes distribution/release.xml x: 2 # contributors y: 5 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/RetainedPersistManager.java x: 2 # contributors y: 7 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/SubscriptionPersistManager.java x: 4 # contributors y: 10 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook/AbstractUpstreamHook.java x: 5 # contributors y: 7 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta/Constants.java x: 1 # contributors y: 3 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Constants.java x: 9 # contributors y: 14 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Message.java x: 8 # contributors y: 14 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Subscription.java x: 8 # contributors y: 11 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Trie.java x: 7 # contributors y: 10 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/WillMessage.java x: 3 # contributors y: 6 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/MessageUtil.java x: 5 # contributors y: 8 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/TopicUtils.java x: 9 # contributors y: 13 # changes mqtt-common/src/main/proto/request.proto x: 5 # contributors y: 12 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/DefaultChannelManager.java x: 8 # contributors y: 22 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConf.java x: 7 # contributors y: 13 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/facotry/MqttMessageFactory.java x: 5 # contributors y: 5 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttConnectHandler.java x: 11 # contributors y: 22 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPingHandler.java x: 8 # contributors y: 12 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttSubscribeHandler.java x: 10 # contributors y: 21 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ws/WebSocketServerHandler.java x: 6 # contributors y: 7 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/PushAction.java x: 6 # contributors y: 11 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java x: 8 # contributors y: 28 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java x: 1 # contributors y: 2 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java x: 10 # contributors y: 16 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedPersistManagerImpl.java x: 3 # contributors y: 12 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/PublishProcessor.java x: 6 # contributors y: 12 # changes mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/RocketMQConsumer.java x: 6 # contributors y: 8 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConfListener.java x: 2 # contributors y: 2 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java x: 2 # contributors y: 10 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java x: 3 # contributors y: 9 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/WillMsgStateProcessor.java x: 2 # contributors y: 8 # changes mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/starter/Startup.java x: 2 # contributors y: 4 # changes mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http/BackedFileOutputStream.java x: 5 # contributors y: 9 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ssl/SslFactory.java x: 6 # contributors y: 4 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/SubscribeProcessor.java x: 6 # contributors y: 10 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/ConnectHandler.java x: 7 # contributors y: 8 # changes mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/UnSubscribeProcessor.java x: 6 # contributors y: 9 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/NamespaceUtil.java x: 6 # contributors y: 6 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/MqttPacketDispatcher.java x: 7 # contributors y: 9 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/MqttPacketHandler.java x: 5 # contributors y: 6 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java x: 4 # contributors y: 5 # changes mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/ChannelInfo.java x: 5 # contributors y: 4 # changes mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/LmqQueueStore.java x: 4 # contributors y: 3 # changes
28.0
# changes
  min: 2.0
  average: 6.16
  25th percentile: 3.0
  median: 5.0
  75th percentile: 8.0
  max: 28.0
0 11.0
# contributors
min: 1.0 | average: 4.4 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 6.0 | max: 11.0

Number of Contributors vs. File Size: 154 points

distribution/conf/meta_spring.xml x: 2 # contributors y: 16 lines of code distribution/conf/spring.xml x: 2 # contributors y: 21 lines of code distribution/release.xml x: 2 # contributors y: 48 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/RetainedPersistManager.java x: 2 # contributors y: 10 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/SubscriptionPersistManager.java x: 4 # contributors y: 12 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook/AbstractUpstreamHook.java x: 5 # contributors y: 42 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta/Constants.java x: 1 # contributors y: 7 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta/IpUtil.java x: 1 # contributors y: 86 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta/RaftUtil.java x: 1 # contributors y: 26 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Constants.java x: 9 # contributors y: 27 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Message.java x: 8 # contributors y: 209 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Subscription.java x: 8 # contributors y: 73 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Trie.java x: 7 # contributors y: 265 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/WillMessage.java x: 3 # contributors y: 47 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/MessageUtil.java x: 5 # contributors y: 113 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/TopicUtils.java x: 9 # contributors y: 132 lines of code mqtt-common/src/main/proto/request.proto x: 5 # contributors y: 58 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/DefaultChannelManager.java x: 8 # contributors y: 192 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConf.java x: 7 # contributors y: 163 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/facotry/MqttMessageFactory.java x: 5 # contributors y: 73 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttConnectHandler.java x: 11 # contributors y: 90 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPingHandler.java x: 8 # contributors y: 25 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPubRecHandler.java x: 9 # contributors y: 33 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPubRelHandler.java x: 7 # contributors y: 27 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPublishHandler.java x: 9 # contributors y: 76 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttSubscribeHandler.java x: 10 # contributors y: 142 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttUnSubscribeHandler.java x: 8 # contributors y: 57 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ws/WebSocketServerHandler.java x: 6 # contributors y: 91 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java x: 8 # contributors y: 415 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/PushAction.java x: 6 # contributors y: 175 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoop.java x: 6 # contributors y: 20 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java x: 8 # contributors y: 552 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java x: 1 # contributors y: 190 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java x: 10 # contributors y: 130 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/config/ServiceConf.java x: 7 # contributors y: 107 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/MetaRpcClient.java x: 2 # contributors y: 88 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java x: 2 # contributors y: 159 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedPersistManagerImpl.java x: 3 # contributors y: 60 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java x: 2 # contributors y: 148 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java x: 2 # contributors y: 74 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store/LmqOffsetStoreManager.java x: 6 # contributors y: 125 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store/LmqQueueStoreManager.java x: 7 # contributors y: 403 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/UpstreamProcessor.java x: 5 # contributors y: 10 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/UpstreamProcessorManager.java x: 5 # contributors y: 55 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/PublishProcessor.java x: 6 # contributors y: 75 lines of code mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttConsumer.java x: 7 # contributors y: 74 lines of code mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttProducer.java x: 7 # contributors y: 84 lines of code mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainConsumer.java x: 1 # contributors y: 73 lines of code mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainProducer.java x: 1 # contributors y: 80 lines of code mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/RocketMQConsumer.java x: 6 # contributors y: 34 lines of code mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/RocketMQProducer.java x: 6 # contributors y: 73 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConf.java x: 2 # contributors y: 102 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConfListener.java x: 2 # contributors y: 47 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/FailoverClosure.java x: 2 # contributors y: 7 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttClosure.java x: 2 # contributors y: 104 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java x: 2 # contributors y: 228 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttStateMachine.java x: 2 # contributors y: 113 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/RetainedMsgStateProcessor.java x: 3 # contributors y: 144 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/StateProcessor.java x: 2 # contributors y: 136 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc/AbstractRpcProcessor.java x: 2 # contributors y: 120 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc/MqttReadRpcProcessor.java x: 2 # contributors y: 24 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc/MqttWriteRpcProcessor.java x: 2 # contributors y: 19 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/rocksdb/RocksDBSnapshot.java x: 1 # contributors y: 130 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/starter/Startup.java x: 2 # contributors y: 12 lines of code mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util/DiskUtils.java x: 2 # contributors y: 107 lines of code mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http/BackedFileOutputStream.java x: 5 # contributors y: 172 lines of code distribution/conf/logback.xml x: 2 # contributors y: 68 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ssl/SslFactory.java x: 6 # contributors y: 54 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/SubscribeProcessor.java x: 6 # contributors y: 49 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/ConnectHandler.java x: 7 # contributors y: 35 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/UnSubscribeProcessor.java x: 6 # contributors y: 45 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/NamespaceUtil.java x: 6 # contributors y: 32 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/SpringUtils.java x: 3 # contributors y: 19 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/StatUtil.java x: 6 # contributors y: 383 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/MqttPacketDispatcher.java x: 7 # contributors y: 182 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/MqttPacketHandler.java x: 5 # contributors y: 8 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttDisconnectHandler.java x: 5 # contributors y: 22 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPubAckHandler.java x: 6 # contributors y: 35 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/InFlyCache.java x: 7 # contributors y: 137 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/MqttMsgId.java x: 6 # contributors y: 58 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/RetryDriver.java x: 6 # contributors y: 288 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/Startup.java x: 5 # contributors y: 12 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/config/ServiceConfListener.java x: 6 # contributors y: 47 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/FirstTopicManager.java x: 6 # contributors y: 137 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq/MqAdmin.java x: 6 # contributors y: 28 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq/MqConsumer.java x: 7 # contributors y: 57 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq/MqFactory.java x: 7 # contributors y: 53 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq/MqProducer.java x: 7 # contributors y: 34 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq/MqPullConsumer.java x: 7 # contributors y: 40 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor/ConnectProcessor.java x: 6 # contributors y: 14 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ws/WebSocketEncoder.java x: 2 # contributors y: 14 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConfListener.java x: 5 # contributors y: 47 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java x: 4 # contributors y: 295 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/match/MatchAction.java x: 5 # contributors y: 124 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/ExporterServer.java x: 2 # contributors y: 30 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WildcardManager.java x: 5 # contributors y: 105 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyManager.java x: 6 # contributors y: 246 lines of code mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/MetricsBuilderFactory.java x: 2 # contributors y: 39 lines of code mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/MqttMetricsCollector.java x: 2 # contributors y: 139 lines of code mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector/MqttMetricsInfo.java x: 2 # contributors y: 62 lines of code mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http/MqttHTTPServer.java x: 2 # contributors y: 335 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/ChannelInfo.java x: 5 # contributors y: 190 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/LmqQueueStore.java x: 4 # contributors y: 17 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/AuthManager.java x: 4 # contributors y: 6 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/LmqOffsetStore.java x: 4 # contributors y: 10 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade/MetaPersistManager.java x: 4 # contributors y: 7 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook/HookResult.java x: 4 # contributors y: 73 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MessageEvent.java x: 4 # contributors y: 47 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MqttMessageUpContext.java x: 4 # contributors y: 31 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MqttTopic.java x: 4 # contributors y: 21 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/PullResult.java x: 4 # contributors y: 34 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java x: 4 # contributors y: 77 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/QueueOffset.java x: 4 # contributors y: 40 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/RpcHeader.java x: 4 # contributors y: 4 lines of code mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util/HostInfo.java x: 4 # contributors y: 30 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/rpc/RpcPacketDispatcher.java x: 4 # contributors y: 55 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ws/WebsocketEncoder.java x: 4 # contributors y: 14 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/notify/MessageNotifyAction.java x: 4 # contributors y: 59 lines of code mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/RpcServer.java x: 4 # contributors y: 37 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/auth/AuthManagerSample.java x: 4 # contributors y: 67 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/MetaPersistManagerSample.java x: 4 # contributors y: 96 lines of code mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify/NotifyRetryManager.java x: 4 # contributors y: 69 lines of code style/copyright/Apache.xml x: 2 # contributors y: 6 lines of code style/rmq_checkstyle.xml x: 2 # contributors y: 84 lines of code style/rmq_codeStyle.xml x: 2 # contributors y: 126 lines of code
552.0
lines of code
  min: 4.0
  average: 77.41
  25th percentile: 18.0
  median: 47.0
  75th percentile: 104.25
  max: 552.0
0 11.0
# contributors
min: 1.0 | average: 4.4 | 25th percentile: 2.0 | median: 4.0 | 75th percentile: 6.0 | max: 11.0