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
|