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