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%)
