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" ] "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 5 ", penwidth="5", color="#00688bA5"]; "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 4 ", penwidth="4", color="#00688b93"]; "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V6__register_target_acs_eventbridge.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V2__baseline.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V7__update_event_connection_table_structure.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V1__baseline.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V5__register_target_acs_dingtalk.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/persistence/src/main/resources/db/migration/V8__update_unique_key.sql]" -- "[adapter/persistence/src/main/resources/db/migration/V3__change_target_transform_type.sql]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" [label=" 3 ", penwidth="3", color="#00688b82"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/listener/EventSubscriber.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/listener/EventSubscriber.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfiguration.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/config/RuntimeConfiguration.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/listener/EventSubscriber.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/storage/EventDataRepository.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/ServiceThread.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/listener/EventSubscriber.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/ServiceThread.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/common/ServiceThread.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventBusListener.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LocalMessageCache.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/consumer/LitePullConsumerImpl.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventRuleTransfer.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/impl/RocketMQEventDataRepository.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnFileObserver.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/Runtime.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/listener/EventSubscriber.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/common/CirculatorContext.java]" -- "[adapter/storage/src/main/java/org/apache/rocketmq/eventbridge/adapter/storage/rocketmq/runtimer/RocketMQEventSubscriber.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/storage/EventDataRepository.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/boot/EventTargetTrigger.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; "[domain/src/main/java/org/apache/rocketmq/eventbridge/domain/storage/EventDataRepository.java]" -- "[adapter/runtime/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtime/service/TargetRunnerConfigOnDBObserver.java]" [label=" 2 ", penwidth="2", color="#00688b70"]; }