18 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (1430:1448, 1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1022:1040, <1%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java (73:83, 16%) - client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java (67:77, 15%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java (73:83, 16%) - client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java (126:136, 10%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java (73:83, 16%) - client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopRequest.java (86:96, 12%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (1108:1117, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (762:771, <1%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java (134:147, 4%) - client/src/main/java/org/apache/rocketmq/client/trace/TraceBean.java (68:84, 10%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (1146:1155, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1974:1982, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/topic/TopicRouteInfoManager.java (218:225, 5%) - client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java (1154:1161, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:637, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3134:3142, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:439, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3086:3095, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:439, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3416:3424, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:439, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3400:3408, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:439, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3354:3362, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:439, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3339:3347, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (1159:1168, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1986:1995, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:439, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3307:3315, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:439, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3323:3331, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (428:436, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3133:3140, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:439, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3431:3439, <1%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (1471:1478, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java (132:139, 3%) 7 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (1177:1186, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1949:1958, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:436, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (2743:2749, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:436, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1428:1434, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:436, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1510:1516, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1428:1434, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/metrics/ProducerAttr.java (31:36, 35%) - client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java (315:320, 1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java (68:76, 2%) - client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java (89:97, 3%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3307:3313, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3354:3360, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3339:3345, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3323:3329, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (857:863, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (2815:2821, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3416:3422, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3400:3406, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:436, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (2109:2115, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:436, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (2089:2095, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:436, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (2131:2137, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:436, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (2071:2077, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3086:3092, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1510:1516, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (2109:2115, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (2089:2095, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (2071:2077, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (2131:2137, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java (64:73, 5%) - client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java (89:97, 3%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (431:439, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1875:1882, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (431:439, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1893:1900, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1578:1584, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerAttr.java (36:41, 28%) - client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java (315:320, 1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3431:3437, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:436, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (1578:1584, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:436, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (416:422, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (430:436, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (465:471, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (2743:2749, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (1225:1231, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (3165:3171, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java (67:75, 3%) - client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java (89:97, 3%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java (86:94, 3%) - client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java (89:97, 3%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (416:422, <1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java (628:634, <1%) - client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java (465:471, <1%)