broker/src/main/java/org/apache/rocketmq/broker/util/PositiveAtomicCounter.java
common/src/main/java/org/apache/rocketmq/common/utils/PositiveAtomicCounter.java

broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java

broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java

broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java

broker/src/main/java/org/apache/rocketmq/broker/processor/DefaultPullMessageResultHandler.java
common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java

broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerAttr.java
common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java

broker/src/main/java/org/apache/rocketmq/broker/metrics/ProducerAttr.java
common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java

broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerAttr.java
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolWrapper.java

broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java
common/src/main/java/org/apache/rocketmq/common/TopicConfig.java

broker/src/main/java/org/apache/rocketmq/broker/metrics/ProducerAttr.java
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolWrapper.java