10 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/util/PositiveAtomicCounter.java (21:38, 100%) - common/src/main/java/org/apache/rocketmq/common/utils/PositiveAtomicCounter.java (21:38, 100%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java (73:83, 16%) - common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java (74:84, 13%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java (73:83, 16%) - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java (67:77, 11%) 9 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java (73:83, 16%) - common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java (39:49, 23%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/processor/DefaultPullMessageResultHandler.java (252:259, 4%) - common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java (218:225, 1%) 8 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/processor/DefaultPullMessageResultHandler.java (252:259, 4%) - common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java (124:131, 1%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerAttr.java (36:41, 28%) - common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java (34:39, 23%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/metrics/ProducerAttr.java (31:36, 35%) - common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java (34:39, 23%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerAttr.java (36:41, 28%) - common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolWrapper.java (100:105, 9%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java (159:165, 6%) - common/src/main/java/org/apache/rocketmq/common/TopicConfig.java (218:224, 3%) 6 duplicated lines in: - broker/src/main/java/org/apache/rocketmq/broker/metrics/ProducerAttr.java (31:36, 35%) - common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolWrapper.java (100:105, 9%)