This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a change to branch shenlin/runtimer
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from 2a24698 feat:add TargetRunnerConfigObserver
add c774175 feat: add EventSubscriber & observer.
No new revisions were added by this update.
Summary of changes:
.../eventbridge/adapter/runtimer/Runtimer.java | 46 ++----
.../adapter/runtimer/boot/EventBusListener.java | 176 ++-------------------
.../adapter/runtimer/boot/EventRuleTransfer.java | 84 ++--------
.../adapter/runtimer/boot/EventTargetPusher.java | 66 +++-----
.../runtimer/boot/listener/EventSubscriber.java | 56 +++++++
.../runtimer/boot/listener/ListenerFactory.java | 125 +++++++++++----
.../boot/listener/RocketMQEventSubscriber.java | 27 ++++
.../runtimer/common/entity/TargetRunnerConfig.java | 41 +++--
.../runtimer/config/RuntimerConfigDefine.java | 2 +
.../src/main/resources/target-runner.config | 7 +
10 files changed, 268 insertions(+), 362 deletions(-)
create mode 100644
adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/boot/listener/EventSubscriber.java
create mode 100644
adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/boot/listener/RocketMQEventSubscriber.java
create mode 100644 adapter/runtimer/src/main/resources/target-runner.config
