You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2021/11/01 13:02:35 UTC
[rocketmq] branch 5.0.0-alpha updated (0f5a0a1 -> 4506f34)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch 5.0.0-alpha
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
from 0f5a0a1 [ISSUE #3436] Make configuration for pop be configurable (#3437)
add 9013cc5 fix document mistake (#3303)
add fa935e8 fix document mistake (#3304)
add 538b6b7 [ISSUE #1869] Delay message can't be consumed when delay offset in delayOffset.json is wrong (#3358)
add a9a7dfa RIP-7 Multiple Directories Storage Suppor
add 8e19069 fix test error
add 9b0e31e 1. fix initial value of physicRatio in org.apache.rocketmq.broker.processor.SendMessageProcessor#diskUtil 2. use minPhysicsUsedRatio instead of max in org.apache.rocketmq.store.DefaultMessageStore#getRuntimeInfo
add 466bb98 fix error in org.apache.rocketmq.store.DefaultMessageStore.CleanCommitLogService#isSpaceFull
add 255a202 add path empty check to avoid error log in org.apache.rocketmq.store.DefaultMessageStore#getRuntimeInfo
add f32406d change default value of org.apache.rocketmq.store.config.MessageStoreConfig#MULTI_PATH_SPLITTER to ',' and can be changed by System.getProperty("rocketmq.broker.multiPathSplitter")
add 474c4eb Fix bug for multi path file loading. Opt code checking for multi-path commitlog path in storePathCommitLog.
add 7d4e5cd fix compile error
add 14d50f9 fix a typo
add 4dbdbf0 Merge pull request #3357 from Jason918/RIP-7
add a83cdc5 [format] Fix formatting errors (#3380)
add 6d78d79 fix apache rat failure because of test result files
add d429aa2 [ISSUE #3375] Lazy init GetMessageResult only when find message
add b30bd87 [ISSUE #2667] Repair 'file doesn't exist on this path'
add daf1b9d [ISSUE #503] NOT_CONSUME_YET not righht in RocketMQ Console (#3091)
add c6a4b82 [ISSUE #3384] Add SendBack message to SCHEDULE_TOPIC_XXXX stats #3385
add 94a527c [ISSUE #3288] Fix producer always timeouts while sending first message (#3383)
add e6768ba [ISSUE #2962] Implement DefaultMQAdminExt::examineTopicConfig function
add 7755aaa Merge pull request #3039 from Aaron-He/dev20210623
add 23506fd fix wrong comment (#3400)
add cd45023 [ISSUE #3148]Support metadata export (#3149)
add a2c6d33 [ISSUE #3415] Fix the problem of failure during checkstyle execution
add 143ac31 prepare to release rocketmq 4.9.2 version
add c840b20 [maven-release-plugin] prepare release rocketmq-all-4.9.2
add 21faa68 [maven-release-plugin] prepare for next development iteration
add 6b8a2b2 trivial cleanups (#3403)
add 78443c3 [ISSUE 3420]rocketmq_client.log will not record the asynchronous sending failure exception，will only throw out the reason for the final time failure to the business (#3421)
add d2776fc [ISSUE #3370] group same Exceptions
add 1657475 [ISSUE#3430] fix the problem that setting parameter mqClientApiTimeout doesn't take effect (#3431)
add f1b0318 Merge remote-tracking branch 'apache/develop' into 5.0.0-alpha
add 4506f34 Resolve some conflicts in the merge that prevent compilation from succeeding
No new revisions were added by this update.
Summary of changes:
.travis.yml | 3 +
.../processor/AbstractSendMessageProcessor.java | 3 +-
.../broker/processor/SendMessageProcessor.java | 17 +-
client/pom.xml | 13 -
.../org/apache/rocketmq/client/ClientConfig.java | 2 +
.../rocketmq/client/consumer/MessageSelector.java | 2 +-
.../rocketmq/client/impl/MQClientAPIImpl.java | 13 +-
.../client/impl/factory/MQClientInstance.java | 6 +-
.../impl/producer/DefaultMQProducerImpl.java | 23 +-
.../java/org/apache/rocketmq/common/UtilAll.java | 11 +-
.../apache/rocketmq/common/RemotingUtilTest.java | 12 +
distribution/bin/export.sh | 89 +++++++
docs/cn/RocketMQ_Example.md | 2 +-
docs/en/Example_Batch.md | 4 +-
.../rocketmq/example/simple/PullConsumer.java | 180 ++++++-------
.../rocketmq/remoting/common/RemotingUtil.java | 4 +
.../java/org/apache/rocketmq/store/CommitLog.java | 26 +-
.../apache/rocketmq/store/DefaultMessageStore.java | 101 ++++++--
.../apache/rocketmq/store/GetMessageResult.java | 17 +-
.../org/apache/rocketmq/store/MappedFileQueue.java | 108 ++++----
.../rocketmq/store/MultiPathMappedFileQueue.java | 127 ++++++++++
.../rocketmq/store/config/MessageStoreConfig.java | 13 +
.../store/schedule/ScheduleMessageService.java | 64 ++++-
.../store/DefaultMessageStoreCleanFilesTest.java | 42 +++
.../rocketmq/store/DefaultMessageStoreTest.java | 16 ++
.../store/MultiPathMappedFileQueueTest.java | 154 +++++++++++
.../rocketmq/store/ScheduleMessageServiceTest.java | 84 ++++++
.../rocketmq/tools/admin/DefaultMQAdminExt.java | 43 +++-
.../tools/admin/DefaultMQAdminExtImpl.java | 59 ++++-
.../apache/rocketmq/tools/admin/MQAdminExt.java | 10 +-
.../apache/rocketmq/tools/command/CommandUtil.java | 1 -
.../rocketmq/tools/command/MQAdminStartup.java | 9 +-
.../tools/command/export/ExportConfigsCommand.java | 128 ++++++++++
.../command/export/ExportMetadataCommand.java | 184 ++++++++++++++
.../tools/command/export/ExportMetricsCommand.java | 282 +++++++++++++++++++++
.../tools/admin/DefaultMQAdminExtTest.java | 16 ++
36 files changed, 1613 insertions(+), 255 deletions(-)
create mode 100644 distribution/bin/export.sh
create mode 100644 store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java
create mode 100644 store/src/test/java/org/apache/rocketmq/store/MultiPathMappedFileQueueTest.java
create mode 100644 store/src/test/java/org/apache/rocketmq/store/ScheduleMessageServiceTest.java
create mode 100644 tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportConfigsCommand.java
create mode 100644 tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataCommand.java
create mode 100644 tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetricsCommand.java