This is an automated email from the ASF dual-hosted git repository.
shenlin pushed a change to branch runtimer
in repository https://gitbox.apache.org/repos/asf/rocketmq-eventbridge.git
from 2f03d44 Add simulated backpressure test code
new 667111e feat:support record commit.
new f12cc04 feat:support record commit.
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../eventbridge/adapter/runtimer/Runtimer.java | 45 ++++++------
.../adapter/runtimer/boot/EventBusListener.java | 18 +++--
.../adapter/runtimer/boot/EventRuleTransfer.java | 82 +++++++++++++---------
.../adapter/runtimer/boot/EventTargetPusher.java | 24 ++++---
.../PushCallback.java => OffsetManager.java} | 18 +++--
.../runtimer/boot/listener/EventSubscriber.java | 11 +++
.../boot/listener/RocketMQEventSubscriber.java | 4 ++
.../adapter/runtimer/boot/pusher/PushRequest.java | 34 ---------
.../adapter/runtimer/common/ServiceThread.java | 1 +
.../runtimer/config/RuntimerConfiguration.java | 41 +++++++++++
.../{retry => error}/DeadLetterQueueService.java | 2 +-
.../runtimer/{retry => error}/ErrorHandler.java | 16 +++--
.../adapter/runtimer/retry/EventBusStorage.java | 25 -------
.../runtimer/retry/EventBusStorageOnRocketMQ.java | 34 ---------
.../service/TargetRunnerConfigOnFileObserver.java | 2 +
15 files changed, 184 insertions(+), 173 deletions(-)
rename
adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/boot/{pusher/PushCallback.java
=> OffsetManager.java} (68%)
delete mode 100644
adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/boot/pusher/PushRequest.java
create mode 100644
adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/config/RuntimerConfiguration.java
rename
adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/{retry
=> error}/DeadLetterQueueService.java (92%)
rename
adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/{retry
=> error}/ErrorHandler.java (87%)
delete mode 100644
adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/retry/EventBusStorage.java
delete mode 100644
adapter/runtimer/src/main/java/org/apache/rocketmq/eventbridge/adapter/runtimer/retry/EventBusStorageOnRocketMQ.java
