apache / rocketmq-mqtt
File Size

The distribution of size of files (measured in lines of code).

Intro
Learn more...
File Size Overall
0% | 4% | 25% | 33% | 35%
Legend:
1001+
501-1000
201-500
101-200
1-100


explore: grouped by folders | grouped by size | sunburst | 3D view
File Size per Extension
1001+
501-1000
201-500
101-200
1-100
java0% | 4% | 26% | 34% | 34%
xml0% | 0% | 0% | 30% | 69%
proto0% | 0% | 0% | 0% | 100%
File Size per Logical Decomposition
primary
1001+
501-1000
201-500
101-200
1-100
mqtt-cs0% | 12% | 23% | 37% | 26%
mqtt-common0% | 0% | 41% | 11% | 46%
mqtt-ds0% | 0% | 26% | 32% | 41%
mqtt-exporter0% | 0% | 41% | 38% | 19%
mqtt-meta0% | 0% | 15% | 64% | 19%
style0% | 0% | 0% | 47% | 52%
mqtt-example0% | 0% | 0% | 0% | 100%
distribution0% | 0% | 0% | 0% | 100%
Longest Files (Top 50)
File# lines# units
SessionLoopImpl.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
552 24
Session.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session
415 39
LmqQueueStoreManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store
403 15
StatUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
383 27
MqttHTTPServer.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http
335 35
QueueCache.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
295 13
RetryDriver.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
288 15
Trie.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
265 17
NotifyManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify
246 10
MqttRaftServer.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft
228 12
Message.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
209 33
DefaultChannelManager.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
192 8
ChannelInfo.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
190 31
WillLoop.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
190 5
MqttPacketDispatcher.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt
182 4
PushAction.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
175 8
BackedFileOutputStream.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http
172 16
ConnectConf.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config
163 41
RetainedMsgClient.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
159 4
WillMsgClient.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
148 6
RetainedMsgStateProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor
144 6
MqttSubscribeHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
142 4
MqttMetricsCollector.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector
139 14
FirstTopicManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
137 7
InFlyCache.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
137 17
StateProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor
136 5
TopicUtils.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
132 16
RocksDBSnapshot.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/rocksdb
130 7
MqttServer.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter
130 4
126 -
LmqOffsetStoreManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store
125 3
MatchAction.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/match
124 2
AbstractRpcProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc
120 4
MqttStateMachine.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft
113 9
MessageUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
113 5
ServiceConf.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/config
107 22
DiskUtils.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util
107 7
WildcardManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
105 6
MqttClosure.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft
104 22
MetaConf.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config
102 24
MetaPersistManagerSample.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
96 5
WebSocketServerHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/ws
91 5
MqttConnectHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
90 2
MetaRpcClient.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
88 6
RocksDBEngine.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/rocksdb
86 13
IpUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta
86 5
MqttProducer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
84 3
84 -
MqttWillRetainProducer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
80 3
Queue.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
77 15
Files With Most Units (Top 50)
File# lines# units
ConnectConf.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config
163 41
Session.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session
415 39
MqttHTTPServer.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http
335 35
Message.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
209 33
ChannelInfo.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
190 31
StatUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
383 27
MetaConf.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config
102 24
SessionLoopImpl.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
552 24
ServiceConf.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/config
107 22
MqttClosure.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft
104 22
InFlyCache.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
137 17
Trie.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
265 17
BackedFileOutputStream.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http
172 16
TopicUtils.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
132 16
Subscription.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
73 16
LmqQueueStoreManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store
403 15
RetryDriver.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
288 15
Queue.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
77 15
MqttMetricsCollector.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector
139 14
HookResult.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook
73 14
RocksDBEngine.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/rocksdb
86 13
QueueCache.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
295 13
MqttRaftServer.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft
228 12
NotifyManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify
246 10
QueueOffset.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
40 10
MessageEvent.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
47 10
MqttStateMachine.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft
113 9
MqttMessageFactory.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/facotry
73 9
WillMessage.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
47 9
MqFactory.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
53 8
DefaultChannelManager.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
192 8
PushAction.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
175 8
MqttMessageUpContext.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
31 8
PullResult.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
34 8
FirstTopicManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
137 7
MqConsumer.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
57 7
RocksDBSnapshot.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/rocksdb
130 7
DiskUtils.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/util
107 7
NamespaceUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
32 7
MetaRpcClient.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
88 6
WildcardManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
105 6
WillMsgClient.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
148 6
MqProducer.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
34 6
MqPullConsumer.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
40 6
RetainedMsgStateProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor
144 6
RocketMQProducer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
73 6
MetaPersistManagerSample.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
96 5
TopicNotExistException.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
17 5
WillMsgPersistManagerImpl.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
74 5
MqAdmin.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
28 5
Files With Long Lines (Top 48)

There are 48 files with lines longer than 120 characters. In total, there are 143 long lines.

File# lines# units# long lines
LmqQueueStoreManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store
403 15 10
SessionLoopImpl.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
552 24 10
MqttMetricsCollector.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector
139 14 9
WillMsgClient.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
148 6 7
MqttServer.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter
130 4 7
QueueCache.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
295 13 7
RetainedMsgClient.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
159 4 6
RocksDBSnapshot.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/rocksdb
130 7 6
WillLoop.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
190 5 6
Trie.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
265 17 6
RetryDriver.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
288 15 5
NotifyManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify
246 10 4
AbstractRpcProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc
120 4 4
MqttConnectHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
90 2 4
RocketMQProducer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
73 6 3
MqttSubscribeHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
142 4 3
DefaultChannelManager.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
192 8 3
MessageUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
113 5 3
WillMsgStateProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor
76 4 2
RetainedMsgStateProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor
144 6 2
MqttProducer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
84 3 2
MqttWillRetainConsumer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
73 3 2
MqttWillRetainProducer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
80 3 2
spring.xml
in distribution/conf
21 - 2
PushAction.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly
175 8 2
MqttHTTPServer.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/http
335 35 2
NamespaceUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
32 7 2
HmacSHA1Util.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
21 2 2
AuthManagerSample.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/auth
67 4 1
RetainedPersistManagerImpl.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
60 3 1
TopicNotExistException.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
17 5 1
FirstTopicManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
137 7 1
MqFactory.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/mq
53 8 1
PublishProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor
75 1 1
UpstreamProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream
10 - 1
Startup.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/starter
12 1 1
StateProcessor.java
in mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor
136 5 1
MqttConsumer.java
in mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example
74 3 1
84 - 1
Apache.xml
in style/copyright
6 - 1
MqttUnSubscribeHandler.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler
57 2 1
Session.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session
415 39 1
MqttMetricsInfo.java
in mqtt-exporter/src/main/java/org/apache/rocketmq/mqtt/exporter/collector
62 5 1
TopicUtils.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
132 16 1
IpUtil.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/meta
86 5 1
MessageEvent.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
47 10 1
HookResult.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook
73 14 1
AbstractUpstreamHook.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook
42 3 1
Correlations

File Size vs. Commits (all time): 154 points

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

File Size vs. Contributors (all time): 154 points

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

File Size vs. Commits (30 days): 0 points

No data for "commits (30d)" vs. "lines of code".

File Size vs. Contributors (30 days): 0 points

No data for "contributors (30d)" vs. "lines of code".


File Size vs. Commits (90 days): 0 points

No data for "commits (90d)" vs. "lines of code".

File Size vs. Contributors (90 days): 0 points

No data for "contributors (90d)" vs. "lines of code".