You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by do...@apache.org on 2018/08/21 03:08:42 UTC

[rocketmq] 01/01: Merge pull request #398 from duhengforever/develop_compatibility_issue

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 cdf4042821e281974dd69d04bb792d856b6fb21a
Merge: acb6859 79890cb
Author: Zhendong Liu <zh...@yeah.net>
AuthorDate: Tue Aug 21 11:08:38 2018 +0800

    Merge pull request #398 from duhengforever/develop_compatibility_issue
    
    [ISSUE #395]Resolve compatibility issues and keep consistent with the old API

 .../impl/producer/DefaultMQProducerImpl.java       | 92 ++++++++++++++--------
 .../client/impl/producer/MQProducerInner.java      |  7 +-
 .../client/producer/DefaultMQProducer.java         | 17 +++-
 ...Listener.java => LocalTransactionExecuter.java} | 25 ++----
 .../rocketmq/client/producer/MQProducer.java       |  6 +-
 .../TransactionCheckListener.java}                 | 28 ++-----
 .../client/producer/TransactionListener.java       |  2 +-
 .../client/producer/TransactionMQProducer.java     | 86 +++++++++++++++++---
 .../org/apache/rocketmq/common/BrokerConfig.java   |  2 +-
 .../java/org/apache/rocketmq/common/MixAll.java    |  2 +-
 .../example/benchmark/TransactionProducer.java     | 83 ++++++++++---------
 .../transaction/TransactionListenerImpl.java       |  2 +
 12 files changed, 227 insertions(+), 125 deletions(-)