rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jinrongt...@apache.org
Subject [rocketmq] branch master updated (73bb4b4 -> 8ef01a6)
Date Tue, 17 Mar 2020 03:19:03 GMT
This is an automated email from the ASF dual-hosted git repository.

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


    from 73bb4b4  [maven-release-plugin] prepare release rocketmq-all-4.6.1
     add dd94362  [maven-release-plugin] prepare for next development iteration
     add c572b4b  [ISSUE #1409] Fix the bug when use queryMsgByKey or queryMsgByUniqueKey
command in aclEnable = true (#1756)
     add 689e770  [ISSUE #1751]Fix bug in MessageClientIDSetter (#1758)
     add d03e46a  [ISSUE #1771]add MessageExt.getBrokerName   for issue  (#1772)
     add 35c3888  min value for autoCommitIntervalMillis.   #1774 (#1775)
     add d15234c  Improve exception handle of transaction check service (#1783)
     add fc3fb2f  [ISSUE #1787] Fix the issue that queryCq command of mqadmin returned incorrect
data (#1793)
     add b628114  chore(pom):update fastjson version (#1795)
     add 0e7d271  fix(pull_schedual) add the namespace wrapper in callback (#1804)
     add f28be82  optimization : change SYNC_MASTER flushSlave/flushDisk to pipeline to reduce
produce latency and improve throughput
     add d7cafdf  WIP: compatible with JDK1.6
     add a0955a4  compatible with JDK1.6 in remoting module
     add a785bcf  fix checkStyle
     add 207d4c0  compatible with dledger
     add 6818568  compatible with dledger
     add f6c05db  resolved PR 1516 merge conflicts
     add 7a6f0ac  1. eliminate redundant CountDownLaunch in GroupCommitRequest 2. fix properties
when store message 3. add IT for transaction 4. correct resonse code when slave down
     add b143ff6  resolve conflict
     add 64e4ca7  Merge pull request #1516 from shenhui0509/sync_pipeline
     add 40710b0  Fix asynchronous send retry
     add be67ff4  Merge branch 'master' into master
     add 997164b  Merge pull request #1800 from Cczzzz/master
     add e875ddb  chore(version):modify current version to prepare release 4.7.0
     add c233f65  chore(all):update the year in notice file and correct header in NamespaceUtilTest
     add d119204  fix(test):fix the issue that MessageClientIDSetter#getIPFromID return wrong
pid when pid greater than short type max value
     add d7102c0  Merge pull request #1822 from RongtongJin/fix_1821
     add 8ef01a6  [maven-release-plugin] prepare release rocketmq-all-4.7.0

No new revisions were added by this update.

Summary of changes:
 NOTICE                                             |   2 +-
 acl/pom.xml                                        |   2 +-
 .../rocketmq/acl/plain/PlainAccessValidator.java   |   4 +-
 .../acl/plain/PlainAccessValidatorTest.java        |  16 +
 broker/pom.xml                                     |   2 +-
 .../broker/plugin/AbstractPluginMessageStore.java  |  12 +
 .../processor/AbstractSendMessageProcessor.java    |   3 +-
 .../broker/processor/AdminBrokerProcessor.java     |   9 +-
 .../broker/processor/ClientManageProcessor.java    |   3 +-
 .../broker/processor/ConsumerManageProcessor.java  |   3 +-
 .../broker/processor/EndTransactionProcessor.java  |   3 +-
 .../broker/processor/ForwardRequestProcessor.java  |   3 +-
 .../broker/processor/PullMessageProcessor.java     |   3 +-
 .../broker/processor/QueryMessageProcessor.java    |   3 +-
 .../broker/processor/SendMessageProcessor.java     | 276 ++++++++++++------
 .../transaction/TransactionalMessageService.java   |   9 +
 .../queue/TransactionalMessageBridge.java          |   5 +
 .../queue/TransactionalMessageServiceImpl.java     |   9 +-
 .../broker/processor/SendMessageProcessorTest.java |  37 ++-
 .../queue/TransactionalMessageBridgeTest.java      |   9 +
 .../util/TransactionalMessageServiceImpl.java      |   7 +
 client/pom.xml                                     |   2 +-
 .../client/consumer/DefaultLitePullConsumer.java   |   9 +-
 .../consumer/MQPullConsumerScheduleService.java    |   3 +-
 .../client/impl/ClientRemotingProcessor.java       |   3 +-
 .../rocketmq/client/impl/MQClientAPIImpl.java      |  10 +-
 .../client/impl/consumer/PullAPIWrapper.java       |   1 +
 common/pom.xml                                     |   2 +-
 .../java/org/apache/rocketmq/common/MQVersion.java |   2 +-
 .../common/message/MessageClientIDSetter.java      |  14 +-
 .../apache/rocketmq/common/message/MessageExt.java |  12 +-
 .../common/message/MessageClientIDSetterTest.java  |  23 +-
 .../common/protocol/NamespaceUtilTest.java         |  20 +-
 distribution/pom.xml                               |   2 +-
 example/pom.xml                                    |   6 +-
 filter/pom.xml                                     |   2 +-
 logappender/pom.xml                                |   2 +-
 logging/pom.xml                                    |   2 +-
 namesrv/pom.xml                                    |   2 +-
 .../namesrv/processor/DefaultRequestProcessor.java |   3 +-
 openmessaging/pom.xml                              |   2 +-
 pom.xml                                            |   6 +-
 remoting/pom.xml                                   |   2 +-
 ...cessor.java => AsyncNettyRequestProcessor.java} |  13 +-
 .../remoting/netty/NettyRemotingAbstract.java      |  43 ++-
 .../remoting/netty/NettyRequestProcessor.java      |   1 +
 ...ventType.java => RemotingResponseCallback.java} |  10 +-
 .../remoting/protocol/RemotingCommand.java         |   2 +-
 .../rocketmq/remoting/RemotingServerTest.java      |   9 +-
 srvutil/pom.xml                                    |   2 +-
 store/pom.xml                                      |   2 +-
 .../java/org/apache/rocketmq/store/CommitLog.java  | 324 +++++++++++++++++++--
 .../apache/rocketmq/store/DefaultMessageStore.java | 166 +++++++----
 .../org/apache/rocketmq/store/MessageStore.java    |  22 ++
 .../rocketmq/store/dledger/DLedgerCommitLog.java   |  11 +
 .../java/org/apache/rocketmq/store/HATest.java     |  39 ++-
 test/pom.xml                                       |   2 +-
 .../test/client/rmq/RMQTransactionalProducer.java  | 106 +++++++
 .../org/apache/rocketmq/test/base/BaseConf.java    |  11 +
 .../producer/transaction/TransactionalMsgIT.java   | 116 ++++++++
 tools/pom.xml                                      |   2 +-
 61 files changed, 1147 insertions(+), 284 deletions(-)
 copy remoting/src/main/java/org/apache/rocketmq/remoting/netty/{NettyRequestProcessor.java
=> AsyncNettyRequestProcessor.java} (73%)
 copy remoting/src/main/java/org/apache/rocketmq/remoting/netty/{NettyEventType.java =>
RemotingResponseCallback.java} (84%)
 create mode 100644 test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQTransactionalProducer.java
 create mode 100644 test/src/test/java/org/apache/rocketmq/test/client/producer/transaction/TransactionalMsgIT.java


Mime
View raw message