apache / rocketmq-mqtt
File Age & Freshness

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

Summary
File Change History Overall
File Age Distribution Overall
Days since first update
  • There are 153 files with 11,907 lines of code in files.
    • 120 files that are 366+ days old (9,267 lines of code)
    • 33 files that are 181-365 days old (2,640 lines of code)
    • 0 files that are 91-180 days old (0 lines of code)
    • 0 files that are 31-90 days old (0 lines of code)
    • 0 files that are 1-30 days old (0 lines of code)
77% | 22% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by age
File Freshness Distribution Overall
Days since last update
  • There are 153 files with 11,907 lines of code in files.
    • 81 files have been last changed 366+ days ago (4,765 lines of code)
    • 72 files have been last changed 181-365 days ago (7,142 lines of code)
    • 0 files have been last changed 91-180 days ago (0 lines of code)
    • 0 files have been last changed 31-90 days ago (0 lines of code)
    • 0 files have been last changed 1-30 days ago (0 lines of code)
40% | 59% | 0% | 0% | 0%
Legend:
366+
181-365
91-180
31-90
1-30

explore: grouped by folders | grouped by freshness
File Change History per File Extension
java, xml, sh, txt, gitignore, md, proto, json, yml, yaml
File Age Distribution per Extension
Days since first update
366+
181-365
91-180
31-90
1-30
java78% | 21% | 0% | 0% | 0%
xml63% | 36% | 0% | 0% | 0%
proto100% | 0% | 0% | 0% | 0%
File Freshness Distribution per Extension
Days since last update
366+
181-365
91-180
31-90
1-30
java39% | 60% | 0% | 0% | 0%
xml63% | 36% | 0% | 0% | 0%
proto0% | 100% | 0% | 0% | 0%
File Change History per Logical Decomposition
primary
primary (file age distribution)
Days since first update
366+
181-365
91-180
31-90
1-30
mqtt-cs93% | 6% | 0% | 0% | 0%
mqtt-ds80% | 19% | 0% | 0% | 0%
mqtt-common93% | 6% | 0% | 0% | 0%
mqtt-exporter100% | 0% | 0% | 0% | 0%
mqtt-example63% | 36% | 0% | 0% | 0%
style100% | 0% | 0% | 0% | 0%
mqtt-meta0% | 100% | 0% | 0% | 0%
distribution0% | 100% | 0% | 0% | 0%
primary (file freshness distribution)
Days since last update
366+
181-365
91-180
31-90
1-30
mqtt-cs41% | 58% | 0% | 0% | 0%
mqtt-ds46% | 53% | 0% | 0% | 0%
mqtt-common45% | 54% | 0% | 0% | 0%
mqtt-exporter78% | 21% | 0% | 0% | 0%
style100% | 0% | 0% | 0% | 0%
mqtt-meta0% | 100% | 0% | 0% | 0%
mqtt-example0% | 100% | 0% | 0% | 0%
distribution0% | 100% | 0% | 0% | 0%
Oldest Files (Top 50)
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
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
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
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
QueueCache.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
 295 13 2022-03-08 2022-04-18 5 4 jinrongtong5@163.com pingw002@gmail.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
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
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
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
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
ChannelInfo.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
 190 31 2022-03-08 2022-04-06 4 5 jinrongtong5@163.com xyong.ac@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
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
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
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
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
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
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
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
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
MatchAction.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/match
 124 2 2022-03-08 2022-04-18 5 5 jinrongtong5@163.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
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
WildcardManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
 105 6 2022-03-08 2022-04-18 6 5 643422162@qq.com pingw002@gmail.com
MetaPersistManagerSample.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
 96 5 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.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
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
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
Queue.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 77 15 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.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
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
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
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
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
HookResult.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook
 73 14 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
NotifyRetryManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify
 69 3 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
AuthManagerSample.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/auth
 67 4 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
MessageNotifyAction.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/notify
 59 2 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.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
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
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
UpstreamProcessorManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream
 55 2 2022-03-08 2023-02-03 7 5 jinrongtong5@163.com pingw002@gmail.com
