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 (c8892e1 -> 73bb4b4)
Date Thu, 13 Feb 2020 06:15:39 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 c8892e1  correct spelling
     add c3b7d18  [maven-release-plugin] prepare for next development iteration
     add a56bec8  feat(PullConsumer) support begin/end seek support for  pull consumer
     add 0bddfe5  test(PullConsumer) add seek to beigin/end unit test
     add 44569e4  fix(PullConsumer) fix the namespace issue of pull consumer's consumerGroup
     add 34c3454  Optimise tx benchmark producer (#1628)
     add 3d778ef  Avoid message in schedule queue enter half message queue (#1626)
     add f8f6fbe  [ISSUE #1637]Fix 1637 (#1644)
     add f1b856a  feat(pullconsumer) add pull sys flag (#1658)
     add 5964e37  fix typo:highter (#1680)
     add b3d93a0  fix typo:highter
     add 691e374  fix typo:paramter
     add 9374555  Merge pull request #1690 from LiosWong/develop
     add 9db11c7  [ISSUE #1110] Fix wrong topic max length in rocketmq client. (#1636)
     add c048e58  [ISSSUE 1188]Fix the problem when more than one producer or consumer in
the same process can trace only one (#1275) (#1303)
     add 48379e4  fix(util) make ipv4 first when choosing local IP
     add 234e04c  Merge pull request #1625 from duhenglucky/ipv4_first
     add 8e2ce06  fix #1620 amout spell error
     add f7c21db  Merge pull request #1629 from martianzhang/master
     add 1c02afd  fix(litePullConsumer):delete invalid method to get next pullBatchSize (#1702)
     add 50ba523  [ISSUE #1699] Fix wrong topic max length in TopicValidator  (#1700)
     add 1aa2355  Update README.md
     add 1f106d7  feat(pull_consumer) refactor the consumer offset update logic
     add 94dc0e0  feat(pull_consumer) refactor the consumer offset update logic
     add ad149dd  chore(pull_consumer) simplify the lite pull consumer update offset logic
     add 366e6e7  Merge pull request #1705 from duhenglucky/pull_consumer_offset
     add 958eb74  [for 4.6.0] Fix concurrent problem in ProducerManager.getAvaliableChannel;
Fix problem that tx check may loss when channel is busy (#1627)
     add ad7622c  fix(transaction) fix the send back message sent into transaction half topic
(#1649)
     add 678cab3  [ISSUE #1656] Fix StatsItem bug (#1704)
     add 881f767  typo fix (#1723)
     add 25c4e1c  Merge branch master into develop
     add 10dec57  feat(release):update version to release 4.6.1
     add 73bb4b4  [maven-release-plugin] prepare release rocketmq-all-4.6.1

No new revisions were added by this update.

Summary of changes:
 acl/pom.xml                                        |   2 +-
 broker/pom.xml                                     |   2 +-
 .../rocketmq/broker/client/ProducerManager.java    | 262 ++++++---------
 .../processor/AbstractSendMessageProcessor.java    |  11 +-
 .../broker/processor/AdminBrokerProcessor.java     |  31 +-
 .../broker/processor/EndTransactionProcessor.java  |   1 +
 .../broker/processor/SendMessageProcessor.java     |   3 +-
 .../rocketmq/broker/topic/TopicConfigManager.java  |   4 -
 .../rocketmq/broker/topic/TopicValidator.java      |  69 ++++
 .../broker/client/ProducerManagerTest.java         |  30 +-
 .../processor/ClientManageProcessorTest.java       |   3 +-
 .../rocketmq/broker/topic/TopicValidatorTest.java  |  80 +++++
 client/pom.xml                                     |   2 +-
 .../org/apache/rocketmq/client/Validators.java     |  13 +-
 .../client/consumer/DefaultLitePullConsumer.java   |  67 +++-
 .../client/consumer/DefaultMQPushConsumer.java     |   2 +-
 .../rocketmq/client/consumer/LitePullConsumer.java |  23 ++
 .../apache/rocketmq/client/impl/MQAdminImpl.java   |   2 +
 .../rocketmq/client/impl/MQClientAPIImpl.java      |   6 +-
 .../client/impl/consumer/AssignedMessageQueue.java |   6 +-
 .../consumer/ConsumeMessageOrderlyService.java     |   1 +
 .../impl/consumer/DefaultLitePullConsumerImpl.java |  88 +++--
 .../impl/consumer/DefaultMQPushConsumerImpl.java   |   1 +
 .../client/impl/consumer/RebalanceImpl.java        |   5 -
 .../impl/consumer/RebalanceLitePullImpl.java       |  71 +++-
 .../client/producer/DefaultMQProducer.java         |   4 +-
 .../client/trace/AsyncTraceDispatcher.java         |  13 +-
 .../rocketmq/client/trace/TraceConstants.java      |   2 +-
 .../rocketmq/client/trace/TraceDispatcher.java     |   5 +-
 .../org/apache/rocketmq/client/ValidatorsTest.java |   6 +-
 .../consumer/DefaultLitePullConsumerTest.java      |  75 +++++
 common/pom.xml                                     |   2 +-
 .../java/org/apache/rocketmq/common/MQVersion.java |   2 +-
 .../java/org/apache/rocketmq/common/MixAll.java    |   2 +-
 .../java/org/apache/rocketmq/common/UtilAll.java   |   6 +-
 .../apache/rocketmq/common/stats/StatsItem.java    |   9 +
 .../rocketmq/common/sysflag/PullSysFlag.java       |  16 +
 .../rocketmq/common/stats/StatsItemSetTest.java    |  29 ++
 .../rocketmq/common/sysflag/PullSysFlagTest.java   |  20 +-
 distribution/pom.xml                               |   2 +-
 example/pom.xml                                    |   6 +-
 .../example/benchmark/TransactionProducer.java     | 364 +++++++++++++++------
 .../example/simple/LitePullConsumerSubscribe.java  |   4 +-
 filter/pom.xml                                     |   2 +-
 logappender/pom.xml                                |   2 +-
 logging/pom.xml                                    |   2 +-
 namesrv/pom.xml                                    |   2 +-
 openmessaging/pom.xml                              |   2 +-
 pom.xml                                            |   4 +-
 remoting/pom.xml                                   |   2 +-
 srvutil/pom.xml                                    |   2 +-
 .../org/apache/rocketmq/srvutil/ServerUtil.java    |   3 +-
 store/pom.xml                                      |   2 +-
 .../store/schedule/ScheduleMessageService.java     |   6 +
 test/pom.xml                                       |   2 +-
 tools/pom.xml                                      |   2 +-
 .../command/cluster/CLusterSendMsgRTCommand.java   |   2 +-
 .../command/message/CheckMsgSendRTCommand.java     |   2 +-
 .../command/topic/UpdateTopicPermSubCommand.java   |   4 +-
 59 files changed, 971 insertions(+), 422 deletions(-)
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/topic/TopicValidator.java
 create mode 100644 broker/src/test/java/org/apache/rocketmq/broker/topic/TopicValidatorTest.java
 copy client/src/test/java/org/apache/rocketmq/client/common/ThreadLocalIndexTest.java =>
common/src/test/java/org/apache/rocketmq/common/sysflag/PullSysFlagTest.java (66%)


Mime
View raw message