rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From duhengfore...@apache.org
Subject [rocketmq] branch master updated (0fe5e50 -> a220364)
Date Fri, 14 Sep 2018 08:58:22 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from 0fe5e50  Replace slack default url with automation invitation link
     add 0fff4a8  shutdown transactionalMessageCheckService
     add efa8e45  [ISSUE #396]Use separated thread pool and add monitor tools for transactional
message (#397)
     add c67a80a  Merge branch 'develop' into master
     add 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
     add cdf4042  Merge pull request #398 from duhengforever/develop_compatibility_issue
     add 901e06a  Fix }
     add 37a642c  [ISSUE430]Remove scripts releate to filtersrv (#431)
     add 5898399  Modify commandLine getOption
     add f6746a7  Merge pull request #440 from Hellojungle/fix#439
     add b620b9c  Fix the problem when method executeLocalTransaction return LocalTransactionState.COMMIT_MESSAGE
but still executing checkLocalTransaction method
     add 53a6346  Merge pull request #450 from joewee/fix-rocketMQClient
     new a220364  Merge branch 'develop'

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:
 .../apache/rocketmq/broker/BrokerController.java   | 33 +++++++-
 .../rocketmq/broker/latency/BrokerFastFailure.java |  3 +
 .../broker/processor/AdminBrokerProcessor.java     |  4 +
 .../rocketmq/broker/util/ServiceProvider.java      | 32 ++++----
 .../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   | 37 ++++++++-
 .../java/org/apache/rocketmq/common/MQVersion.java |  2 +-
 .../java/org/apache/rocketmq/common/MixAll.java    |  2 +-
 distribution/bin/mqfiltersrv                       | 45 -----------
 distribution/bin/mqfiltersrv.cmd                   | 23 ------
 distribution/bin/mqfiltersrv.xml                   | 45 -----------
 distribution/conf/logback_filtersrv.xml            | 87 --------------------
 .../example/benchmark/TransactionProducer.java     | 83 ++++++++++---------
 .../transaction/TransactionListenerImpl.java       |  2 +
 .../command/message/ConsumeMessageCommand.java     |  2 +-
 22 files changed, 315 insertions(+), 317 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%)
 delete mode 100644 distribution/bin/mqfiltersrv
 delete mode 100644 distribution/bin/mqfiltersrv.cmd
 delete mode 100644 distribution/bin/mqfiltersrv.xml
 delete mode 100644 distribution/conf/logback_filtersrv.xml


Mime
View raw message