This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from c10812407 [ISSUE #5331]Fix ConsumeQueueTest stable sleep cause NPE.
(#5397)
add 5d0db77f0 [RIP-50]RocketMQ Transaction Message Improvement Of Batch OP
Message (#5386)
No new revisions were added by this update.
Summary of changes:
.../{GetResult.java => MessageQueueOpContext.java} | 35 +--
.../queue/TransactionalMessageBridge.java | 70 +++---
.../queue/TransactionalMessageServiceImpl.java | 252 +++++++++++++++++++--
.../queue/TransactionalMessageUtil.java | 4 +-
.../queue/TransactionalOpBatchService.java | 65 ++++++
.../queue/TransactionalMessageBridgeTest.java | 4 +-
.../queue/TransactionalMessageServiceImplTest.java | 26 ++-
.../org/apache/rocketmq/common/BrokerConfig.java | 23 ++
8 files changed, 398 insertions(+), 81 deletions(-)
copy
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/{GetResult.java
=> MessageQueueOpContext.java} (51%)
create mode 100644
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalOpBatchService.java
