duplicated block id: 1 size: 23 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttConsumer.java (66:98) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainConsumer.java (65:97) duplicated block id: 2 size: 18 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttProducer.java (42:66) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainProducer.java (44:68) duplicated block id: 3 size: 14 cleaned lines of code in 2 files: - distribution/conf/meta_spring.xml (1:28) - distribution/conf/spring.xml (1:30) duplicated block id: 4 size: 12 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttProducer.java (96:109) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainProducer.java (92:105) duplicated block id: 5 size: 12 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainConsumer.java (84:97) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainProducer.java (92:105) duplicated block id: 6 size: 12 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttProducer.java (96:109) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainConsumer.java (84:97) duplicated block id: 7 size: 12 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttConsumer.java (85:98) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainProducer.java (92:105) duplicated block id: 8 size: 12 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttConsumer.java (85:98) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttProducer.java (96:109) duplicated block id: 9 size: 11 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConfListener.java (52:63) - mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConfListener.java (51:62) duplicated block id: 10 size: 10 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttConsumer.java (50:64) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainConsumer.java (50:64) duplicated block id: 11 size: 10 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java (110:120) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java (157:168) duplicated block id: 12 size: 10 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Trie.java (72:83) - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Trie.java (100:111) duplicated block id: 13 size: 9 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/DefaultChannelManager.java (171:179) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java (214:222) duplicated block id: 14 size: 9 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java (85:93) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java (139:147) duplicated block id: 15 size: 9 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConfListener.java (54:63) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/config/ServiceConfListener.java (54:63) duplicated block id: 16 size: 9 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java (69:78) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java (158:168) duplicated block id: 17 size: 9 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/config/ServiceConfListener.java (54:63) - mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConfListener.java (53:62) duplicated block id: 18 size: 9 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/match/MatchAction.java (107:117) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/match/MatchAction.java (130:140) duplicated block id: 19 size: 9 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java (69:78) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java (111:120) duplicated block id: 20 size: 9 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConf.java (56:66) - mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConf.java (46:56) duplicated block id: 21 size: 8 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MqttMessageUpContext.java (34:47) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java (104:117) duplicated block id: 22 size: 8 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttConsumer.java (40:47) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainConsumer.java (40:47) duplicated block id: 23 size: 8 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MessageEvent.java (62:75) - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java (54:67) duplicated block id: 24 size: 8 cleaned lines of code in 2 files: - style/rmq_codeStyle.xml (81:88) - style/rmq_codeStyle.xml (125:132) duplicated block id: 25 size: 7 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/DefaultChannelManager.java (96:102) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java (67:73) duplicated block id: 26 size: 7 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/MetaRpcClient.java (76:83) - mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/MqttRaftServer.java (199:206) duplicated block id: 27 size: 7 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainConsumer.java (71:79) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainProducer.java (61:68) duplicated block id: 28 size: 7 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttConsumer.java (72:80) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttProducer.java (59:66) duplicated block id: 29 size: 7 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPubCompHandler.java (47:55) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/protocol/mqtt/handler/MqttPubRecHandler.java (43:51) duplicated block id: 30 size: 7 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttConsumer.java (72:80) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainProducer.java (61:68) duplicated block id: 31 size: 7 cleaned lines of code in 2 files: - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttProducer.java (59:66) - mqtt-example/src/main/java/org/apache/rocketmq/mqtt/example/MqttWillRetainConsumer.java (71:79) duplicated block id: 32 size: 7 cleaned lines of code in 2 files: - style/rmq_codeStyle.xml (51:57) - style/rmq_codeStyle.xml (97:103) duplicated block id: 33 size: 7 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java (136:146) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/RetainedMsgClient.java (185:195) duplicated block id: 34 size: 7 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/DefaultChannelManager.java (182:192) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java (225:235) duplicated block id: 35 size: 7 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (104:111) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (159:166) duplicated block id: 36 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store/LmqOffsetStoreManager.java (50:57) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/store/LmqQueueStoreManager.java (84:91) duplicated block id: 37 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (52:58) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (132:138) duplicated block id: 38 size: 6 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/channel/DefaultChannelManager.java (163:169) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java (207:212) duplicated block id: 39 size: 6 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java (385:391) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java (406:412) duplicated block id: 40 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MessageEvent.java (29:35) - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Subscription.java (69:75) duplicated block id: 41 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Message.java (219:225) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java (129:135) duplicated block id: 42 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MessageEvent.java (29:35) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java (129:135) duplicated block id: 43 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (52:58) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (105:111) duplicated block id: 44 size: 6 cleaned lines of code in 2 files: - mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/StateProcessor.java (124:129) - mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/processor/StateProcessor.java (146:152) duplicated block id: 45 size: 6 cleaned lines of code in 2 files: - style/rmq_codeStyle.xml (98:103) - style/rmq_codeStyle.xml (121:126) duplicated block id: 46 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Subscription.java (69:75) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java (608:614) duplicated block id: 47 size: 6 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/PushAction.java (111:116) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/infly/PushAction.java (129:134) duplicated block id: 48 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Message.java (219:225) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java (608:614) duplicated block id: 49 size: 6 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java (324:331) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/Session.java (426:433) duplicated block id: 50 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (78:84) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (160:166) duplicated block id: 51 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MessageEvent.java (29:35) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java (608:614) duplicated block id: 52 size: 6 cleaned lines of code in 2 files: - style/rmq_codeStyle.xml (84:89) - style/rmq_codeStyle.xml (108:113) duplicated block id: 53 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (56:65) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (84:93) duplicated block id: 54 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java (78:84) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java (129:135) duplicated block id: 55 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (56:65) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (70:79) duplicated block id: 56 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (42:51) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (84:93) duplicated block id: 57 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Message.java (219:225) - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Subscription.java (69:75) duplicated block id: 58 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (105:111) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (132:138) duplicated block id: 59 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java (78:84) - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Subscription.java (69:75) duplicated block id: 60 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (78:84) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (132:138) duplicated block id: 61 size: 6 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java (82:87) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/starter/MqttServer.java (110:115) duplicated block id: 62 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (42:51) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (56:65) duplicated block id: 63 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Subscription.java (96:105) - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/WillMessage.java (63:72) duplicated block id: 64 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MessageEvent.java (29:35) - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java (78:84) duplicated block id: 65 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Subscription.java (69:75) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java (129:135) duplicated block id: 66 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (78:84) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (105:111) duplicated block id: 67 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Message.java (219:225) - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/MessageEvent.java (29:35) duplicated block id: 68 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (42:51) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (70:79) duplicated block id: 69 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (52:58) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (78:84) duplicated block id: 70 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (132:138) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (160:166) duplicated block id: 71 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (70:79) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgPersistManagerImpl.java (84:93) duplicated block id: 72 size: 6 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/QueueCache.java (129:135) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java (608:614) duplicated block id: 73 size: 6 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/config/ConnectConfListener.java (44:50) - mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/config/MetaConfListener.java (43:49) duplicated block id: 74 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java (78:84) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java (608:614) duplicated block id: 75 size: 6 cleaned lines of code in 2 files: - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (52:58) - mqtt-ds/src/main/java/org/apache/rocketmq/mqtt/ds/meta/WillMsgClient.java (160:166) duplicated block id: 76 size: 6 cleaned lines of code in 2 files: - mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc/AbstractRpcProcessor.java (51:56) - mqtt-meta/src/main/java/org/apache/rocketmq/mqtt/meta/raft/rpc/AbstractRpcProcessor.java (108:113) duplicated block id: 77 size: 6 cleaned lines of code in 2 files: - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/SessionLoopImpl.java (96:103) - mqtt-cs/src/main/java/org/apache/rocketmq/mqtt/cs/session/loop/WillLoop.java (53:60) duplicated block id: 78 size: 6 cleaned lines of code in 2 files: - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Message.java (219:225) - mqtt-common/src/main/java/org/apache/rocketmq/mqtt/common/model/Queue.java (78:84) duplicated block id: 79 size: 6 cleaned lines of code in 2 files: - style/rmq_codeStyle.xml (52:57) - style/rmq_codeStyle.xml (121:126)