RpcPacketDispatcher.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/rpc
 55 4 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.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
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
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
ConnectConfListener.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config
 47 1 2022-03-08 2022-04-18 5 5 jinrongtong5@163.com pingw002@gmail.com
UpstreamHookManagerImpl.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/hook
 47 3 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
MessageEvent.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 47 10 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.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
Files Not Recently Changed (Top 50)
File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
TrieMethod.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 4 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
RpcHeader.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 4 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
Hook.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook
 5 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
UpstreamHookEnum.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook
 5 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
PullResultStatus.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop
 5 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
ChannelCloseFrom.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
 5 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
AuthManager.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade
 6 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
Apache.xml
in style/copyright
 6 - 2022-03-09 2022-03-10 2 2 643422162@qq.com libya_003@163.com
UpstreamHook.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook
 7 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
RpcCode.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 7 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
MetaPersistManager.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade
 7 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
UpstreamHookManager.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook
 8 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
ChannelManager.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
 9 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
LmqOffsetStore.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade
 10 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
Remark.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 11 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
DisconnectProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor
 14 1 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
BaseProcessor.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream/processor
 15 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
TrieException.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 16 5 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
StoreResult.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 17 4 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
LmqQueueStore.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/facade
 17 - 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
ChannelException.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
 17 5 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
TopicNotExistException.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
 17 5 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
MqttTopic.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 21 5 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
HmacSHA1Util.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
 21 2 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
HostInfo.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/util
 30 4 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
MqttMessageUpContext.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 31 8 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
PullResult.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 34 8 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
RpcServer.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter
 37 1 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
QueueOffset.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 40 10 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
QueueFresh.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session
 40 1 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
MessageEvent.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 47 10 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
UpstreamHookManagerImpl.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/hook
 47 3 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
profiles_settings.xml
in style/copyright
 47 - 2022-03-09 2022-03-10 2 2 643422162@qq.com libya_003@163.com
RpcPacketDispatcher.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/rpc
 55 4 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
MessageNotifyAction.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/notify
 59 2 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
AuthManagerSample.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/auth
 67 4 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
NotifyRetryManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/notify
 69 3 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
HookResult.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook
 73 14 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
Queue.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model
 77 15 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
84 - 2022-03-09 2022-03-10 2 2 643422162@qq.com libya_003@163.com
MetaPersistManagerSample.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta
 96 5 2022-03-08 2022-03-10 3 4 jinrongtong5@163.com libya_003@163.com
126 - 2022-03-09 2022-03-10 2 2 643422162@qq.com libya_003@163.com
ChannelInfo.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel
 190 31 2022-03-08 2022-04-06 4 5 jinrongtong5@163.com xyong.ac@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
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
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
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
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
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
ConnectConfListener.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config
 47 1 2022-03-08 2022-04-18 5 5 jinrongtong5@163.com pingw002@gmail.com
Most Recently Created Files (Top 50)
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
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
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
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
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
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
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
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
meta_spring.xml
in distribution/conf
 16 - 2022-10-31 2023-02-03 3 2 dongyuanpan0@gmail.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
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
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
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
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
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
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
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
logback.xml
in distribution/conf
 68 - 2022-08-26 2022-10-21 2 2 pingw002@gmail.com dongyuanpan0@gmail.com
release.xml
in distribution
 48 - 2022-08-26 2023-02-03 5 2 pingw002@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
MqttMessageFactory.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/facotry
 73 9 2022-08-12 2023-02-03 5 5 ruolinwzw1@163.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
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
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
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
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
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
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
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
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
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
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
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
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
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
Most Recently Changed Files (Top 50)
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
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
MqttMessageFactory.java
in mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/facotry
 73 9 2022-08-12 2023-02-03 5 5 ruolinwzw1@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
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
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
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
UpstreamProcessorManager.java
in mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/upstream
 55 2 2022-03-08 2023-02-03 7 5 jinrongtong5@163.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
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
AbstractUpstreamHook.java
in mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/hook
 42 3 2022-03-08 2023-02-03 7 5 jinrongtong5@163.com pingw002@gmail.com