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=" 4 ", penwidth="4", color="#00688b93"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[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=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[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"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java]" -- "[broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; }