rocketmq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From zho...@apache.org
Subject [rocketmq] branch 5.0.0-preview updated (48d3c7e -> dd09ba1)
Date Fri, 24 Sep 2021 09:07:08 GMT
This is an automated email from the ASF dual-hosted git repository.

zhoubo pushed a change to branch 5.0.0-preview
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.


    from 48d3c7e  [maven-release-plugin] prepare for next development iteration
     add a027f8d  [maven-release-plugin] prepare release rocketmq-all-4.9.0
     add a1babab  [maven-release-plugin] prepare for next development iteration
     add f42db53  Changing the comma input method
     add 317fd7e  Changing the comma input method
     add 52348b8  Merge pull request #2977 from ferris-cx/master
     add 2fe6dc3  #2990 Add message tracing switch in sendMessage command of mqadmin
     add 57c166b  Merge pull request #2991 from yuz10/develop4
     add b9c108b  Merge remote-tracking branch 'origin/develop_include_3_commits' into develop
     add 93dd086  AsyncTraceDispatcher unique groupName
     add 0c36d14  remove SubAfter field
     add a92996a  Merge pull request #3005 from lfz757077613/develop
     add 5fe0041  Change default value of some parameters: sendMessageThreadPoolNums/useReentrantLockWhenPutMessage/flushCommitLogTimed/endTransactionThreadPoolNums
     add e5a3f7d  Merge pull request #2888 from areyouok/dev_speed_D
     add e126310  [ISSUE #2997] Add a Chinese version of Configuration_System.md
     add 2b236c3  [ISSUE 3019] Fixed bug with batch-sent message statistics
     add 160c577  test(benchmark): support delay message test (#3010)
     add a0a2192  [ISSUE #2873] add benchmark for batch message
     add 6b519ef  [ISSUE #3068] remove jaeger tracing dependency in release package
     add a2f8810  [ISSUE #2988] fix fail to send trace of last message before shutting down
producer
     add fcc20de  [ISSUE #3059] typo transactional message wiki
     add 95a6275  typo
     add df35edf  Merge pull request #3088 from sunbufu/fix-a-typo
     add 9a5ec90  [ISSUE  #3109]Return a no-support value when not match any request code
     add 56c3ad8  update the option's description of deleteAccessConfig command
     add 22647de  update the option's description of updateAccessConfig command
     add b186bcd  update the option's description of consumer.sh
     add 4f33895  Merge branch 'develop' into RocketMQ-zhurunhua
     add 2a63717  Merge pull request #2882 from zhurunhua/RocketMQ-zhurunhua
     add 6591589  [ISSUE #3118] Fix type conversion exception
     add 7c36468  [ISSUE #3089] fix Print log format is incorrect in NettyRemotingAbstract
class (#3126)
     add 6cee569  duplicate doAfterRpcHooks
     add 7029545  Merge branch 'apache:develop' into develop
     add b74c48b  add trace data format test case
     add cba3e05  Merge pull request #3124 from lizhiboo/add_trace_test_case
     add d65778f  [ISSUE #2883] [Part B] Improve produce performance in M/S mode.  (#2885)
     add 3183122  Eliminate array copy (#2886)
     add 7f1cb79  remove useless code
     add 2fc1148  Merge pull request #3111 from codersfarm/develop
     add 589e87c  [ISSUE #3099] Fix the incorrect judegment  'writePos - lastCommittedPosition
> commitLeastPages' in the method 'commit0' of class 'MappedFile' (#3125)
     add f4b3d4f  fix namesrv endpoint
     add 3efcd85  Merge pull request #3122 from panzhi33/master
     add 94e0899  [ISSUE #3097] docs remove obsolete/error configuration
     add 2bd0676  Merge pull request #3116 from trdmm/develop
     add d8dec65  add different send examples
     add d0d2f15  add chinese version of FAQ.md
     add e1f94aa  Merge pull request #3034 from PatrickkZ/develop
     add 278d328  add Chinese version
     add 0cc5ad2  add Chinese version of Example_Batch
     add 69e8185  Merge pull request #3036 from Cu-Cu/master
     add 622bbbf  add some doc of the API_Reference_DefaultMQProducer of English.
     add 5908ca7  Merge pull request #3056 from zplovekq/doc_add
     add 23f3893  Add a Chinese version of Deployment.md
     add 30058cf  Merge pull request #3038 from IntroDrop/develop
     add 92f2d03  log exception stack
     add 83efcce  Merge remote-tracking branch 'upstream/develop' into fix-issue-603
     add bc73c32  use String.format() in warn log.
     add 89d9ed7  Merge pull request #3100 from sunbufu/fix-issue-603
     add a99cf37  Add Chinses Version Doc of Example_Simple.md
     add e4daba5  Merge pull request #3042 from haoran-pku/master
     add 17a8e93  fix spell error
     add cf0819e  Merge pull request #3144 from A-Zee029/master
     add 44e2669  [ISSUE #3128] fix the delete global white addresses
     add 4c1998a  retrigger ci
     add a315833  Merge pull request #3132 from zhangjidi2016/fix_update_globalWhiteAddresses
     add 04c7354  delete the unuse code
     add 36333ce  Merge pull request #3157 from yglovewms/yeyi
     add 61cd395  code style(client):polish lite pull consumer code style
     add 893e8fd  code style(client):polish lite pull consumer code style
     add 6aabf77  Merge pull request #3047 from qingjiyuji/develop
     add 18e2a26  [ISSUE #3164]Fix the checkstyle error
     add bb9a70c  Merge pull request #3165 from zhangjidi2016/fix_checkstyle_error
     add d7c2d25  [ISSUE #2708] fix offset rollback when fetch offset from broker exception
     add 5b945a9  Merge pull request #3158 from Zanglei06/fix_rmq_client_offset_dev
     add 5808772  fix checkstyle fail
     add df88bce  add msgTraceEnable config in transaction producer benchmark
     add 011035f  Merge pull request #3163 from yuz10/develop6
     add ece364a  Improve the comment of maxReconsumeTimes
     add 35a15b6  Merge pull request #3022 from heihaozi/maxReconsumeTimes
     add 25f6711  [statistics] Fix the inconsistency of putMessageDistributeTime statistics
     add 765cac3  Merge pull request #3025 from Git-Yang/statistics_bug
     add bc3eeed  fix: fix issue 2055
     add 74aa3e0  Update SendMessageProcessor.java
     add c63ec20  Merge pull request #2058 from RealBar/fix/issue2055
     add 40e1435  #2990 Add document
     add 1e982af  Merge pull request #2995 from yuz10/develop4
     add 361eb8d  Upgrade netty-all dependency version to 4.1.65.Final
     add 9a9039e  Merge pull request #3032 from messense/upgrade-netty-all
     add b954d35  feat: issue2715, make netty parameter configure by system property
     add 33a533b  feat: add some test case
     add 03adb63  feat: add some test case
     add 98237b1  feat: add some test case
     add 67ceb64  fix: add license
     add 59cbbc4  feat: add some test case
     add d60643a  Merge pull request #2720 from EZLippi/feature/issue2715
     add 36422c5  [ISSUE #3066]producing a ghost consumer
     add d93dc4d  Merge branch 'apache:develop' into develop
     add 4e5a60c  [ISSUE #2442] when happening system busy, retry
     add 062e6f3  revert [ISSUE #2442] when happening system busy, retry
     add c75ef50  Merge branch 'apache:develop' into develop
     add 8eb275f  Merge branch 'apache:develop' into develop
     add 36e6687  Merge pull request #3120 from lwclover/develop
     add 360b616  [ISSUE #3185]remove the arm machine test in travis ci
     add 0325772  [ISSUE #2883] [Part E] Improve produce performance in M/S mode.  (#2889)
     add b68724b  [ISSUE #3030]Remove the -Xmn JVM parameter when using G1 (#3170)
     add 800421e  registerProducer & unregisterProducer add synchronization too, how about
add for producer
     add 72128f7  Merge branch 'develop' of https://github.com/lwclover/rocketmq-2.git into
develop
     add 6f7b0d6  Merge pull request #3182 from lwclover/develop
     add 17b9efe  [ISSUE #3177]updateAclConfig in all brokers. (#3184)
     add 1b757b4  [ISSUE #3196] Check if "requestHeader" is null before "requestHeader.getTopic()"
     add 1eaa38f  [ISSUE #3200] Fix code style in 'NettySystemConfig.java'
     add d067bfc  [ISSUE #3192] Make free disk value more accurate
     add 20b6cdd  [ISSUE 2883] Remove an duplicate MessageDecoder.string2messageProperties
for each message, and prevent store "WAIT=true" property (in most case) to save 9 bytes for
each message.
     add a23df96  [ISSUE 2883] Improve performance of string2messageProperties/messageProperties2String,
and save 1 byte for each message.
     add 2509b0e  Merge pull request #2961 from areyouok/dev_speed_F
     add b13a4c8  [ISSUE 2883] [Part G] Optimise parse performance for SendMessageRequestHeaderV2
     add a137e48  [ISSUE 2883] [Part G] Optimise parse performance for SendMessageRequestHeaderV2,
unit test
     add 3e01424  Merge pull request #3134 from areyouok/dev_speed_G
     add 94abced  [ISSUE #3199] Two timed task for RequestFutureTable (#3202)
     add 66eeaed  #3175 check acl config before update. otherwise broker may fail to start
     add 3aa4943  fix checkstyle
     add d21266d  Merge branch 'develop' into develop3
     add 9e8fea9  Merge pull request #3176 from yuz10/develop3
     add 5e58893  prepare to release rocketmq 4.9.1 version
     add 73db297  [#Issue3205]Fix the issue of code style in client and broker modules.
     add ec985ee  Merge pull request #3206 from zongtanghu/develop_fix_4.9.1_codestyle
     add a1bfe1a  [maven-release-plugin] prepare release rocketmq-all-4.9.1
     add a7e71cb  [maven-release-plugin] prepare for next development iteration
     add 2820e47  [ISSUE #3215] polish litePullConsumer seek logic #3216
     add 5bd7ccc  Add little rocketmq robot
     add d1f9915  Place into workflows directory
     add 15b0cde  Update greetings.yml
     add 5a2aa7e  Update greetings.yml
     add d83b7e5  Fix typo
     add cfadd4d  Update greetings.yml
     add 39f549a  Update greetings.yml
     add a20f31b  Limit event trigger
     add fb8bc64  Merge branch 'develop'
     add e9c4253  [maven-release-plugin] prepare release rocketmq-all-4.9.1
     add bb34171  [maven-release-plugin] prepare for next development iteration
     add 9d4e8de  Looking at the Chinese document, I found that the subtraction operation
of countdown timer is missing in asynchronous message push, so I downloaded the code. I found
that someone added subtraction operation to the demo code in 18 years, but the document was
not repaired, so I did this repair
     add 0fdc73d  Merge pull request #3033 from zyh-future/zyh_asuncproducer_doc_fix
     add 3a2b172  [ISSUE #3006]Replace ScheduledExecutorService instead of Timer to avoid
affecting other tasks during exception (#3001)
     add 44bdeed  [ISSUE 3203] Replace the class 'StringBuffer' by 'StringBuilder' (#3204)
     add 9e66da4  Merge branch 'develop_include_prs_after_4.9.1_version', remote-tracking
branch 'origin' into develop
     add 7c7e9ac  [ISSUE #3284]Optimizing benchmark code (#3285)
     add 2cac866  [ISSUE #3136] TraceDataEncoder add SubAfter trace bean timestamp (#3137)
     add 857d28d  [ISSUE #3284]Optimizing benchmark code (#3317)
     add d7a830c  [ISSUE 3194] [PART A] Use LongAdder instead of AtomicLong in BrokerStatsService
to improve performance. (#3195)
     add fea769d  [ISSUE #3284]Optimize the buildMessage method (#3324)
     add 7519a53  [ISSUE 3333] Remove commons-codes dependency (#3334)
     add ef7685d  [ISSUE #3341](doc)fix typo in update operation.md
     add b2aa85d  [ISSUS #3340] (doc)add hyperlink for client repos in the introduction. (#3338)
     add 4b7a90a  [#3326] fix send trace fail if useTLS=true (#3325)
     add 8434658  [ISSUE #2724] Resend message to DLQ directly when max reconsume times reach
(#3318)
     add 564ee29  [ISSUE] Add get stats and single queue stats for schedule topic
     add 3604100  [ISSUE #3314] Make mqClientApi request timeout settable
     add 53c55f7  [ISSUE #3245] Use df algorithm to calculate the disk used ratio
     add 83b04d0  [ISSUE #3346]Avoid double parse remoteAddr in rpcHook call
     add bf343a3  [ISSUE #3225]change Random to ThreadLocalRandom in broker
     add 8d964f4  close #1848
     add 1f2b84b  fix #1883 fix wipeWritePerm doc desc
     add f9a0f53  Merge pull request #1858 from coder-zzzz/github_features/#1848
     add 147d23e  [ISSUE #3281 ][acl] fix fail to delete topic perm list and global white
address(#3128) (#3280)
     add 311d76f  [ISSUE 3194] [PART C] Replace AtomicLong with LongAdder in StatsItem.java
to improve performance (#3351)
     add 0a16ff6  DLQ topic default perm change
     add b822db0  Fix DLQ can't be query sometimes
     add 502ca60  fix ci
     add a9ae546  Merge pull request #2437 from maixiaohai/DLQ_perm
     add 0de4038  [ISSUE #3361]DefaultMQProducer's constructor can call the overloaded constructor.
(#3362)
     add 0363be1  add response code for retrying
     add d6da221  fix import issue
     add 67ccb7f  Merge pull request #2729 from wz2cool/master
     add 46bd4be  [ISSUE #2964] Add a query consumer config command in mqadmin.
     add a9837d9  Merge pull request #2965 from zhangjidi2016/add_getConsumerConfig_command
     add ced5843  Update rocketmq client maven version
     add ee55441  Merge pull request #3335 from zhouwentong1993/patch-1
     add 2baae14  Improve performance of expandIP, and readable
     add 7a6c374  Revert "Improve performance of expandIP, and readable"
     add 6358b3c  Revert "Improve performance of expandIP, and readable"
     add 97da4ac  Improve performance of expandIP, and readable
     add 7314183  netadress toUpperCase beforehand
     add 0748aa0  Merge pull request #3322 from 844392610/develop_xm
     add 67f4357  add checkstyle to travis ci
     add 401dc8e  production level pull api demo
     add 1e8e728  Merge pull request #3295 from lwclover/develop
     new 2bf133b  Merge branch 'develop' into 5.0.0-preview
     new dd09ba1  merger from develop branch and fix compile error

The 2 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:
 .github/workflows/greetings.yml                    |  29 +
 README.md                                          |   2 +-
 .../org/apache/rocketmq/acl/common/AclUtils.java   |  68 +-
 .../rocketmq/acl/plain/PlainPermissionManager.java |  53 +-
 .../acl/plain/RemoteAddressStrategyFactory.java    |   2 +-
 .../apache/rocketmq/acl/common/AclUtilsTest.java   |   1 +
 .../acl/plain/PlainAccessValidatorTest.java        |  53 +-
 .../broker/pagecache/ManyMessageTransfer.java      |  27 +
 .../broker/pagecache/OneMessageTransfer.java       |  27 +
 .../broker/pagecache/QueryMessageTransfer.java     |  27 +
 .../broker/plugin/AbstractPluginMessageStore.java  |   4 +-
 .../processor/AbstractSendMessageProcessor.java    |  87 ++-
 .../broker/processor/AdminBrokerProcessor.java     |  20 +-
 .../broker/processor/ReplyMessageProcessor.java    |   4 +-
 .../broker/processor/SendMessageProcessor.java     | 120 ++-
 .../AbstractTransactionalMessageCheckListener.java |   2 -
 .../DefaultTransactionalMessageCheckListener.java  |   4 +-
 .../AbstractSendMessageProcessorTest.java          |  82 ++
 client/pom.xml                                     |   4 -
 .../org/apache/rocketmq/client/ClientConfig.java   |  13 +-
 .../client/consumer/DefaultLitePullConsumer.java   |   4 +-
 .../client/consumer/DefaultMQPushConsumer.java     |  18 +-
 .../rocketmq/client/impl/MQClientAPIImpl.java      |  28 +-
 .../ConsumeMessageConcurrentlyService.java         |  28 +-
 .../consumer/ConsumeMessageOrderlyService.java     |   4 +-
 .../impl/consumer/DefaultLitePullConsumerImpl.java |  64 +-
 .../impl/consumer/DefaultMQPushConsumerImpl.java   |   2 +-
 .../client/impl/consumer/RebalanceImpl.java        |   2 +-
 .../impl/consumer/RebalanceLitePullImpl.java       |   3 +-
 .../client/impl/factory/MQClientInstance.java      |  42 +-
 .../impl/producer/DefaultMQProducerImpl.java       |  60 +-
 .../client/producer/DefaultMQProducer.java         |  54 +-
 .../client/producer/RequestFutureTable.java        |   7 +
 .../client/trace/AsyncTraceDispatcher.java         |  74 +-
 .../rocketmq/client/trace/TraceDataEncoder.java    |   1 -
 .../apache/rocketmq/client/trace/TraceView.java    |   4 +-
 .../rocketmq/client/impl/MQClientAPIImplTest.java  |  27 +
 .../ConsumeMessageConcurrentlyServiceTest.java     |   2 +-
 .../trace/DefaultMQConsumerWithTraceTest.java      |   9 +
 .../DefaultMQLitePullConsumerWithTraceTest.java    |  12 +-
 .../trace/DefaultMQProducerWithTraceTest.java      |  10 +
 .../client/trace/TraceDataEncoderTest.java         | 106 ++-
 .../rocketmq/client/trace/TraceViewTest.java       |   4 +-
 .../org/apache/rocketmq/common/BrokerConfig.java   |   8 +-
 .../java/org/apache/rocketmq/common/MixAll.java    |   1 +
 .../java/org/apache/rocketmq/common/UtilAll.java   |  33 +-
 .../apache/rocketmq/common/message/Message.java    |  11 +-
 .../rocketmq/common/message/MessageDecoder.java    |  41 +-
 .../rocketmq/common/protocol/NamespaceUtil.java    |   2 +-
 .../rocketmq/common/protocol/RequestCode.java      |   2 +
 ...java => AddWritePermOfBrokerRequestHeader.java} |   2 +-
 ...ava => AddWritePermOfBrokerResponseHeader.java} |  13 +-
 .../apache/rocketmq/common/stats/StatsItem.java    |  23 +-
 .../apache/rocketmq/common/stats/StatsItemSet.java |   8 +-
 .../common/utils/NameServerAddressUtils.java       |   1 +
 .../org/apache/rocketmq/common/UtilAllTest.java    |  14 +
 .../common/message/MessageDecoderTest.java         | 108 +++
 .../rocketmq/common/stats/StatsItemSetTest.java    |   4 +-
 .../rocketmq/common/utils/IOTinyUtilsTest.java     |   4 +-
 .../benchmark/{consumer.sh => batchproducer.sh}    |   2 +-
 distribution/bin/runbroker.cmd                     |   2 +-
 distribution/bin/runbroker.sh                      |   2 +-
 distribution/bin/runserver.cmd                     |   2 +-
 distribution/bin/runserver.sh                      |   6 +-
 distribution/release.xml                           |   4 +
 docs/cn/Configuration_System.md                    |  70 ++
 docs/cn/Deployment.md                              | 159 ++++
 docs/{en => cn}/Example_Batch.md                   |  15 +-
 docs/{en => cn}/Example_Delay.md                   |  16 +-
 .../Example_Simple.md => cn/Example_Simple_cn.md}  |  24 +-
 docs/cn/FAQ.md                                     | 110 +++
 docs/cn/RocketMQ_Example.md                        |   8 +-
 docs/cn/best_practice.md                           |   2 +-
 docs/cn/design.md                                  |   4 +-
 docs/cn/image/rocketmq_architecture_1.png          | Bin 89290 -> 62810 bytes
 docs/cn/image/rocketmq_architecture_3.png          | Bin 106758 -> 74884 bytes
 docs/cn/msg_trace/user_guide.md                    |  19 +-
 docs/cn/operation.md                               |  10 +-
 docs/en/CLITools.md                                |   8 +
 docs/en/Example_Transaction.md                     |   2 +-
 docs/en/best_practice.md                           |   2 +-
 .../client/java/API_Reference_DefaultMQProducer.md |  71 ++
 docs/en/image/rocketmq_architecture_1.png          | Bin 89290 -> 62810 bytes
 docs/en/image/rocketmq_architecture_3.png          | Bin 106758 -> 74884 bytes
 docs/en/msg_trace/user_guide.md                    |  16 +
 docs/en/operation.md                               |   2 +-
 .../rocketmq/example/benchmark/BatchProducer.java  | 403 ++++++++++
 .../rocketmq/example/benchmark/Consumer.java       |  66 +-
 .../rocketmq/example/benchmark/Producer.java       | 157 ++--
 .../example/benchmark/TransactionProducer.java     | 117 +--
 .../rocketmq/example/quickstart/Producer.java      |  33 +
 .../rocketmq/example/simple/PullConsumer.java      | 154 ++--
 .../filter/expression/UnaryExpression.java         |  16 +-
 .../rocketmq/filter/parser/ParseException.java     |   7 +-
 .../rocketmq/filter/parser/TokenMgrError.java      |   3 +-
 .../org/apache/rocketmq/filter/ParserTest.java     |   2 +-
 .../namesrv/processor/DefaultRequestProcessor.java |  26 +-
 .../namesrv/routeinfo/RouteInfoManager.java        |  43 +-
 .../namesrv/routeinfo/RouteInfoManagerTest.java    |  52 +-
 pom.xml                                            |   2 +-
 .../rocketmq/remoting/common/RemotingHelper.java   |   2 +-
 .../rocketmq/remoting/netty/NettyClientConfig.java |   8 +-
 .../rocketmq/remoting/netty/NettyLogger.java       |  46 ++
 .../remoting/netty/NettyRemotingAbstract.java      |   7 +-
 .../rocketmq/remoting/netty/NettySystemConfig.java |  16 +
 .../remoting/netty/NettyClientConfigTest.java      |  64 ++
 .../rocketmq/store/AppendMessageCallback.java      |   5 +-
 .../apache/rocketmq/store/AppendMessageResult.java |  17 +
 .../java/org/apache/rocketmq/store/CommitLog.java  | 835 ++++++++-------------
 .../apache/rocketmq/store/DefaultMessageStore.java |  73 +-
 .../java/org/apache/rocketmq/store/MappedFile.java |  26 +-
 .../rocketmq/store/MessageExtBrokerInner.java      |  12 +
 .../org/apache/rocketmq/store/MessageStore.java    |   4 +-
 .../rocketmq/store/SelectMappedBufferResult.java   |   7 -
 .../apache/rocketmq/store/StoreStatsService.java   | 109 +--
 .../rocketmq/store/config/MessageStoreConfig.java  |   7 +-
 .../rocketmq/store/dledger/DLedgerCommitLog.java   | 250 +-----
 .../org/apache/rocketmq/store/ha/HAService.java    |  63 +-
 .../apache/rocketmq/store/ha/WaitNotifyObject.java |  64 +-
 .../store/schedule/ScheduleMessageService.java     |   5 +
 .../apache/rocketmq/store/stats/BrokerStats.java   |   4 +-
 .../rocketmq/store/stats/BrokerStatsManager.java   |  50 +-
 .../apache/rocketmq/store/AppendCallbackTest.java  |  28 +-
 .../apache/rocketmq/store/BatchPutMessageTest.java |  18 +-
 .../rocketmq/store/StoreStatsServiceTest.java      |  18 +-
 .../store/schedule/ScheduleMessageServiceTest.java |   6 +-
 .../test/java/stats/BrokerStatsManagerTest.java    |  47 ++
 .../rocketmq/tools/admin/DefaultMQAdminExt.java    |   8 +-
 .../tools/admin/DefaultMQAdminExtImpl.java         |  12 +-
 .../apache/rocketmq/tools/admin/MQAdminExt.java    |   5 +-
 .../rocketmq/tools/command/MQAdminStartup.java     |   4 +
 .../command/acl/DeleteAccessConfigSubCommand.java  |  14 +-
 .../command/acl/UpdateAccessConfigSubCommand.java  |   8 +-
 .../acl/UpdateGlobalWhiteAddrSubCommand.java       |   6 +-
 .../consumer/GetConsumerConfigSubCommand.java      | 146 ++++
 .../message/QueryMsgByUniqueKeySubCommand.java     |   5 +-
 .../tools/command/message/SendMessageCommand.java  |  17 +-
 ...SubCommand.java => AddWritePermSubCommand.java} |  29 +-
 .../command/namesrv/WipeWritePermSubCommand.java   |   2 +-
 .../tools/admin/DefaultMQAdminExtTest.java         |   7 +
 .../GetConsumerConfigSubCommandTest.java}          |  11 +-
 .../AddWritePermSubCommandTest.java}               |  19 +-
 142 files changed, 3531 insertions(+), 1659 deletions(-)
 create mode 100644 .github/workflows/greetings.yml
 create mode 100644 broker/src/test/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessorTest.java
 copy common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/{WipeWritePermOfBrokerRequestHeader.java
=> AddWritePermOfBrokerRequestHeader.java} (94%)
 copy common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/{WipeWritePermOfBrokerRequestHeader.java
=> AddWritePermOfBrokerResponseHeader.java} (81%)
 copy distribution/benchmark/{consumer.sh => batchproducer.sh} (91%)
 create mode 100644 docs/cn/Configuration_System.md
 create mode 100644 docs/cn/Deployment.md
 copy docs/{en => cn}/Example_Batch.md (79%)
 copy docs/{en => cn}/Example_Delay.md (76%)
 copy docs/{en/Example_Simple.md => cn/Example_Simple_cn.md} (82%)
 create mode 100644 docs/cn/FAQ.md
 create mode 100644 docs/en/client/java/API_Reference_DefaultMQProducer.md
 create mode 100644 example/src/main/java/org/apache/rocketmq/example/benchmark/BatchProducer.java
 create mode 100644 remoting/src/test/java/org/apache/rocketmq/remoting/netty/NettyClientConfigTest.java
 create mode 100644 tools/src/main/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java
 copy tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/{WipeWritePermSubCommand.java
=> AddWritePermSubCommand.java} (77%)
 copy tools/src/test/java/org/apache/rocketmq/tools/command/{broker/UpdateBrokerConfigSubCommandTest.java
=> consumer/GetConsumerConfigSubCommandTest.java} (92%)
 copy tools/src/test/java/org/apache/rocketmq/tools/command/{acl/GetAccessConfigSubCommandTest.java
=> namesrv/AddWritePermSubCommandTest.java} (68%)

Mime
View raw message