client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalMessageService.java

client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java

client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueSelector.java

client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteService.java

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