client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java

client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java

client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java

client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java

client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopRequest.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java

client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopRequest.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java

client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java

client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java

client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopRequest.java
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java

client/src/main/java/org/apache/rocketmq/client/exception/RequestTimeoutException.java
common/src/main/java/org/apache/rocketmq/common/AbortProcessException.java

client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolWrapper.java

client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java
common/src/main/java/org/apache/rocketmq/common/AbortProcessException.java

client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java
common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java