rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dongefore...@apache.org
Subject [rocketmq] branch develop updated (acb6859 -> cdf4042)
Date Tue, 21 Aug 2018 03:08:41 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from acb6859  Merge pull request #410 from chixuan777/master
     add 61a0fcb  Reslove compatibility issues and keep consistent with the old API
     add da9d5c3  Trigger travis CI
     add 9db2acd  Rename variable name
     add f6696b1  Compatible with the original transactional message API
     add 14ee75d  Remove unused import
     add 8c38d5e  Format the code style
     add 79890cb  Modify log level
     new cdf4042  Merge pull request #398 from duhengforever/develop_compatibility_issue

The 1 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:
 .../impl/producer/DefaultMQProducerImpl.java       | 92 ++++++++++++++--------
 .../client/impl/producer/MQProducerInner.java      |  7 +-
 .../client/producer/DefaultMQProducer.java         | 17 +++-
 ...Selector.java => LocalTransactionExecuter.java} | 10 ++-
 .../rocketmq/client/producer/MQProducer.java       |  6 +-
 .../client/producer/TransactionCheckListener.java  | 12 +--
 .../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(+), 94 deletions(-)
 copy client/src/main/java/org/apache/rocketmq/client/producer/{MessageQueueSelector.java
=> LocalTransactionExecuter.java} (77%)
 copy common/src/main/java/org/apache/rocketmq/common/filter/MessageFilter.java => client/src/main/java/org/apache/rocketmq/client/producer/TransactionCheckListener.java
(74%)


Mime
View raw message