rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jinrongt...@apache.org
Subject [rocketmq] branch master updated (9f95a97 -> 39bb938)
Date Mon, 21 Dec 2020 06:46:21 GMT
This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.


    from 9f95a97  [maven-release-plugin] prepare release rocketmq-all-4.7.1
     add fac30c3  [maven-release-plugin] prepare for next development iteration
     add 336f55c  [ISSUE #2171] fix the spell error in ACL (#2175)
     add 8c71dee  [ISSUE #2162] Fix getBrokerConfig help info wrong description (#2163)
     add f98567f  [ISSUE #2190] Fix import mistakes in RocketMQ_Example.md
     add 5002de0  [ISSUE #2192] Typo fix in DefaultMQProducerImpl.java
     add c91a2f4  [ISSUE #2180] Polish jvm options when starting nameserver failed
     add d91e7a9  [ISSUE #1435] Fix discarded mqadmin subcommand document description
     add ea7acf4  docs(readme):fix the typo (#2202)
     add e58a6b2  [ISSUE #2196] code style(acl): correct spell mistake, remove redundant code
(#2197)
     add 3e5008f  refactor(build): Remove duplicated logback-core dependency and update some
modules to 1.8 compiler lever
     add 67a1b51  fix(build): remove warning when maven build
     add 30766d2  [ISSUE #1576] Delete redundant if statment in select MessageQueue (#1607)
     add 064d4c3  [ISSUE#2176] Fix the issue of redundancy parameters in method
     add 83cc99a  Merge branch 'develop' of github.com:apache/rocketmq into develop
     add f5b7958  [ISSUE #2217] Upgrade dledger version (#2218)
     add 3774a22  [ISSUE #2231] Fix document(cn/msg_trace/user_guide.md) formal error
     add bbfdd92  [ISSUE #2170] Update BrokerOuterAPI (#2203)
     add 915424c  [ISSUE#2172] Fix the issue of ArrayIndexOutOfBoundsException
     add a093f8a  [ISSUE #2067] Add logs when collecting disk space usage
     add e23f586  [ISSUE#2233] Enhancement MQBrokerException include broker information(such
as broker ip) for troubleshooting
     add e088f2e  keep compatibility
     add 9d34fad  Merge pull request #2236 from Demogorgon314/develop
     add 6a46640  [ISSUE #2245]enhancement: expose config defaultBrokerId and connectBrokerByUser
for DefaultLitePullConsumer (#2246)
     add 4d073af  doc(rocketmq) add a recommendation to PR template
     add 2abda6d  Merge pull request #2258 from imaffe/affe-0819-prtemplate
     add f07bc79  [ISSUE #2283] Fix the spelling mistake in ProducerManager & some code
optimization
     add ba5e0e5  [ISSUE #2272] Fix spelling mistakes
     add 2f14aa5  [ISSUE #2280] Disk ratio return -1.0 when cluster deployed on DLedger mode
     add 3eaabee  [ISSUE #2293] Add clientID for warning log message in MQClientInstance (#2294)
     add 2a8ba5a  [ISSUE #1473] Trace message`s clientHost was wrong (#1474)
     add 9ddcab4  [ISSUE apache#2152] Add isRunning method in DefaultLitePullConsumerImpl
class and test suit (#2302)
     add a460c5c  [ISSUE #1770] Add a query message trace command in mqadmin. (#2303)
     add 28e6b55  [ISSUE #2299]modify the error character of the Example_Filter.md
     add b29209e  [ISSUE #2152] Use mock style in unit test for time-consuming (#2308)
     add 742ba50  fix(dependency): remove Imcompatible plugin with jdk15
     add 73f2071  [ISSUE #2219]  Add some asynchronous API for batch messages (#2315)
     add f58dbc3  [ISSUE #2300] Enhancement: Benchmark support acl and msg trace (#2301)
     add 77d24de  [ISSUE# 2325] Use CopyOnWriteArrayList to avoid possible thread safety issues
     add c932941  [ISSUE #2334] Polish the log and response remark when service not available
(#2335)
     add d5cb67f  [ISSUE #2165] Slave read enable not work sometimes When cluster deployed
on DLedger mode (#2167)
     add 3f48c17  [ISSUE# 2330] Store the properties of MessageBatch (#2343)
     add fd7da35  [ISSUE #2338] use commitLeastPages parameters and substitute 'lastCommittedPosition'
for duplicated 'this.committedPosition.get()' in 'commit0' method (#2338) (#2346)
     add 3be7033  [ISSUE #2146] Add benchmark shutdown script, add more print info, add consumer
threand count command option (#2150)
     add 845c5fd  [ISSUE #1846] Dledger model change into pipeline manner to improve performance
(#1847)
     add f5a119f  [ISSUE #2366] Fix tproducer start faild with parameter w
     add 03c1f11  [ISSUE #2378] FIx `NullPointerException` when Consumer shutdown in the ClientRemotingProcessor.
     add 872f37d  [ISSUE#2415] Delete the useless code (#2416)
     add 0b60048  [ISSUE #2421] Fix SelectMessageQueueByHash in case hashcode is Integer.MIN
     add c286600  Fix error in ipCheck method (#2376)
     add 2defd08  Redirect the twitter account
     add 6588063  Writing style optimization
     add 3cc7f09  [ISSUE #2477] Fix allocate algorithm in AllocateMessageQueueByMachineRoom
     add b69ad17  [ISSUE #2459] Fix the error in best practice doc
     add ac3adc5  [ISSUE#2468] Fix DefaultLayout SimpleDateFormat Pattern (#2469)
     add ac356f1  [ISSUE #2412] Support to add TAG when producing message
     add bd67f7a  [ISSUE #2402] Update directory for RocketMQ_Example.md
     add 912ceda  [ISSUE #2223] Polish the selectOneMessageQueue method (#2253)
     add bb9f106  [ISSUE #1904] Print log when flush timeout (#1903)
     add 7f49ce4  [ISSUE #1678] Use thread safe CopyOnWriteArrayList for registerBrokerResultList
     add 48f076f  fix(test):temporary fix on Mac OS when pid greater than short type max value
(#2492)
     add 4730987  [ISSUE #690] Support batch msgs in dledger mode (#2406)
     add 84da462  chore(release): prepare to release rocketmq 4.8.0
     add 39bb938  [maven-release-plugin] prepare release rocketmq-all-4.8.0

No new revisions were added by this update.

Summary of changes:
 .github/PULL_REQUEST_TEMPLATE.md                   |   3 +
 README.md                                          |   4 +-
 acl/pom.xml                                        |  11 +-
 .../org/apache/rocketmq/acl/common/AclUtils.java   |   4 +-
 .../org/apache/rocketmq/acl/common/Permission.java |   1 -
 .../rocketmq/acl/plain/PlainPermissionManager.java |  13 +-
 .../acl/plain/RemoteAddressStrategyFactory.java    |  14 +-
 .../apache/rocketmq/acl/common/AclUtilsTest.java   |  18 +-
 .../acl/plain/RemoteAddressStrategyTest.java       |  10 +
 broker/pom.xml                                     |   6 +-
 .../rocketmq/broker/client/ProducerManager.java    |  12 +-
 .../apache/rocketmq/broker/out/BrokerOuterAPI.java |  15 +-
 .../broker/processor/ReplyMessageProcessor.java    |  17 +-
 .../broker/processor/SendMessageProcessor.java     |   3 +-
 .../AbstractTransactionalMessageCheckListener.java |   2 +-
 .../broker/client/ProducerManagerTest.java         |   8 +-
 client/pom.xml                                     |   7 +-
 .../rocketmq/client/common/ThreadLocalIndex.java   |   5 -
 .../client/consumer/DefaultLitePullConsumer.java   |  21 +
 .../rocketmq/client/consumer/LitePullConsumer.java |   7 +
 .../AllocateMessageQueueByMachineRoom.java         |   2 +-
 .../client/exception/MQBrokerException.java        |  16 +-
 .../rocketmq/client/impl/MQClientAPIImpl.java      |  74 +--
 .../consumer/ConsumeMessageOrderlyService.java     |   4 +-
 .../impl/consumer/DefaultLitePullConsumerImpl.java |   4 +
 .../impl/consumer/DefaultMQPushConsumerImpl.java   |   6 -
 .../client/impl/consumer/ProcessQueue.java         |   2 +-
 .../client/impl/consumer/PullAPIWrapper.java       |   4 +-
 .../client/impl/factory/MQClientInstance.java      |  18 +-
 .../impl/producer/DefaultMQProducerImpl.java       |   2 +-
 .../client/impl/producer/TopicPublishInfo.java     |   4 +-
 .../rocketmq/client/latency/MQFaultStrategy.java   |   6 +-
 .../client/producer/DefaultMQProducer.java         |  23 +
 .../rocketmq/client/producer/MQProducer.java       |  14 +-
 .../selector/SelectMessageQueueByHash.java         |   4 +-
 .../rocketmq/client/trace/TraceDataEncoder.java    |  25 +-
 .../apache/rocketmq/client/trace/TraceView.java    | 180 ++++++
 .../trace/hook/ConsumeMessageTraceHookImpl.java    |   2 +
 .../trace/hook/SendMessageTraceHookImpl.java       |   1 +
 .../client/common/ThreadLocalIndexTest.java        |   7 +
 .../consumer/DefaultLitePullConsumerTest.java      |  33 +-
 .../store/RemoteBrokerOffsetStoreTest.java         |   2 +-
 .../client/impl/factory/MQClientInstanceTest.java  |  68 +++
 .../client/producer/DefaultMQProducerTest.java     |  45 ++
 .../selector/SelectMessageQueueByHashTest.java     |   8 +
 .../selector/SelectMessageQueueRetryTest.java      |  66 +++
 .../client/trace/TraceDataEncoderTest.java         |  93 +++
 .../rocketmq/client/trace/TraceViewTest.java       |  57 ++
 common/pom.xml                                     |   7 +-
 .../java/org/apache/rocketmq/common/MQVersion.java |   2 +-
 .../java/org/apache/rocketmq/common/UtilAll.java   |  41 +-
 .../rocketmq/common/message/MessageDecoder.java    |   1 +
 .../common/message/MessageClientIDSetterTest.java  |   6 +-
 distribution/benchmark/runclass.sh                 |   2 +-
 distribution/benchmark/shutdown.sh                 |  63 ++
 distribution/benchmark/tproducer.sh                |   2 +-
 distribution/bin/runserver.sh                      |  19 +-
 distribution/pom.xml                               |   2 +-
 docs/cn/RocketMQ_Example.md                        |  46 +-
 docs/cn/architecture.md                            |  10 +-
 docs/cn/best_practice.md                           |   4 +-
 docs/cn/msg_trace/user_guide.md                    |   2 +-
 docs/en/Example_Filter.md                          |   2 +-
 example/pom.xml                                    |  26 +-
 .../rocketmq/example/benchmark/AclClient.java      |  18 +-
 .../rocketmq/example/benchmark/Consumer.java       |  30 +-
 .../rocketmq/example/benchmark/Producer.java       |  31 +-
 .../example/benchmark/TransactionProducer.java     |  13 +-
 filter/pom.xml                                     |   2 +-
 logappender/pom.xml                                |   7 +-
 logging/pom.xml                                    |   7 +-
 .../rocketmq/logging/inner/LoggingBuilder.java     |   2 +-
 namesrv/pom.xml                                    |  10 +-
 openmessaging/pom.xml                              |   6 +-
 pom.xml                                            |  39 +-
 remoting/pom.xml                                   |   7 +-
 srvutil/pom.xml                                    |   2 +-
 store/pom.xml                                      |   9 +-
 .../java/org/apache/rocketmq/store/CommitLog.java  |  50 +-
 .../apache/rocketmq/store/DefaultMessageStore.java |  21 +-
 .../java/org/apache/rocketmq/store/MappedFile.java |   2 +-
 .../rocketmq/store/config/MessageStoreConfig.java  |  20 +
 .../rocketmq/store/dledger/DLedgerCommitLog.java   | 651 ++++++++++++++++++---
 .../apache/rocketmq/store/BatchPutMessageTest.java |  10 +-
 .../org/apache/rocketmq/store/StoreTestBase.java   |  68 ++-
 .../store/dledger/DLedgerCommitlogTest.java        | 160 ++++-
 .../store/dledger/MessageStoreTestBase.java        |   4 +-
 test/pom.xml                                       |   3 +-
 tools/pom.xml                                      |   6 +-
 .../rocketmq/tools/command/MQAdminStartup.java     |   2 +
 .../command/broker/GetBrokerConfigCommand.java     |   4 +-
 .../message/QueryMsgTraceByIdSubCommand.java       | 148 +++++
 .../QueryMsgTraceByIdSubCommandTest.java}          |  18 +-
 93 files changed, 2069 insertions(+), 467 deletions(-)
 create mode 100644 client/src/main/java/org/apache/rocketmq/client/trace/TraceView.java
 create mode 100644 client/src/test/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueRetryTest.java
 create mode 100644 client/src/test/java/org/apache/rocketmq/client/trace/TraceDataEncoderTest.java
 create mode 100644 client/src/test/java/org/apache/rocketmq/client/trace/TraceViewTest.java
 create mode 100644 distribution/benchmark/shutdown.sh
 copy tools/src/main/java/org/apache/rocketmq/tools/command/SubCommand.java => example/src/main/java/org/apache/rocketmq/example/benchmark/AclClient.java
(65%)
 create mode 100644 tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgTraceByIdSubCommand.java
 copy tools/src/test/java/org/apache/rocketmq/tools/command/{broker/UpdateBrokerConfigSubCommandTest.java
=> message/QueryMsgTraceByIdSubCommandTest.java} (88%)


Mime
View raw message