You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by du...@apache.org on 2021/06/29 05:41:42 UTC
[rocketmq] branch pop_consumer updated (d98192b -> 48fa70b)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch pop_consumer
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
from d98192b Merge pull request #2908 from duhenglucky/duheng_pop_consumer
add f5cf3cc Fix ORIGIN_MESSAGE_ID field not write into commitlog (#2869)
add 6c279f3 docs(fix typo)
add 8a2554d [ISSUE #2826] Remove useless code (#2827)
add 662404e [ISSUE #1057]Filter out docker0 when finding a local address (#1177)
add 18dadeb Add unit tests for org.apache.rocketmq.common.UtilAll (#1249)
add f37dc18 Fix some code style issue and remove redundant code (#1378)
add 305b195 fix(script): windows can not startup when acl enable(#1393)
add f799f17 Revert "Add unit tests for org.apache.rocketmq.common.UtilAll (#1249)"
add 8e9fa51 Merge pull request #2913 from apache/revert-1249-add-diffblue-tests
add 432236e Revert 2912 & 2866 and merge to develop branch(#2915)
add b34e68a Fix ConcurrentModificationException
add 85ab220 Fix concurrent issue of test of tracer of OpenTracing
add 0aaaeb6 DefaultMQPushConsumerTest/DefaultMQConsumerWithOpenTracingTest mock everything before start
add b0a8959 Merge pull request #2917 from ayanamist/fix-test
add 908782f [ISSUE #2921]Fix consume msgtrace loss (#2922)
add 4e73ba0 docs(example): change delay start point (#2586)
add 088dd29 update fastjson version from 1.2.69 to 1.2.76
add 4d1b9cf Merge pull request #2923 from nibiwodong/develop
add 11703c3 [ISSUE #2698] TopicRouteSubCommand enhancement
add 48d36bd [ISSUE #2698] TopicRouteSubCommand enhancement
add 40d4a22 [ISSUE #2698] TopicRouteSubCommand enhancement
add 6323754 [ISSUE #2698] TopicRouteSubCommand enhancement
add d444dd2 [ISSUE #2698] TopicRouteSubCommand enhancement
add a0dbca7 Merge pull request #2712 from lizhimins/update_topicRouteSubCommand
add 32881d4 add the property of benchmark producer that specifies how many messages to send
add 2d18e50 Print InterruptedException message
add 1c75d02 Merge pull request #2617 from xxd763795151/bench_producer_num
add 7006d3a benchmark consumer isSuffixEnable default value set [false] and update help info
add 58cbf59 recover the property key of group suffix enable
add 88add9d Merge pull request #2608 from xxd763795151/bench_consumer
add 9eca70f Add delay message stats to brokerStatsManager
add d510dd7 Add constuctor of default
add a8606d4 Add check to avoid npe
add 19fb42f Add config enableScheduleMessageStats
add 5f9f75a0 Add UT
add 3e1d501 Merge pull request #2684 from maixiaohai/add_delay_message_stats_to_stats_manager
add 5829fbd #2935 check kv config should not be null
add 0430860 Merge pull request #2936 from yuz10/develop3
add 85168cd fix the problem of potential NPE in ACL plain
add 7b7e45b fix the problem of potential NPE in ACL plain
add b219c16 fix the problem of potential NPE in ACL plain
add 4f48fb7 gerge branch 'develop' of https://github.com/shendongsd/rocketmq into develop
add 7804c74 Merge branch 'develop' of https://github.com/shendongsd/rocketmq into develop
add 7af4307 Merge branch 'develop' of https://github.com/shendongsd/rocketmq into develop
add 99b69ab Merge branch 'develop' of https://github.com/shendongsd/rocketmq into develop
add cd183b8 Merge branch 'develop' of https://github.com/shendongsd/rocketmq into develop
add e320775 Merge branch 'develop' of https://github.com/shendongsd/rocketmq into develop
add d21f4d3 Merge pull request #2893 from shendongsd/develop
add 3401ba5 [ACL] Parameter verification
add 7848895 Merge branch 'develop' into enhanced_acl
add 59718fd Merge pull request #2418 from Git-Yang/enhanced_acl
add b78326d [ISSUE #2783] fix_bug_in_ThreadLocalIndex
add 2fb5f7a Merge pull request #2785 from Kingdon1992/fix_bug_in_ThreadLocalIndex
add 952772f fix(dledger): reload the delay offset when master changed (#2518)
add 7a6edb7 [ISSUE #2926] fix fast-try.sh fail to run in ubuntu (#2927)
add 99b42f2 [ISSUE #2735] QueryMsgByUniqueKey tool should return all messages with same unique key
add 672f581 [ISSUE #2735] QueryMsgByUniqueKey tool should return all messages with same unique key
add c34796b [ISSUE #2735] QueryMsgByUniqueKey tool should return all messages with same unique key
add 4daf0ee Merge pull request #2943 from lizhimins/develop
add 6ab6afd [ISSUE #2708] Client may submit wrong offset when network instability
add da589b1 [ISSUE #2708] Client may submit wrong offset when network instability
add 707d1b8 [ISSUE #2708] Client may submit wrong offset when network instability, add more log
add 4f7e831 [ISSUE #2708] Fix unit test
add 96a4e55 [ISSUE #2708] Fix unit test
add da286a4 [ISSUE #2708] Fix unit test
add 436d72b [ISSUE #2708] Fix unit test
add 9f90a23 [ISSUE #2708] Fix unit test
add 715a614 [ISSUE #2708] Fix unit test
add fb34b64 [ISSUE #2708] Reformat
add c3750b3 [ISSUE #2708] Reformat
add cca4d92 Merge pull request #2948 from lizhimins/fix-offset
add fbb35d3 [ISSUE #2898] Resolve rocketmq-example project failed during checkstyle execution
add e47f655 Merge remote-tracking branch 'upstream/develop' into develop
add b81e90f Merge remote-tracking branch 'upstream/develop' into develop
add db05f81 Merge remote-tracking branch 'upstream/develop' into develop
add f244ee3 [ISSUE #2556] LitePullConsumer support message trace.
add 2dc75d3 The messageTrace related configurations is set as a property
add 620d02f Merge pull request #2930 from zhangjidi2016/litePullConsumer_support_msgTrace
add ae394c7 Update operation.md
add 8e05485 Merge pull request #2951 from hehejiejie/develop
add 5515791 [ISSUE #2556] The queryMsgTraceById command supports specifying the customerTraceTopic
add 5e99cdb Merge pull request #2952 from zhangjidi2016/develop
add 3ae2517 Delete README
add b4240d5 docs(reblance design): modify typographical issues
add 1669448 [ISSUE #2865] Batch message send bug fix (#2866)
add 129d7e2 Revert "[ISSUE #2865] Batch message send bug fix (#2866)" (#2912)
add bc1c1b1 docs(architecture_cn): fix incorrect description of the Producer module (#2856)
add aaa92a2 Revert "docs(architecture_cn): fix incorrect description of the Producer module (#2856)" (#2928)
add 60fc4c4 Merge branch 'master' into develop
add 93974b0 chore(release): prepare to release rocketmq 4.9.0
add 5203d52 [maven-release-plugin] prepare release rocketmq-all-4.9.0
add df1d93f [maven-release-plugin] prepare for next development iteration
add 48fa70b Merge branch 5.0.0-preview into pop_consumer
No new revisions were added by this update.
Summary of changes:
acl/pom.xml | 2 +-
.../apache/rocketmq/acl/common/AclConstants.java | 10 +
.../org/apache/rocketmq/acl/common/Permission.java | 29 +-
.../rocketmq/acl/plain/PlainPermissionManager.java | 44 +--
.../acl/plain/RemoteAddressStrategyFactory.java | 2 +-
.../apache/rocketmq/acl/common/PermissionTest.java | 24 ++
.../acl/plain/PlainAccessValidatorTest.java | 20 ++
broker/pom.xml | 2 +-
.../broker/loadbalance/AssignmentManager.java | 2 +-
.../rocketmq/broker/mqtrace/SendMessageHook.java | 6 +-
.../broker/processor/SendMessageProcessor.java | 2 +
.../apache/rocketmq/broker/BrokerOuterAPITest.java | 2 +-
client/pom.xml | 6 +-
.../rocketmq/client/common/ThreadLocalIndex.java | 5 +-
.../client/consumer/DefaultLitePullConsumer.java | 65 +++++
.../client/consumer/DefaultMQPushConsumer.java | 2 +-
.../apache/rocketmq/client/impl/MQAdminImpl.java | 16 +-
.../impl/consumer/DefaultLitePullConsumerImpl.java | 66 ++++-
.../impl/consumer/DefaultMQPushConsumerImpl.java | 37 ++-
.../rocketmq/client/impl/consumer/PullRequest.java | 10 +-
.../client/impl/consumer/RebalanceImpl.java | 34 ++-
.../impl/consumer/RebalanceLitePullImpl.java | 18 +-
.../client/impl/consumer/RebalancePullImpl.java | 7 +
.../client/impl/consumer/RebalancePushImpl.java | 23 +-
.../rocketmq/client/trace/TraceDataEncoder.java | 16 +-
.../apache/rocketmq/client/trace/TraceView.java | 12 +-
.../trace/hook/ConsumeMessageTraceHookImpl.java | 16 +-
.../trace/hook/SendMessageTraceHookImpl.java | 1 -
.../client/consumer/DefaultMQPushConsumerTest.java | 27 +-
.../impl/consumer/RebalancePushImplTest.java | 6 +
.../DefaultMQConsumerWithOpenTracingTest.java | 80 +++---
...=> DefaultMQLitePullConsumerWithTraceTest.java} | 314 ++++++++++-----------
.../client/trace/TraceDataEncoderTest.java | 5 +-
.../rocketmq/client/trace/TraceViewTest.java | 40 +--
common/pom.xml | 2 +-
.../java/org/apache/rocketmq/common/MQVersion.java | 2 +-
.../apache/rocketmq/common/constant/PermName.java | 4 +-
.../rocketmq/common/hook/FilterCheckHook.java | 4 +-
distribution/bin/dledger/fast-try.sh | 24 +-
distribution/bin/runbroker.cmd | 2 +-
distribution/bin/runserver.cmd | 2 +-
distribution/pom.xml | 2 +-
docs/cn/RocketMQ_Example.md | 2 +-
docs/cn/design.md | 2 +-
docs/cn/operation.md | 2 +-
docs/en/Design_LoadBlancing.md | 20 +-
example/pom.xml | 2 +-
.../rocketmq/example/benchmark/Consumer.java | 4 +-
.../rocketmq/example/benchmark/Producer.java | 70 ++++-
.../rocketmq/example/simple/PopPushConsumer.java | 1 +
filter/pom.xml | 2 +-
.../rocketmq/filter/parser/SimpleCharStream.java | 8 +-
logappender/pom.xml | 2 +-
logging/pom.xml | 2 +-
.../org/apache/rocketmq/logging/inner/Level.java | 1 -
namesrv/pom.xml | 2 +-
.../namesrv/processor/DefaultRequestProcessor.java | 5 +
openmessaging/pom.xml | 2 +-
pom.xml | 10 +-
remoting/pom.xml | 2 +-
.../rocketmq/remoting/common/RemotingUtil.java | 18 ++
srvutil/pom.xml | 2 +-
store/pom.xml | 2 +-
.../rocketmq/store/config/MessageStoreConfig.java | 10 +
.../rocketmq/store/dledger/DLedgerCommitLog.java | 58 ++--
.../store/schedule/ScheduleMessageService.java | 7 +
.../store/schedule/ScheduleMessageServiceTest.java | 11 +
test/pom.xml | 2 +-
...QBroadCastConsumer.java => RMQPopConsumer.java} | 10 +-
.../rocketmq/test/factory/ConsumerFactory.java | 10 +
.../org/apache/rocketmq/test/util/FileUtil.java | 2 +-
.../java/org/apache/rocketmq/test/util/MQWait.java | 2 +-
.../org/apache/rocketmq/test/util/RandomUtil.java | 10 +-
.../org/apache/rocketmq/test/util/RandomUtils.java | 8 +-
.../org/apache/rocketmq/test/util/VerifyUtils.java | 2 +-
.../data/collect/impl/ListDataCollectorImpl.java | 6 +-
.../rocketmq/test/base/IntegrationTestBase.java | 1 +
.../consumer/balance/NormalMsgStaticBalanceIT.java | 18 +-
.../test/client/consumer/pop/PopSubCheckIT.java | 11 +-
.../test/client/consumer/tag/MulTagSubIT.java | 6 +-
.../consumer/tag/TagMessageWithMulConsumerIT.java | 6 +-
tools/pom.xml | 2 +-
.../rocketmq/tools/admin/DefaultMQAdminExt.java | 12 +-
.../tools/admin/DefaultMQAdminExtImpl.java | 12 +-
.../command/cluster/CLusterSendMsgRTCommand.java | 2 +-
.../message/QueryMsgByUniqueKeySubCommand.java | 137 ++++-----
.../message/QueryMsgTraceByIdSubCommand.java | 68 +++--
.../tools/command/topic/TopicRouteSubCommand.java | 52 +++-
88 files changed, 1009 insertions(+), 610 deletions(-)
copy client/src/test/java/org/apache/rocketmq/client/trace/{DefaultMQConsumerWithTraceTest.java => DefaultMQLitePullConsumerWithTraceTest.java} (50%)
copy test/src/main/java/org/apache/rocketmq/test/client/rmq/{RMQBroadCastConsumer.java => RMQPopConsumer.java} (74%)