You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2020/02/28 10:22:27 UTC
[rocketmq] branch develop updated (0e7d271 -> 64e4ca7)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
from 0e7d271 fix(pull_schedual) add the namespace wrapper in callback (#1804)
new f28be82 optimization : change SYNC_MASTER flushSlave/flushDisk to pipeline to reduce produce latency and improve throughput
new d7cafdf WIP: compatible with JDK1.6
new a0955a4 compatible with JDK1.6 in remoting module
new a785bcf fix checkStyle
new 207d4c0 compatible with dledger
new 6818568 compatible with dledger
new f6c05db resolved PR 1516 merge conflicts
new 7a6f0ac 1. eliminate redundant CountDownLaunch in GroupCommitRequest 2. fix properties when store message 3. add IT for transaction 4. correct resonse code when slave down
new b143ff6 resolve conflict
new 64e4ca7 Merge pull request #1516 from shenhui0509/sync_pipeline
The 1327 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:
.../broker/plugin/AbstractPluginMessageStore.java | 12 +
.../processor/AbstractSendMessageProcessor.java | 3 +-
.../broker/processor/AdminBrokerProcessor.java | 3 +-
.../broker/processor/ClientManageProcessor.java | 3 +-
.../broker/processor/ConsumerManageProcessor.java | 3 +-
.../broker/processor/EndTransactionProcessor.java | 3 +-
.../broker/processor/ForwardRequestProcessor.java | 3 +-
.../broker/processor/PullMessageProcessor.java | 3 +-
.../broker/processor/QueryMessageProcessor.java | 3 +-
.../broker/processor/SendMessageProcessor.java | 276 ++++++++++++------
.../transaction/TransactionalMessageService.java | 9 +
.../queue/TransactionalMessageBridge.java | 5 +
.../queue/TransactionalMessageServiceImpl.java | 6 +
.../broker/processor/SendMessageProcessorTest.java | 37 ++-
.../queue/TransactionalMessageBridgeTest.java | 9 +
.../util/TransactionalMessageServiceImpl.java | 7 +
.../client/impl/ClientRemotingProcessor.java | 3 +-
.../namesrv/processor/DefaultRequestProcessor.java | 3 +-
...cessor.java => AsyncNettyRequestProcessor.java} | 13 +-
.../remoting/netty/NettyRemotingAbstract.java | 43 ++-
.../remoting/netty/NettyRequestProcessor.java | 1 +
...ventType.java => RemotingResponseCallback.java} | 10 +-
.../rocketmq/remoting/RemotingServerTest.java | 9 +-
.../java/org/apache/rocketmq/store/CommitLog.java | 324 +++++++++++++++++++--
.../apache/rocketmq/store/DefaultMessageStore.java | 166 +++++++----
.../org/apache/rocketmq/store/MessageStore.java | 22 ++
.../rocketmq/store/dledger/DLedgerCommitLog.java | 11 +
.../java/org/apache/rocketmq/store/HATest.java | 39 ++-
.../test/client/rmq/RMQTransactionalProducer.java | 106 +++++++
.../org/apache/rocketmq/test/base/BaseConf.java | 11 +
.../producer/transaction/TransactionalMsgIT.java | 116 ++++++++
31 files changed, 1037 insertions(+), 225 deletions(-)
copy remoting/src/main/java/org/apache/rocketmq/remoting/netty/{NettyRequestProcessor.java => AsyncNettyRequestProcessor.java} (73%)
copy remoting/src/main/java/org/apache/rocketmq/remoting/netty/{NettyEventType.java => RemotingResponseCallback.java} (84%)
create mode 100644 test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQTransactionalProducer.java
create mode 100644 test/src/test/java/org/apache/rocketmq/test/client/producer/transaction/TransactionalMsgIT.java