This is an automated email from the ASF dual-hosted git repository. dongeforever pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit e90d20dd49338b8934b385413b5c74a509bb26b3 Merge: bf4ac79 1bc1f22 Author: Zhendong Liu <[email protected]> AuthorDate: Thu Mar 7 16:46:26 2019 +0800 Merge pull request #1046 from apache/store_with_dledger Add store with dledger .gitignore | 6 +- README.md | 2 + .../apache/rocketmq/broker/BrokerController.java | 183 ++++- .../broker/dledger/DLedgerRoleChangeHandler.java | 104 +++ .../apache/rocketmq/broker/out/BrokerOuterAPI.java | 2 +- .../broker/processor/ClientManageProcessor.java | 2 +- .../rocketmq/broker/slave/SlaveSynchronize.java | 8 +- .../TransactionalMessageCheckService.java | 21 - .../client/impl/factory/MQClientInstance.java | 18 +- .../org/apache/rocketmq/common/ServiceThread.java | 35 +- .../rocketmq/common/message/MessageDecoder.java | 1 + distribution/bin/dledger/fast-try.sh | 102 +++ distribution/conf/dledger/broker-n0.conf | 27 + distribution/conf/dledger/broker-n1.conf | 27 + distribution/conf/dledger/broker-n2.conf | 27 + distribution/release.xml | 2 +- docs/cn/dledger/deploy_guide.md | 76 +++ docs/cn/dledger/quick_start.md | 61 ++ .../namesrv/routeinfo/RouteInfoManager.java | 11 + pom.xml | 5 +- store/pom.xml | 15 + .../rocketmq/store/AllocateMappedFileService.java | 11 +- .../java/org/apache/rocketmq/store/CommitLog.java | 26 +- .../org/apache/rocketmq/store/ConsumeQueue.java | 15 +- .../apache/rocketmq/store/DefaultMessageStore.java | 123 +++- .../org/apache/rocketmq/store/DispatchRequest.java | 16 +- .../org/apache/rocketmq/store/MappedFileQueue.java | 4 +- .../org/apache/rocketmq/store/MessageStore.java | 7 + .../rocketmq/store/SelectMappedBufferResult.java | 4 +- .../rocketmq/store/config/MessageStoreConfig.java | 36 + .../rocketmq/store/dledger/DLedgerCommitLog.java | 747 +++++++++++++++++++++ .../org/apache/rocketmq/store/ha/HAConnection.java | 4 +- .../store/schedule/ScheduleMessageService.java | 81 ++- .../apache/rocketmq/store/ConsumeQueueTest.java | 3 +- .../store/DefaultMessageStoreShutDownTest.java | 2 +- .../org/apache/rocketmq/store/StoreTestBase.java | 93 +++ .../store/dledger/DLedgerCommitlogTest.java | 213 ++++++ .../store/dledger/MessageStoreTestBase.java | 143 ++++ .../rocketmq/store/dledger/MixCommitlogTest.java | 193 ++++++ store/src/test/resources/logback-test.xml | 2 +- .../rocketmq/test/factory/ConsumerFactory.java | 10 + .../rocketmq/test/factory/ProducerFactory.java | 2 + .../org/apache/rocketmq/test/util/MQAdmin.java | 2 + .../org/apache/rocketmq/test/base/BaseConf.java | 4 +- .../rocketmq/test/base/IntegrationTestBase.java | 40 +- .../base/dledger/DLedgerProduceAndConsumeIT.java | 121 ++++ .../broadcast/order/OrderMsgBroadCastIT.java | 5 + .../rocketmq/test/delay/NormalMsgDelayIT.java | 3 +- 48 files changed, 2444 insertions(+), 201 deletions(-)
