broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
container/src/main/java/org/apache/rocketmq/container/InnerBrokerController.java

broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
container/src/main/java/org/apache/rocketmq/container/BrokerContainerStartup.java

broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java

broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java

broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java

broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java

broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java

broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java
container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java