graph G { compound="true" rankdir="TB" bgcolor="white" fontname="Tahoma" node [ fixedsize="false" fontname="Tahoma" color="white" fillcolor="deepskyblue2" fontcolor="black" shape="box" style="filled" penwidth="1.0" ] edge [ fontname="Arial" color="#00688b" fontcolor="black" fontsize="12" arrowsize="0.5" penwidth="1.0" ] "[broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 6 ", penwidth="6", color="#00688bB7"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java]" -- "[client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java]" -- "[client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java]" -- "[client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java]" -- "[common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java]" -- "[tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java]" -- "[tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java]" -- "[remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBTopicConfigManager.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java]" -- "[tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java]" -- "[remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java]" -- "[client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java]" -- "[client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBTopicConfigManager.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java]" -- "[remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; }