rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ding...@apache.org
Subject [rocketmq] branch master updated (ffc8e00 -> 734834c)
Date Thu, 07 Mar 2019 02:28:32 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from ffc8e00  Update NOTICE
     new b52738c  [maven-release-plugin] prepare for next development iteration
     new a7b0c27  [RIP-9]add the msg trace and acl feature content of RocketMQ doc part. (#707)
     new e204376  polish filter example
     new 11f6edd  Merge pull request #620 from RongtongJin/polish_filter_example
     new 45a78ae  modify architecture.md
     new d0b0fa9  modify test case,cover FlushRealTimeService
     new 5595fe3  delete unit test releated file
     new 68aa58d  recover unit test file
     new cc1a4bc  [RIP-9]Modify the architecture part Develop
     new 649ad4a  [RIP-9]adjust the formate of RocketMQ acl doc part.
     new a7e70fb  [RIP-9]Adjust the formate of RocketMQ ACL doc part.
     new 06fbe7b  更新了ch08-operation
     new 7b37381  修改了文件名称为运维管理
     new 91c82df  修改了文件名称为operation
     new 3b9e8af  修改了表格代码
     new 8c317f3  修改了表格代码
     new d13bf6c  修改了表格代码
     new 27661e5  修改了表格代码
     new bf679ab  修改了表格代码
     new 198400d  修改了表格代码
     new 837ccc1  修改了operation标题格式
     new 035eb55  correct some edit-errors.
     new 39ebc5e  some edit errors is corrected.
     new 50e7d39  some edit errors is corrected.
     new 077e5d0  [RIP-9]Add the operation part
     new 9d0e429  1. Simple Example 2. Order Example 3. Schedule Example 4. Batch Example
5. Filter Example 6. Transaction Example 7. Logappender Example 8. OpenMessaging Example
     new 71fcc07  Modified some typos
     new acb98ec  unuseful blank same indentation OpenMessaging
     new 07ac443  1. Optimized formatting and indentation 2. Corrected some typos 3. Introduce
of the Schedule Message
     new 146fc43  1. indentation
     new 168c68b  1. Modified the format
     new e67e3db  [RIP-9] Add the simple example description
     new 030f432  Add the best practice of RocketMQ
     new 66e2358  Modify the format of the title
     new 91e27a6  Update best_practice.md
     new a8b430d  [RIP-9]Add the best practice of RocketMQ
     new d9e5029  Add ACL and Message trace feature in README file.
     new 02d2382  RIP-9 RocketMQ Develop Guide: add description section for broker configuration
     new bac3594  Revise section format and reword some sentences for broker configuration
section
     new dd9e9fd  Revise some title format
     new 86ceb1d  [RIP-9] RocketMQ Develop Guide: enhance description section for broker configuration
     new 9745071  [RIP-9]Add the features of RocketMQ into the develop guide for users (#765)
     new f2df910  [RIP-9]add the design content of RocketMQ doc part. (#732)
     new 6a573a7  [RIP-9] Add the introduction of the basic samples in RocketMQ (#758)
     new 1c36c99  [issue#790]fix defaultTopicPerm and defaultGroupPerm values which are in
yaml config file dosen't work. (#798)
     new deaece5  [RIP-9] Add a delay example in RocketMQ
     new 5b47023  [RIP-9] Added sample English documents of English transaction messages
     new e01b5ae  Merge pull request #781 from chenhaoxiang/develop
     new 971eb9d  [RIP-9] Add the introduction of the batch message samples in RocketMQ (#792)
     new 132d0ae  [RIP-9]Add the English docs for Filter Example of RocketMQ into the develop
guide for users (#800)
     new 6c17951  [RIP-9] Add the English description document for Deployment.md (#780)
     new 95db64d  [RIP-10] Add test cases for DefaultMessageStore.putMessages (#777)
     new 1128a5a  [RIP-10]Add test cases for DefaultMessageStore which methods read from CommitLog/ConsumeQueue
(#778)
     new 8357b44  [RIP-10] Add  test cases of  ScheduleMessageService (#782)
     new 13b5dd1  [RIP-10] Optimize test batch send message use cases(#831)
     new 6f322c4  [issue#789]fix NullPointerException in the PlainAccessValidator#parse()
method when recieved some admin request command,if configed no aclRPCHook. (#819)
     new fb48f4d  add en doc of Operation FAQ
     new 82634b8  Change the first character to upper case.
     new 760bc3a  [RIP-9] Add en doc of Operation FAQ (#784)
     new caec839  [RIP-9] Add the introduction of the access control list in RocketMQ (#791)
     new 5dc64d0  [RIP-9]To add English version of Examples of Ordered Messages in docs/en/
(#795)
     new ffd2696  [RIP-9]Add English docs of transactional message design (#804)
     new 648cac3  [RIP-9] Add english document of storage design(#809)
     new 698effa  [RIP-10]  Add test cases for CheckClientRequestBody (#808)
     new 39406a3  [RIP-10] Add test case for ConsumeStatsList (#814)
     new d2fba24  [ISSUE #776] make mqadmin usage information more friendly to user(#796)
     new 0623c6f  [RIP-10] Add ClusterInfo testing case (#830)
     new 5e05b14  [RIP-10] Add test cases for TopicStatsTable.java (#832)
     new cbba3f6  [RIP-10] Fix junit bug in ScheduleMessageServiceTest (#839)
     new 6bece12  [RIP-10]Add  test case for CommitLog.handleHA (#829)
     new ee08826  [RIP-10] Add test case for KVTable (#828)
     new a9b6939  [RIP-10]  Add test cases for DefaultMessageStore.CleanCommitLogService and
DefaultMessageStore.CleanConsumeQueueService (#836)
     new 3aaaba8  [RIP-9] Add the introduction of the Operations_Producer in RocketMQ (#794)
     new 4d966b4  [ISSUE #731] Change log level in TransactionalMessageServiceImpl
     new 580037f  Merge pull request #742 from Aaron-He/develop
     new 77e3c23   [RIP-9] Add Operations_Trace.md in rocketmq (#859)
     new 1dd9f16  [RIP-9] Add the introduction of the basic concepts in RocketMQ (#793)
     new ac62ce9  [RIP-9]Add the client configuration section of the RocketMQ documentation
best practices. (#799)
     new 8d04250  [RIP-9]Add English docs of architecture (#812)
     new e4bbcc8  [RIP-9] Add the Configuration_System in RocketMQ  (#885)
     new fc037bb  [RIP-9] Add ta CLITools.md file to illustrate the use of  mqadmin management
tools (#821)
     new 2e55ffb  [RIP-9] Add API_Reference_DefaultMQProducer.md for Java (#837)
     new 3041c82  [RIP-9] Commit docs Design_Filter.md (#840)
     new cfceb1f  [RIP-9] Change the Chinese punctuation in Example_Delay.md to English punctuation
(#878)
     new d1f2f2d  [RIP-9] update the en doc for Troubleshoopting.md #881 (#883)
     new 90e0c4b  [RIP-9] Add the FAQ in RocketMQ (#879)
     new 06ea92b  [RIP-9] Delete the number on the title (#887)
     new 175dc21  [RIP-9] Update incorrect symbol  (#886)
     new 79361b8  [RIP-9] enhance description about the state "SLAVE_NOT_AVAILABLE" in the
chinese version of "best_practice.md" (#867)
     new fe49193  [RIP-9]Polish Best practice.md (#890)
     new e12dde5  [RIP-9] Modify the wrong architecture diagram. (#891)
     new 6eff504  [RIP-9]Change the project number to a solid black dot (#893)
     new 2e04ca7  [RIP-10]fix-bug: ScheduleMessageServiceTest (#869)
     new 83c788e  [RIP-9] Modify English document for Example_Orderly.md (#902)
     new 42ddf3d  [RIP-10] Add test cases for ConsumerConnection (#834)
     new 656b014  use putIfAbsent instead of put
     new 9d77e9e  1.use putIfAbsent instead of put method of ConcurrentHashMap 2.add test
code
     new b2544b5  rewrite unit test BrokerStatsManagerTest.java
     new 4bf4681  use putIfAbsent in MomentStatsItemSet.java
     new 32877cf  adjust test code to increase coverage
     new 3e1a5cc  Merge pull request #516 from xiangwangcheng/statsitemset-multi-thread
     new fe23415  [RIP-10]  Add test cases for   ConsumeMessageConcurrentlyService consume
success status (#888)
     new 3b5a170  [RIP-10] Add test case for QueryCorrectionOffsetBody & ResetOffsetBody
(#898)
     new 4ba062b  [RIP-10] Add test cases for SubscriptionGroupWrapper (#899)
     new 8da75e8  [RIP-10] Fix-ScheduleMessageServiceTest (#928)
     new ef9c806  [RIP-10] Add test cases for UpdateKvConfigCommand (#929)
     new 562a638  [RIP-9] Add the English docs for Feature.md into the develop guide for users
(#825)
     new 1b754c0  [RIP-9] Modify Chinese punctuation to English (#896)
     new 38a385e  [RIP-9] Add the introduction of the Operations_Consumer in RocketMQ(#897)
     new 4cce9b6  [RIP-9] Add English document to Design_Query(#901)
     new bd2e13b  [RIP-9] Add English document for Design_Trancation.md (#908)
     new 13eeab8   [ISSUE #762]fix defaultAsyncSenderExecutor not shutdown when DefaultMQProducerImpl
shutdown. (#880)
     new 059c777  [RIP-9] Add English document for Design_LoadBlancing.md and Design_Remoting.md
(#810)
     new eb1e915  [RIP-9] Modify Chinese punctuation to English (#941)
     new 27622c5  [RIP-10]HA test case optimization and reduce the time spent (#931)
     new bbb723f  [RIP-10]Optimize the test case for DefaultMessageStore.CleanCommitLogService
and DefaultMessageStore.CleanConsumeQueueService (#939)
     new b6f1aeb  [RIP-9] Polish Example_Orderly.md
     new b439b8a  Merge pull request #975 from nisiyong/develop
     new 644d1cf  Update Example_Filter.md
     new 9891217  Merge pull request #972 from Geek-S/patch-2
     new 5b4fc96  [RIP-9] Modify English document for Design_Trancation.md
     new ce7b0d4  [RIP-9] Modify English document for Design_Store.md
     new 295c433  Update Design_Trancation.md
     new 2b6d91a  Merge pull request #965 from JJFighting/develop4
     new f4dfe2e  Modify incorrect word
     new 4b70128  Merge pull request #957 from wxynihao/develop
     new a857d24  [RIP-9]
     new 9243a4b  [RIP-9]
     new 6a93101  [RIP-9]
     new c9eacad  Merge pull request #954 from gitdh/develop
     new 99ba1b8  Update '同步消息,' to '同步消息、' and delete the ordinal number
of subsection 3.4
     new 160b907  Merge remote-tracking branch 'upstream/develop' into develop
     new f7de85d  Merge remote-tracking branch 'upstream/develop' into develop
     new a28a8eb  Merge remote-tracking branch 'upstream/develop' into develop
     new 5f8a754  Merge pull request #942 from dyja/develop
     new ff90141  [RIP-9] Add doc of best practice for broker (#774)
     new 4f8d96c  [RIP-9]Modify English document for Example_Orderly.md (#944)
     new 9cf0979  [RIP-9] Modify the article layout format (#1033)
     new 690a406  [RIP-10] modify test case  StatsItemSetTest's param (#1053)
     new ede33c1  [RIP-10] optimization test case of DefaultMessageStore (#995)
     new 734834c  Merge branch 'develop'

The 839 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:
 README.md                                          |    2 +
 acl/pom.xml                                        |    2 +-
 .../rocketmq/acl/plain/PlainAccessValidator.java   |    5 +
 .../rocketmq/acl/plain/PlainPermissionLoader.java  |    4 +-
 .../acl/plain/PlainAccessValidatorTest.java        |   17 +
 .../acl/plain/PlainPermissionLoaderTest.java       |    4 +-
 broker/pom.xml                                     |    2 +-
 .../queue/TransactionalMessageServiceImpl.java     |   10 +-
 client/pom.xml                                     |    2 +-
 .../impl/producer/DefaultMQProducerImpl.java       |    1 +
 .../ConsumeMessageConcurrentlyServiceTest.java}    |  201 +--
 common/pom.xml                                     |    2 +-
 .../rocketmq/common/stats/MomentStatsItemSet.java  |    6 +-
 .../apache/rocketmq/common/stats/StatsItemSet.java |    6 +-
 .../rocketmq/common/admin/TopicStatsTableTest.java |   89 ++
 .../rocketmq/common/protocol/ClusterInfoTest.java  |   98 ++
 .../protocol/body/CheckClientRequestBodyTest.java  |   43 +
 .../common/protocol/body/ConsumeStatsListTest.java |   62 +
 .../protocol/body/ConsumerConnectionTest.java      |   83 ++
 .../KVTableTest.java}                              |   31 +-
 .../QueryCorrectionOffsetBodyTest.java}            |   29 +-
 .../common/protocol/body/ResetOffsetBodyTest.java} |   38 +-
 .../body/SubscriptionGroupWrapperTest.java         |   49 +
 .../rocketmq/common/stats/StatsItemSetTest.java    |   93 ++
 distribution/pom.xml                               |    2 +-
 docs/cn/RocketMQ_Example.md                        |  956 +++++++++++++
 docs/cn/acl/user_guide.md                          |   82 ++
 docs/cn/architecture.md                            |   37 +-
 docs/cn/best_practice.md                           |  374 ++++++
 .../client/java/API_Reference_DefaultMQProducer.md | 1088 +++++++++++++++
 docs/cn/design.md                                  |  213 +++
 docs/cn/features.md                                |   82 ++
 docs/cn/image/rocketmq_architecture_1.png          |  Bin 46292 -> 377784 bytes
 docs/cn/image/rocketmq_design_1.png                |  Bin 0 -> 111170 bytes
 docs/cn/image/rocketmq_design_10.png               |  Bin 0 -> 35963 bytes
 docs/cn/image/rocketmq_design_11.png               |  Bin 0 -> 69366 bytes
 docs/cn/image/rocketmq_design_12.png               |  Bin 0 -> 53898 bytes
 docs/cn/image/rocketmq_design_13.png               |  Bin 0 -> 33918 bytes
 docs/cn/image/rocketmq_design_2.png                |  Bin 0 -> 22281 bytes
 docs/cn/image/rocketmq_design_3.png                |  Bin 0 -> 66199 bytes
 docs/cn/image/rocketmq_design_4.png                |  Bin 0 -> 20733 bytes
 docs/cn/image/rocketmq_design_5.png                |  Bin 0 -> 139527 bytes
 docs/cn/image/rocketmq_design_6.png                |  Bin 0 -> 64670 bytes
 docs/cn/image/rocketmq_design_7.png                |  Bin 0 -> 6780 bytes
 docs/cn/image/rocketmq_design_8.png                |  Bin 0 -> 79037 bytes
 docs/cn/image/rocketmq_design_9.png                |  Bin 0 -> 39837 bytes
 docs/cn/msg_trace/user_guide.md                    |  106 ++
 docs/cn/operation.md                               | 1410 ++++++++++++++++++++
 docs/en/CLITools.md                                | 1220 +++++++++++++++++
 docs/en/Concept.md                                 |   41 +
 docs/en/Configuration_Client.md                    |  119 ++
 docs/en/Configuration_System.md                    |   67 +
 docs/en/Deployment.md                              |  159 +++
 docs/en/Design_Filter.md                           |   10 +
 docs/en/Design_LoadBlancing.md                     |   42 +
 docs/en/Design_Query.md                            |   17 +
 docs/en/Design_Remoting.md                         |   50 +
 docs/en/Design_Store.md                            |   39 +
 docs/en/Design_Trancation.md                       |   51 +
 docs/en/Example_Batch.md                           |   76 ++
 docs/en/Example_Delay.md                           |   85 ++
 docs/en/Example_Filter.md                          |   86 ++
 docs/en/Example_Orderly.md                         |  233 ++++
 docs/en/Example_Simple.md                          |  136 ++
 docs/en/Example_Transaction.md                     |   96 ++
 docs/en/FAQ.md                                     |  100 ++
 docs/en/Feature.md                                 |   86 ++
 docs/en/Operations_Broker.md                       |   23 +
 docs/en/Operations_Consumer.md                     |  106 ++
 docs/en/Operations_Producer.md                     |   44 +
 docs/en/Operations_Trace.md                        |  108 ++
 docs/en/Troubleshoopting.md                        |   76 ++
 docs/en/acl/Operations_ACL.md                      |   76 ++
 docs/en/architecture.md                            |   46 +
 docs/en/best_practice.md                           |   29 +
 docs/en/design.md                                  |  110 ++
 docs/{cn => en}/image/rocketmq_architecture_1.png  |  Bin
 docs/{cn => en}/image/rocketmq_architecture_2.png  |  Bin
 docs/{cn => en}/image/rocketmq_architecture_3.png  |  Bin
 docs/en/images/rocketmq_design_7.png               |  Bin 0 -> 6780 bytes
 docs/en/images/rocketmq_design_message_query.png   |  Bin 0 -> 26148 bytes
 docs/en/images/rocketmq_storage_arch.png           |  Bin 0 -> 111170 bytes
 docs/en/images/rocketmq_storage_flush.png          |  Bin 0 -> 22281 bytes
 example/pom.xml                                    |    6 +-
 .../{SqlConsumer.java => SqlFilterConsumer.java}   |   29 +-
 .../{Producer.java => SqlFilterProducer.java}      |   36 +-
 .../rocketmq/example/filter/SqlProducer.java       |   67 -
 .../{Consumer.java => TagFilterConsumer.java}      |   12 +-
 .../{Producer.java => TagFilterProducer.java}      |   32 +-
 filter/pom.xml                                     |    2 +-
 logappender/pom.xml                                |    2 +-
 logging/pom.xml                                    |    2 +-
 namesrv/pom.xml                                    |    2 +-
 openmessaging/pom.xml                              |    2 +-
 pom.xml                                            |    4 +-
 remoting/pom.xml                                   |    2 +-
 srvutil/pom.xml                                    |    2 +-
 store/pom.xml                                      |    2 +-
 .../apache/rocketmq/store/BatchPutMessageTest.java |  172 +++
 .../apache/rocketmq/store/ConsumeQueueTest.java    |    1 +
 .../store/DefaultMessageStoreCleanFilesTest.java   |  387 ++++++
 .../rocketmq/store/DefaultMessageStoreTest.java    |  318 ++++-
 .../java/org/apache/rocketmq/store/HATest.java     |  182 +++
 .../org/apache/rocketmq/store/StoreTestUtil.java   |   89 ++
 .../store/schedule/ScheduleMessageServiceTest.java |  224 ++++
 test/pom.xml                                       |    2 +-
 tools/pom.xml                                      |    2 +-
 .../tools/command/topic/UpdateTopicSubCommand.java |   12 +-
 .../UpdateKvConfigCommandTest.java}                |   21 +-
 109 files changed, 9774 insertions(+), 398 deletions(-)
 copy client/src/test/java/org/apache/rocketmq/client/{consumer/DefaultMQPushConsumerTest.java
=> impl/consumer/ConsumeMessageConcurrentlyServiceTest.java} (51%)
 create mode 100644 common/src/test/java/org/apache/rocketmq/common/admin/TopicStatsTableTest.java
 create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/ClusterInfoTest.java
 create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/body/CheckClientRequestBodyTest.java
 create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/body/ConsumeStatsListTest.java
 create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/body/ConsumerConnectionTest.java
 copy common/src/test/java/org/apache/rocketmq/common/protocol/{ConsumeStatusTest.java =>
body/KVTableTest.java} (57%)
 copy common/src/test/java/org/apache/rocketmq/common/protocol/{ConsumeStatusTest.java =>
body/QueryCorrectionOffsetBodyTest.java} (56%)
 copy common/src/{main/java/org/apache/rocketmq/common/protocol/body/GetConsumerStatusBody.java
=> test/java/org/apache/rocketmq/common/protocol/body/ResetOffsetBodyTest.java} (55%)
 create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/body/SubscriptionGroupWrapperTest.java
 create mode 100644 common/src/test/java/org/apache/rocketmq/common/stats/StatsItemSetTest.java
 create mode 100644 docs/cn/RocketMQ_Example.md
 create mode 100644 docs/cn/acl/user_guide.md
 create mode 100755 docs/cn/best_practice.md
 create mode 100644 docs/cn/client/java/API_Reference_DefaultMQProducer.md
 create mode 100644 docs/cn/design.md
 create mode 100644 docs/cn/features.md
 create mode 100644 docs/cn/image/rocketmq_design_1.png
 create mode 100644 docs/cn/image/rocketmq_design_10.png
 create mode 100644 docs/cn/image/rocketmq_design_11.png
 create mode 100644 docs/cn/image/rocketmq_design_12.png
 create mode 100644 docs/cn/image/rocketmq_design_13.png
 create mode 100644 docs/cn/image/rocketmq_design_2.png
 create mode 100644 docs/cn/image/rocketmq_design_3.png
 create mode 100644 docs/cn/image/rocketmq_design_4.png
 create mode 100644 docs/cn/image/rocketmq_design_5.png
 create mode 100644 docs/cn/image/rocketmq_design_6.png
 create mode 100644 docs/cn/image/rocketmq_design_7.png
 create mode 100644 docs/cn/image/rocketmq_design_8.png
 create mode 100644 docs/cn/image/rocketmq_design_9.png
 create mode 100644 docs/cn/msg_trace/user_guide.md
 create mode 100644 docs/cn/operation.md
 create mode 100644 docs/en/CLITools.md
 create mode 100644 docs/en/Concept.md
 create mode 100644 docs/en/Configuration_Client.md
 create mode 100644 docs/en/Configuration_System.md
 create mode 100644 docs/en/Deployment.md
 create mode 100644 docs/en/Design_Filter.md
 create mode 100644 docs/en/Design_LoadBlancing.md
 create mode 100644 docs/en/Design_Query.md
 create mode 100644 docs/en/Design_Remoting.md
 create mode 100644 docs/en/Design_Store.md
 create mode 100644 docs/en/Design_Trancation.md
 create mode 100644 docs/en/Example_Batch.md
 create mode 100644 docs/en/Example_Delay.md
 create mode 100644 docs/en/Example_Filter.md
 create mode 100644 docs/en/Example_Orderly.md
 create mode 100644 docs/en/Example_Simple.md
 create mode 100644 docs/en/Example_Transaction.md
 create mode 100644 docs/en/FAQ.md
 create mode 100644 docs/en/Feature.md
 create mode 100644 docs/en/Operations_Broker.md
 create mode 100644 docs/en/Operations_Consumer.md
 create mode 100644 docs/en/Operations_Producer.md
 create mode 100644 docs/en/Operations_Trace.md
 create mode 100644 docs/en/Troubleshoopting.md
 create mode 100644 docs/en/acl/Operations_ACL.md
 create mode 100644 docs/en/architecture.md
 create mode 100755 docs/en/best_practice.md
 create mode 100644 docs/en/design.md
 copy docs/{cn => en}/image/rocketmq_architecture_1.png (100%)
 copy docs/{cn => en}/image/rocketmq_architecture_2.png (100%)
 copy docs/{cn => en}/image/rocketmq_architecture_3.png (100%)
 create mode 100644 docs/en/images/rocketmq_design_7.png
 create mode 100644 docs/en/images/rocketmq_design_message_query.png
 create mode 100644 docs/en/images/rocketmq_storage_arch.png
 create mode 100644 docs/en/images/rocketmq_storage_flush.png
 rename example/src/main/java/org/apache/rocketmq/example/filter/{SqlConsumer.java => SqlFilterConsumer.java}
(74%)
 copy example/src/main/java/org/apache/rocketmq/example/filter/{Producer.java => SqlFilterProducer.java}
(59%)
 delete mode 100644 example/src/main/java/org/apache/rocketmq/example/filter/SqlProducer.java
 rename example/src/main/java/org/apache/rocketmq/example/filter/{Consumer.java => TagFilterConsumer.java}
(81%)
 rename example/src/main/java/org/apache/rocketmq/example/filter/{Producer.java => TagFilterProducer.java}
(59%)
 create mode 100644 store/src/test/java/org/apache/rocketmq/store/BatchPutMessageTest.java
 create mode 100644 store/src/test/java/org/apache/rocketmq/store/DefaultMessageStoreCleanFilesTest.java
 create mode 100644 store/src/test/java/org/apache/rocketmq/store/HATest.java
 create mode 100644 store/src/test/java/org/apache/rocketmq/store/StoreTestUtil.java
 create mode 100644 store/src/test/java/org/apache/rocketmq/store/schedule/ScheduleMessageServiceTest.java
 copy tools/src/test/java/org/apache/rocketmq/tools/command/{broker/UpdateBrokerConfigSubCommandTest.java
=> namesrv/UpdateKvConfigCommandTest.java} (74%)


Mime
View raw message