This is an automated email from the ASF dual-hosted git repository.
zhouxzhan pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 5e2ad386f [ISSUE #6036] Optimize the PULL_REQUEST_TEMPLATE.md (#6037)
new 144254a5c [ISSUE #5884] Concurrent check CommitLog messages
new b92a29e13 Create ConcurrentReputMessageService and replace native
thread with ServiceThread
new 8a3c7ffde Fixed the infinite loop bug and useless import
new 8bf81c468 Set a custom reject policy for batchDispatchRequestExecutor
new d211e8664 Change the reject policy to AbortPolicy and add try catch
final protect
new 87c0a0316 Refactor LOGGER.warn()
new 04b8400eb Refactor MainBatchDispatchRequestService and DispatchService
service object locations
new 65e3d1e4c Add try catch
new e5c19647a Fix codeStyle issue
new 2af52a5db Delete redundant method run()
new d2a4b7047 Change the permission modifier of reputFromOffset from
public to protected
new 64dbc2695 Add case MESSAGE_MAGIC_CODE_V2
new dcf84e412 Add integration test and add
enableBuildConsumeQueueConcurrently attribute to BrokerConfig class
new c2ea0922b Remove enableBuildConsumeQueueConcurrently attribute from
BrokerConfig class
new ee6cddfdb Combine the process of decoding byteBuffer into
preCheckMessageAndReturnSize method
new 07e65d37d Put batchDispatchRequestThreadPoolNums config to
MessageStoreConfig.java
new 7d58f6881 Modify abbreviated variables and add comments
new 50651ef8d Add integration test
The 18 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:
.../org/apache/rocketmq/common/BrokerConfig.java | 1 +
.../apache/rocketmq/store/DefaultMessageStore.java | 402 ++++++++++++++++++++-
.../rocketmq/store/config/MessageStoreConfig.java | 23 ++
.../test/smoke/NormalMessageSendAndRecvIT.java | 51 ++-
4 files changed, 462 insertions(+), 15 deletions(-)
