This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 8ccffa7e8 [ISSUE #4646] Document modification of rocketmq 5.0
automatic master-slave switching (#4645)
new ccead0451 [RIP-43] Support Timing Messages with Arbitrary Time Delay
new 8f99df33b refactor #RIP-43
new fcdbc3023 Merge remote-tracking branch 'open-core/develop' into RIP-43
new d538133af [RIP-43] Resolve some review problems.
new 8336b4994 Merge pull request #4642 from GenerousMan/RIP-43
The 7207 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:
.../apache/rocketmq/broker/BrokerController.java | 28 +-
.../rocketmq/broker/BrokerPathConfigHelper.java | 6 +
.../broker/schedule/ScheduleMessageService.java | 2 +
.../org/apache/rocketmq/broker/util/HookUtils.java | 83 +-
.../apache/rocketmq/common/message/Message.java | 10 +
.../rocketmq/common/message/MessageConst.java | 17 +
example/pom.xml | 4 +
.../example/benchmark/timer/TimerConsumer.java | 191 +++
.../example/benchmark/timer/TimerProducer.java | 322 ++++
pom.xml | 6 +
store/pom.xml | 8 +
.../java/org/apache/rocketmq/store/CommitLog.java | 1 +
.../org/apache/rocketmq/store/ConsumeQueue.java | 2 +-
.../apache/rocketmq/store/DefaultMessageStore.java | 21 +
.../org/apache/rocketmq/store/MessageStore.java | 7 +-
.../apache/rocketmq/store/PutMessageStatus.java | 4 +
.../rocketmq/store/config/MessageStoreConfig.java | 174 ++-
.../java/org/apache/rocketmq/store/timer/Slot.java | 46 +-
.../rocketmq/store/timer/TimerCheckpoint.java | 152 ++
.../org/apache/rocketmq/store/timer/TimerLog.java | 126 ++
.../rocketmq/store/timer/TimerMessageStore.java | 1608 ++++++++++++++++++++
.../apache/rocketmq/store/timer/TimerMetrics.java | 284 ++++
.../apache/rocketmq/store/timer/TimerRequest.java | 113 ++
.../apache/rocketmq/store/timer/TimerWheel.java | 209 +++
.../rocketmq/store/timer/StoreTestUtils.java | 52 +-
.../apache/rocketmq/store/timer/TimerLogTest.java | 108 ++
.../store/timer/TimerMessageStoreTest.java | 542 +++++++
.../rocketmq/store/timer/TimerMetricsTest.java | 78 +
.../rocketmq/store/timer/TimerWheelTest.java | 156 ++
29 files changed, 4295 insertions(+), 65 deletions(-)
create mode 100644
example/src/main/java/org/apache/rocketmq/example/benchmark/timer/TimerConsumer.java
create mode 100644
example/src/main/java/org/apache/rocketmq/example/benchmark/timer/TimerProducer.java
copy
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolQueueSizeMonitor.java
=> store/src/main/java/org/apache/rocketmq/store/timer/Slot.java (56%)
create mode 100644
store/src/main/java/org/apache/rocketmq/store/timer/TimerCheckpoint.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/timer/TimerLog.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/timer/TimerMetrics.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/timer/TimerRequest.java
create mode 100644
store/src/main/java/org/apache/rocketmq/store/timer/TimerWheel.java
copy
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/LanguageCode.java
=> store/src/test/java/org/apache/rocketmq/store/timer/StoreTestUtils.java (51%)
create mode 100644
store/src/test/java/org/apache/rocketmq/store/timer/TimerLogTest.java
create mode 100644
store/src/test/java/org/apache/rocketmq/store/timer/TimerMessageStoreTest.java
create mode 100644
store/src/test/java/org/apache/rocketmq/store/timer/TimerMetricsTest.java
create mode 100644
store/src/test/java/org/apache/rocketmq/store/timer/TimerWheelTest.java
