You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2022/07/21 12:32:11 UTC
[rocketmq] branch develop updated (8ccffa7e8 -> 8336b4994)
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