关联漏洞
介绍
## Apache RocketMQ
[](https://travis-ci.org/apache/rocketmq) [](https://coveralls.io/github/apache/rocketmq?branch=master)
[](https://codecov.io/gh/apache/rocketmq)
[](http://search.maven.org/#search%7Cga%7C1%7Corg.apache.rocketmq)
[](https://rocketmq.apache.org/dowloading/releases)
[](https://www.apache.org/licenses/LICENSE-2.0.html)
[](http://isitmaintained.com/project/apache/rocketmq "Average time to resolve an issue")
[](http://isitmaintained.com/project/apache/rocketmq "Percentage of issues still open")
[](https://twitter.com/intent/follow?screen_name=ApacheRocketMQ)
**[Apache RocketMQ](https://rocketmq.apache.org) is a distributed messaging and streaming platform with low latency, high performance and reliability, trillion-level capacity and flexible scalability.**
It offers a variety of features:
* Messaging patterns including publish/subscribe, request/reply and streaming
* Financial grade transactional message
* Built-in fault tolerance and high availability configuration options base on [DLedger](https://github.com/openmessaging/openmessaging-storage-dledger)
* Built-in message tracing capability, also support opentracing
* Versatile big-data and streaming ecosystem integration
* Message retroactivity by time or offset
* Reliable FIFO and strict ordered messaging in the same queue
* Efficient pull and push consumption model
* Million-level message accumulation capacity in a single queue
* Multiple messaging protocols like gRPC, MQTT, JMS and OpenMessaging
* Flexible distributed scale-out deployment architecture
* Lightning-fast batch message exchange system
* Various message filter mechanics such as SQL and Tag
* Docker images for isolated testing and cloud isolated clusters
* Feature-rich administrative dashboard for configuration, metrics and monitoring
* Authentication and authorization
* Free open source connectors, for both sources and sinks
* Lightweight real-time computing
----------
## Quick Start
This paragraph guides you through steps of installing RocketMQ in different ways.
For local development and testing, only one instance will be created for each component.
### Run RocketMQ locally
RocketMQ runs on all major operating systems and requires only a Java JDK version 8 or higher to be installed.
To check, run `java -version`:
```shell
$ java -version
java version "1.8.0_121"
```
For Windows users, click [here](https://archive.apache.org/dist/rocketmq/4.9.3/rocketmq-all-4.9.3-bin-release.zip) to download the 4.9.3 RocketMQ binary release,
unpack it to your local disk, such as `D:\rocketmq`.
For macOS and Linux users, execute following commands:
```shell
# Download release from the Apache mirror
$ wget https://archive.apache.org/dist/rocketmq/4.9.3/rocketmq-all-4.9.3-bin-release.zip
# Unpack the release
$ unzip rocketmq-all-4.9.3-bin-release.zip
```
Prepare a terminal and change to the extracted `bin` directory:
```shell
$ cd rocketmq-4.9.3/bin
```
**1) Start NameServer**
NameServer will be listening at `0.0.0.0:9876`, make sure that the port is not used by others on the local machine, and then do as follows.
For macOS and Linux users:
```shell
### start Name Server
$ nohup sh mqnamesrv &
### check whether Name Server is successfully started
$ tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...
```
For Windows users, you need set environment variables first:
- From the desktop, right click the Computer icon.
- Choose Properties from the context menu.
- Click the Advanced system settings link.
- Click Environment Variables.
- Add Environment `ROCKETMQ_HOME="D:\rocketmq"`.
Then change directory to rocketmq, type and run:
```shell
$ mqnamesrv.cmd
The Name Server boot success...
```
**2) Start Broker**
For macOS and Linux users:
```shell
### start Broker
$ nohup sh bin/mqbroker -n localhost:9876 &
### check whether Broker is successfully started, eg: Broker's IP is 192.168.1.2, Broker's name is broker-a
$ tail -f ~/logs/rocketmqlogs/broker.log
The broker[broker-a, 192.169.1.2:10911] boot success...
```
For Windows users:
```shell
$ mqbroker.cmd -n localhost:9876
The broker[broker-a, 192.169.1.2:10911] boot success...
```
### Run RocketMQ in Docker
You can run RocketMQ on your own machine within Docker containers,
`host` network will be used to expose listening port in the container.
**1) Start NameServer**
```shell
$ docker run -it --net=host apache/rocketmq ./mqnamesrv
```
**2) Start Broker**
```shell
$ docker run -it --net=host --mount source=/tmp/store,target=/home/rocketmq/store apache/rocketmq ./mqbroker -n localhost:9876
```
### Run RocketMQ in Kubernetes
You can also run a RocketMQ cluster within a Kubernetes cluster using [RocketMQ Operator](https://github.com/apache/rocketmq-operator).
Before your operations, make sure that `kubectl` and related kubeconfig file installed on your machine.
**1) Install CRDs**
```shell
### install CRDs
$ git clone https://github.com/apache/rocketmq-operator
$ cd rocketmq-operator && make deploy
### check whether CRDs is successfully installed
$ kubectl get crd | grep rocketmq.apache.org
brokers.rocketmq.apache.org 2022-05-12T09:23:18Z
consoles.rocketmq.apache.org 2022-05-12T09:23:19Z
nameservices.rocketmq.apache.org 2022-05-12T09:23:18Z
topictransfers.rocketmq.apache.org 2022-05-12T09:23:19Z
### check whether operator is running
$ kubectl get pods | grep rocketmq-operator
rocketmq-operator-6f65c77c49-8hwmj 1/1 Running 0 93s
```
**2) Create Cluster Instance**
```shell
### create RocketMQ cluster resource
$ cd example && kubectl create -f rocketmq_v1alpha1_rocketmq_cluster.yaml
### check whether cluster resources is running
$ kubectl get sts
NAME READY AGE
broker-0-master 1/1 107m
broker-0-replica-1 1/1 107m
name-service 1/1 107m
```
---
## Apache RocketMQ Community
* [RocketMQ Streams](https://github.com/apache/rocketmq-streams): A lightweight stream computing engine based on Apache RocketMQ.
* [RocketMQ Flink](https://github.com/apache/rocketmq-flink): The Apache RocketMQ connector of Apache Flink that supports source and sink connector in data stream and Table.
* RocketMQ Muli-Language Clients
- [RocketMQ Client CPP](https://github.com/apache/rocketmq-client-cpp)
- [RocketMQ Client Go](https://github.com/apache/rocketmq-client-go)
- [RocketMQ Client Python](https://github.com/apache/rocketmq-client-python)
- [RocketMQ Client Nodejs](https://github.com/apache/rocketmq-client-nodejs)
* [RocketMQ Spring](https://github.com/apache/rocketmq-spring): A project which helps developers quickly integrate Apache RocketMQ with Spring Boot.
* [RocketMQ Exporter](https://github.com/apache/rocketmq-exporter): An Apache RocketMQ exporter for Prometheus.
* [RocketMQ Operator](https://github.com/apache/rocketmq-operator): Providing a way to run an Apache RocketMQ cluster on Kubernetes.
* [RocketMQ Docker](https://github.com/apache/rocketmq-docker): The Git repo of the Docker Image for Apache RocketMQ.
* [RocketMQ Dashboard](https://github.com/apache/rocketmq-dashboard): Operation and maintenance console of Apache RocketMQ.
* [RocketMQ Connect](https://github.com/apache/rocketmq-connect): A tool for scalably and reliably streaming data between Apache RocketMQ and other systems.
* [RocketMQ MQTT](https://github.com/apache/rocketmq-mqtt): A new MQTT protocol architecture model, based on which Apache RocketMQ can better support messages from terminals such as IoT devices and Mobile APP.
* [RocketMQ Incubating Community Projects](https://github.com/apache/rocketmq-externals): Icubator community projects of Apache RocketMQ, including [logappender](https://github.com/apache/rocketmq-externals/tree/master/logappender), [rocketmq-ansible](https://github.com/apache/rocketmq-externals/tree/master/rocketmq-ansible), [rocketmq-beats-integration](https://github.com/apache/rocketmq-externals/tree/master/rocketmq-beats-integration), [rocketmq-cloudevents-binding](https://github.com/apache/rocketmq-externals/tree/master/rocketmq-cloudevents-binding), etc.
* [RocketMQ Site](https://github.com/apache/rocketmq-site): The repository for Apache RocketMQ website.
----------
## Learn it & Contact us
* Mailing Lists: <https://rocketmq.apache.org/about/contact/>
* Home: <https://rocketmq.apache.org>
* Docs: <https://rocketmq.apache.org/docs/quick-start/>
* Issues: <https://github.com/apache/rocketmq/issues>
* Rips: <https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal>
* Ask: <https://stackoverflow.com/questions/tagged/rocketmq>
* Slack: <https://rocketmq-invite-automation.herokuapp.com/>
----------
## Contributing
We always welcome new contributions, whether for trivial cleanups, [big new features](https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal) or other material rewards, more details see [here](http://rocketmq.apache.org/docs/how-to-contribute/).
----------
## License
[Apache License, Version 2.0](http://www.apache.org/licenses/LICENSE-2.0.html) Copyright (C) Apache Software Foundation
----------
## Export Control Notice
This distribution includes cryptographic software. The country in which you currently reside may have
restrictions on the import, possession, use, and/or re-export to another country, of encryption software.
BEFORE using any encryption software, please check your country's laws, regulations and policies concerning
the import, possession, or use, and re-export of encryption software, to see if this is permitted. See
<http://www.wassenaar.org/> for more information.
The U.S. Government Department of Commerce, Bureau of Industry and Security (BIS), has classified this
software as Export Commodity Control Number (ECCN) 5D002.C.1, which includes information security software
using or performing cryptographic functions with asymmetric algorithms. The form and manner of this Apache
Software Foundation distribution makes it eligible for export under the License Exception ENC Technology
Software Unrestricted (TSU) exception (see the BIS Export Administration Regulations, Section 740.13) for
both object code and source code.
The following provides more details on the included cryptographic software:
This software uses Apache Commons Crypto (https://commons.apache.org/proper/commons-crypto/) to
support authentication, and encryption and decryption of data sent across the network between
services.
文件快照
[4.0K] /data/pocs/01a465b3900389daa02f1ace7fd94d9d9c01255c
├── [4.0K] acl
│ ├── [2.7K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] acl
│ │ ├── [ 873] AccessResource.java
│ │ ├── [2.5K] AccessValidator.java
│ │ ├── [4.0K] common
│ │ │ ├── [2.7K] AclClientRPCHook.java
│ │ │ ├── [2.1K] AclConstants.java
│ │ │ ├── [1.9K] AclException.java
│ │ │ ├── [4.2K] AclSigner.java
│ │ │ ├── [ 11K] AclUtils.java
│ │ │ ├── [4.4K] Permission.java
│ │ │ ├── [4.9K] SessionCredentials.java
│ │ │ └── [ 920] SigningAlgorithm.java
│ │ └── [4.0K] plain
│ │ ├── [5.1K] PlainAccessResource.java
│ │ ├── [9.0K] PlainAccessValidator.java
│ │ ├── [ 34K] PlainPermissionManager.java
│ │ ├── [ 11K] RemoteAddressStrategyFactory.java
│ │ └── [ 946] RemoteAddressStrategy.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] acl
│ │ ├── [4.0K] common
│ │ │ ├── [5.4K] AclClientRPCHookTest.java
│ │ │ ├── [1.2K] AclSignerTest.java
│ │ │ ├── [ 12K] AclUtilsTest.java
│ │ │ ├── [7.0K] PermissionTest.java
│ │ │ └── [4.0K] SessionCredentialsTest.java
│ │ └── [4.0K] plain
│ │ ├── [ 20K] PlainAccessControlFlowTest.java
│ │ ├── [ 54K] PlainAccessValidatorTest.java
│ │ ├── [ 14K] PlainPermissionManagerTest.java
│ │ └── [ 20K] RemoteAddressStrategyTest.java
│ └── [4.0K] resources
│ ├── [4.0K] both_acl_file_folder_conf
│ │ └── [4.0K] conf
│ │ ├── [4.0K] acl
│ │ │ └── [1.3K] plain_acl.yml
│ │ └── [ 869] plain_acl.yml
│ ├── [4.0K] conf
│ │ ├── [4.0K] acl
│ │ │ └── [1.4K] plain_acl.yml
│ │ ├── [1.2K] plain_acl_correct.yml
│ │ ├── [1.2K] plain_acl_delete.yml
│ │ ├── [1.2K] plain_acl_global_white_addrs.yml
│ │ ├── [ 942] plain_acl_incomplete.yml
│ │ ├── [1.2K] plain_acl_update_create.yml
│ │ ├── [ 863] plain_acl_with_no_accouts.yml
│ │ ├── [1.3K] plain_acl.yml
│ │ └── [4.0K] watch
│ │ └── [1009] plain_acl_watch.yml
│ ├── [4.0K] empty_acl_folder_conf
│ │ └── [4.0K] conf
│ │ └── [ 848] plain_acl.yml
│ ├── [1.3K] logback-test.xml
│ ├── [4.0K] only_acl_folder_conf
│ │ └── [4.0K] conf
│ │ └── [4.0K] acl
│ │ └── [1.3K] plain_acl.yml
│ └── [4.0K] update_global_white_addr
│ └── [4.0K] conf
│ ├── [4.0K] acl
│ │ ├── [ 821] empty.yml
│ │ └── [1.2K] plain_acl.yml
│ └── [1.1K] plain_acl.yml
├── [4.0K] broker
│ ├── [3.4K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ ├── [4.0K] java
│ │ │ └── [4.0K] org
│ │ │ └── [4.0K] apache
│ │ │ └── [4.0K] rocketmq
│ │ │ └── [4.0K] broker
│ │ │ ├── [ 55K] BrokerController.java
│ │ │ ├── [2.1K] BrokerPathConfigHelper.java
│ │ │ ├── [ 12K] BrokerStartup.java
│ │ │ ├── [4.0K] client
│ │ │ │ ├── [3.2K] ClientChannelInfo.java
│ │ │ │ ├── [3.5K] ClientHousekeepingService.java
│ │ │ │ ├── [1.1K] ConsumerGroupEvent.java
│ │ │ │ ├── [8.9K] ConsumerGroupInfo.java
│ │ │ │ ├── [ 967] ConsumerIdsChangeListener.java
│ │ │ │ ├── [8.5K] ConsumerManager.java
│ │ │ │ ├── [2.6K] DefaultConsumerIdsChangeListener.java
│ │ │ │ ├── [4.0K] net
│ │ │ │ │ └── [ 14K] Broker2Client.java
│ │ │ │ ├── [9.2K] ProducerManager.java
│ │ │ │ └── [4.0K] rebalance
│ │ │ │ └── [ 11K] RebalanceLockManager.java
│ │ │ ├── [4.0K] dledger
│ │ │ │ └── [5.2K] DLedgerRoleChangeHandler.java
│ │ │ ├── [4.0K] filter
│ │ │ │ ├── [4.5K] CommitLogDispatcherCalcBitMap.java
│ │ │ │ ├── [4.0K] ConsumerFilterData.java
│ │ │ │ ├── [ 19K] ConsumerFilterManager.java
│ │ │ │ ├── [3.7K] ExpressionForRetryMessageFilter.java
│ │ │ │ ├── [6.1K] ExpressionMessageFilter.java
│ │ │ │ └── [1.8K] MessageEvaluationContext.java
│ │ │ ├── [4.0K] latency
│ │ │ │ ├── [5.7K] BrokerFastFailure.java
│ │ │ │ ├── [2.6K] BrokerFixedThreadPoolExecutor.java
│ │ │ │ └── [1.3K] FutureTaskExt.java
│ │ │ ├── [4.0K] longpolling
│ │ │ │ ├── [2.6K] LmqPullRequestHoldService.java
│ │ │ │ ├── [1.6K] ManyPullRequest.java
│ │ │ │ ├── [1.5K] NotifyMessageArrivingListener.java
│ │ │ │ ├── [7.3K] PullRequestHoldService.java
│ │ │ │ └── [2.5K] PullRequest.java
│ │ │ ├── [4.0K] mqtrace
│ │ │ │ ├── [4.1K] ConsumeMessageContext.java
│ │ │ │ ├── [1.0K] ConsumeMessageHook.java
│ │ │ │ ├── [5.9K] SendMessageContext.java
│ │ │ │ └── [1.0K] SendMessageHook.java
│ │ │ ├── [4.0K] offset
│ │ │ │ ├── [10.0K] ConsumerOffsetManager.java
│ │ │ │ └── [3.8K] LmqConsumerOffsetManager.java
│ │ │ ├── [4.0K] out
│ │ │ │ └── [ 18K] BrokerOuterAPI.java
│ │ │ ├── [4.0K] pagecache
│ │ │ │ ├── [3.3K] ManyMessageTransfer.java
│ │ │ │ ├── [3.0K] OneMessageTransfer.java
│ │ │ │ └── [3.3K] QueryMessageTransfer.java
│ │ │ ├── [4.0K] plugin
│ │ │ │ ├── [7.7K] AbstractPluginMessageStore.java
│ │ │ │ ├── [2.1K] MessageStoreFactory.java
│ │ │ │ └── [2.2K] MessageStorePluginContext.java
│ │ │ ├── [4.0K] processor
│ │ │ │ ├── [ 15K] AbstractSendMessageProcessor.java
│ │ │ │ ├── [ 83K] AdminBrokerProcessor.java
│ │ │ │ ├── [9.2K] ClientManageProcessor.java
│ │ │ │ ├── [7.4K] ConsumerManageProcessor.java
│ │ │ │ ├── [ 13K] EndTransactionProcessor.java
│ │ │ │ ├── [1.8K] ForwardRequestProcessor.java
│ │ │ │ ├── [ 31K] PullMessageProcessor.java
│ │ │ │ ├── [7.3K] QueryMessageProcessor.java
│ │ │ │ ├── [ 17K] ReplyMessageProcessor.java
│ │ │ │ └── [ 38K] SendMessageProcessor.java
│ │ │ ├── [4.0K] slave
│ │ │ │ └── [6.6K] SlaveSynchronize.java
│ │ │ ├── [4.0K] subscription
│ │ │ │ ├── [1.8K] LmqSubscriptionGroupManager.java
│ │ │ │ └── [8.1K] SubscriptionGroupManager.java
│ │ │ ├── [4.0K] topic
│ │ │ │ ├── [1.8K] LmqTopicConfigManager.java
│ │ │ │ └── [ 20K] TopicConfigManager.java
│ │ │ ├── [4.0K] transaction
│ │ │ │ ├── [4.9K] AbstractTransactionalMessageCheckListener.java
│ │ │ │ ├── [4.0K] jdbc
│ │ │ │ │ ├── [1.8K] JDBCTransactionStoreConfig.java
│ │ │ │ │ └── [7.6K] JDBCTransactionStore.java
│ │ │ │ ├── [1.6K] OperationResult.java
│ │ │ │ ├── [4.0K] queue
│ │ │ │ │ ├── [4.3K] DefaultTransactionalMessageCheckListener.java
│ │ │ │ │ ├── [1.3K] GetResult.java
│ │ │ │ │ ├── [ 16K] TransactionalMessageBridge.java
│ │ │ │ │ ├── [ 22K] TransactionalMessageServiceImpl.java
│ │ │ │ │ └── [1.5K] TransactionalMessageUtil.java
│ │ │ │ ├── [2.5K] TransactionalMessageCheckService.java
│ │ │ │ ├── [3.5K] TransactionalMessageService.java
│ │ │ │ ├── [1.4K] TransactionRecord.java
│ │ │ │ └── [1.3K] TransactionStore.java
│ │ │ └── [4.0K] util
│ │ │ ├── [1.3K] PositiveAtomicCounter.java
│ │ │ └── [8.4K] ServiceProvider.java
│ │ └── [4.0K] resources
│ │ ├── [4.0K] META-INF
│ │ │ └── [4.0K] service
│ │ │ └── [ 50] org.apache.rocketmq.acl.AccessValidator
│ │ └── [ 902] transaction.sql
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] broker
│ │ ├── [3.0K] BrokerControllerTest.java
│ │ ├── [8.9K] BrokerOuterAPITest.java
│ │ ├── [1.8K] BrokerPathConfigHelperTest.java
│ │ ├── [1.6K] BrokerStartupTest.java
│ │ ├── [4.0K] client
│ │ │ └── [5.3K] ProducerManagerTest.java
│ │ ├── [4.0K] filter
│ │ │ ├── [6.6K] CommitLogDispatcherCalcBitMapTest.java
│ │ │ ├── [8.9K] ConsumerFilterManagerTest.java
│ │ │ └── [ 15K] MessageStoreWithFilterTest.java
│ │ ├── [4.0K] latency
│ │ │ └── [2.4K] BrokerFastFailureTest.java
│ │ ├── [4.0K] offset
│ │ │ └── [4.7K] LmqConsumerOffsetManagerTest.java
│ │ ├── [4.0K] pagecache
│ │ │ ├── [2.5K] ManyMessageTransferTest.java
│ │ │ └── [2.3K] OneMessageTransferTest.java
│ │ ├── [4.0K] processor
│ │ │ ├── [ 29K] AdminBrokerProcessorTest.java
│ │ │ ├── [6.0K] ClientManageProcessorTest.java
│ │ │ ├── [7.2K] EndTransactionProcessorTest.java
│ │ │ ├── [ 12K] PullMessageProcessorTest.java
│ │ │ ├── [6.7K] ReplyMessageProcessorTest.java
│ │ │ └── [ 14K] SendMessageProcessorTest.java
│ │ ├── [4.0K] transaction
│ │ │ └── [4.0K] queue
│ │ │ ├── [4.6K] DefaultTransactionalMessageCheckListenerTest.java
│ │ │ ├── [9.5K] TransactionalMessageBridgeTest.java
│ │ │ └── [ 11K] TransactionalMessageServiceImplTest.java
│ │ └── [4.0K] util
│ │ ├── [1.1K] LogTransactionalMessageCheckListener.java
│ │ ├── [2.0K] ServiceProviderTest.java
│ │ └── [2.6K] TransactionalMessageServiceImpl.java
│ └── [4.0K] resources
│ ├── [1.2K] logback-test.xml
│ └── [4.0K] META-INF
│ └── [4.0K] service
│ ├── [ 50] org.apache.rocketmq.acl.AccessValidator
│ ├── [ 68] org.apache.rocketmq.broker.transaction.AbstractTransactionalMessageCheckListener
│ └── [ 63] org.apache.rocketmq.broker.transaction.TransactionalMessageService
├── [ 997] BUILDING
├── [4.0K] client
│ ├── [2.3K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] client
│ │ ├── [1.2K] AccessChannel.java
│ │ ├── [4.0K] admin
│ │ │ └── [ 883] MQAdminExtInner.java
│ │ ├── [ 12K] ClientConfig.java
│ │ ├── [4.0K] common
│ │ │ ├── [1.3K] ClientErrorCode.java
│ │ │ └── [1.5K] ThreadLocalIndex.java
│ │ ├── [4.0K] consumer
│ │ │ ├── [1.6K] AllocateMessageQueueStrategy.java
│ │ │ ├── [ 20K] DefaultLitePullConsumer.java
│ │ │ ├── [ 17K] DefaultMQPullConsumer.java
│ │ │ ├── [ 33K] DefaultMQPushConsumer.java
│ │ │ ├── [4.0K] listener
│ │ │ │ ├── [1.9K] ConsumeConcurrentlyContext.java
│ │ │ │ ├── [1.0K] ConsumeConcurrentlyStatus.java
│ │ │ │ ├── [1.7K] ConsumeOrderlyContext.java
│ │ │ │ ├── [1.2K] ConsumeOrderlyStatus.java
│ │ │ │ ├── [1.2K] ConsumeReturnType.java
│ │ │ │ ├── [1.5K] MessageListenerConcurrently.java
│ │ │ │ ├── [ 984] MessageListener.java
│ │ │ │ └── [1.5K] MessageListenerOrderly.java
│ │ │ ├── [8.6K] LitePullConsumer.java
│ │ │ ├── [1.4K] MessageQueueListener.java
│ │ │ ├── [2.1K] MessageSelector.java
│ │ │ ├── [2.1K] MQConsumer.java
│ │ │ ├── [6.7K] MQPullConsumer.java
│ │ │ ├── [8.4K] MQPullConsumerScheduleService.java
│ │ │ ├── [3.6K] MQPushConsumer.java
│ │ │ ├── [1016] PullCallback.java
│ │ │ ├── [2.2K] PullResult.java
│ │ │ ├── [1.1K] PullStatus.java
│ │ │ ├── [1018] PullTaskCallback.java
│ │ │ ├── [1.4K] PullTaskContext.java
│ │ │ ├── [4.0K] rebalance
│ │ │ │ ├── [2.1K] AbstractAllocateMessageQueueStrategy.java
│ │ │ │ ├── [5.8K] AllocateMachineRoomNearby.java
│ │ │ │ ├── [1.7K] AllocateMessageQueueAveragelyByCircle.java
│ │ │ │ ├── [2.0K] AllocateMessageQueueAveragely.java
│ │ │ │ ├── [1.5K] AllocateMessageQueueByConfig.java
│ │ │ │ ├── [2.6K] AllocateMessageQueueByMachineRoom.java
│ │ │ │ └── [3.4K] AllocateMessageQueueConsistentHash.java
│ │ │ ├── [4.0K] store
│ │ │ │ ├── [8.8K] LocalFileOffsetStore.java
│ │ │ │ ├── [1.6K] OffsetSerializeWrapper.java
│ │ │ │ ├── [2.3K] OffsetStore.java
│ │ │ │ ├── [1.1K] ReadOffsetType.java
│ │ │ │ └── [ 10K] RemoteBrokerOffsetStore.java
│ │ │ └── [1.2K] TopicMessageQueueChangeListener.java
│ │ ├── [4.0K] exception
│ │ │ ├── [2.1K] MQBrokerException.java
│ │ │ ├── [2.0K] MQClientException.java
│ │ │ └── [1.9K] RequestTimeoutException.java
│ │ ├── [4.0K] hook
│ │ │ ├── [3.4K] CheckForbiddenContext.java
│ │ │ ├── [1.0K] CheckForbiddenHook.java
│ │ │ ├── [2.8K] ConsumeMessageContext.java
│ │ │ ├── [1.0K] ConsumeMessageHook.java
│ │ │ ├── [2.5K] EndTransactionContext.java
│ │ │ ├── [ 970] EndTransactionHook.java
│ │ │ ├── [2.1K] FilterMessageContext.java
│ │ │ ├── [ 967] FilterMessageHook.java
│ │ │ ├── [3.9K] SendMessageContext.java
│ │ │ └── [1.0K] SendMessageHook.java
│ │ ├── [4.0K] impl
│ │ │ ├── [ 15K] ClientRemotingProcessor.java
│ │ │ ├── [ 911] CommunicationMode.java
│ │ │ ├── [4.0K] consumer
│ │ │ │ ├── [9.0K] AssignedMessageQueue.java
│ │ │ │ ├── [ 19K] ConsumeMessageConcurrentlyService.java
│ │ │ │ ├── [ 27K] ConsumeMessageOrderlyService.java
│ │ │ │ ├── [1.6K] ConsumeMessageService.java
│ │ │ │ ├── [ 54K] DefaultLitePullConsumerImpl.java
│ │ │ │ ├── [ 34K] DefaultMQPullConsumerImpl.java
│ │ │ │ ├── [ 53K] DefaultMQPushConsumerImpl.java
│ │ │ │ ├── [1.6K] MessageQueueLock.java
│ │ │ │ ├── [1.8K] MQConsumerInner.java
│ │ │ │ ├── [ 16K] ProcessQueue.java
│ │ │ │ ├── [ 11K] PullAPIWrapper.java
│ │ │ │ ├── [4.5K] PullMessageService.java
│ │ │ │ ├── [3.2K] PullRequest.java
│ │ │ │ ├── [1.8K] PullResultExt.java
│ │ │ │ ├── [ 21K] RebalanceImpl.java
│ │ │ │ ├── [6.8K] RebalanceLitePullImpl.java
│ │ │ │ ├── [3.4K] RebalancePullImpl.java
│ │ │ │ ├── [ 11K] RebalancePushImpl.java
│ │ │ │ └── [1.9K] RebalanceService.java
│ │ │ ├── [4.0K] factory
│ │ │ │ └── [ 51K] MQClientInstance.java
│ │ │ ├── [1.5K] FindBrokerResult.java
│ │ │ ├── [ 21K] MQAdminImpl.java
│ │ │ ├── [110K] MQClientAPIImpl.java
│ │ │ ├── [2.8K] MQClientManager.java
│ │ │ └── [4.0K] producer
│ │ │ ├── [ 74K] DefaultMQProducerImpl.java
│ │ │ ├── [1.6K] MQProducerInner.java
│ │ │ └── [4.1K] TopicPublishInfo.java
│ │ ├── [4.0K] latency
│ │ │ ├── [6.2K] LatencyFaultToleranceImpl.java
│ │ │ ├── [1.1K] LatencyFaultTolerance.java
│ │ │ └── [4.3K] MQFaultStrategy.java
│ │ ├── [4.0K] log
│ │ │ └── [5.4K] ClientLogger.java
│ │ ├── [3.6K] MQAdmin.java
│ │ ├── [3.2K] MQHelper.java
│ │ ├── [4.0K] producer
│ │ │ ├── [ 47K] DefaultMQProducer.java
│ │ │ ├── [1.2K] LocalTransactionExecuter.java
│ │ │ ├── [ 940] LocalTransactionState.java
│ │ │ ├── [1.1K] MessageQueueSelector.java
│ │ │ ├── [7.0K] MQProducer.java
│ │ │ ├── [1023] RequestCallback.java
│ │ │ ├── [4.4K] RequestFutureHolder.java
│ │ │ ├── [3.6K] RequestResponseFuture.java
│ │ │ ├── [4.0K] selector
│ │ │ │ ├── [1.3K] SelectMessageQueueByHash.java
│ │ │ │ ├── [1.5K] SelectMessageQueueByMachineRoom.java
│ │ │ │ └── [1.4K] SelectMessageQueueByRandom.java
│ │ │ ├── [ 973] SendCallback.java
│ │ │ ├── [3.8K] SendResult.java
│ │ │ ├── [ 962] SendStatus.java
│ │ │ ├── [1.1K] TransactionCheckListener.java
│ │ │ ├── [1.6K] TransactionListener.java
│ │ │ ├── [5.6K] TransactionMQProducer.java
│ │ │ └── [1.2K] TransactionSendResult.java
│ │ ├── [1.6K] QueryResult.java
│ │ ├── [4.0K] stat
│ │ │ └── [5.8K] ConsumerStatsManager.java
│ │ ├── [4.0K] trace
│ │ │ ├── [ 18K] AsyncTraceDispatcher.java
│ │ │ ├── [4.0K] hook
│ │ │ │ ├── [3.8K] ConsumeMessageOpenTracingHookImpl.java
│ │ │ │ ├── [5.2K] ConsumeMessageTraceHookImpl.java
│ │ │ │ ├── [3.0K] EndTransactionOpenTracingHookImpl.java
│ │ │ │ ├── [3.7K] EndTransactionTraceHookImpl.java
│ │ │ │ ├── [3.6K] SendMessageOpenTracingHookImpl.java
│ │ │ │ └── [4.3K] SendMessageTraceHookImpl.java
│ │ │ ├── [3.9K] TraceBean.java
│ │ │ ├── [2.4K] TraceConstants.java
│ │ │ ├── [3.9K] TraceContext.java
│ │ │ ├── [ 12K] TraceDataEncoder.java
│ │ │ ├── [1.6K] TraceDispatcher.java
│ │ │ ├── [ 908] TraceDispatcherType.java
│ │ │ ├── [1.3K] TraceTransferBean.java
│ │ │ ├── [ 929] TraceType.java
│ │ │ └── [5.0K] TraceView.java
│ │ ├── [4.0K] utils
│ │ │ └── [3.0K] MessageUtil.java
│ │ └── [4.2K] Validators.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] client
│ │ ├── [4.0K] common
│ │ │ └── [2.0K] ThreadLocalIndexTest.java
│ │ ├── [4.0K] consumer
│ │ │ ├── [ 38K] DefaultLitePullConsumerTest.java
│ │ │ ├── [7.4K] DefaultMQPullConsumerTest.java
│ │ │ ├── [ 16K] DefaultMQPushConsumerTest.java
│ │ │ ├── [4.0K] rebalance
│ │ │ │ ├── [9.6K] AllocateMachineRoomNearByTest.java
│ │ │ │ ├── [3.1K] AllocateMessageQueueAveragelyByCircleTest.java
│ │ │ │ ├── [2.2K] AllocateMessageQueueAveragelyTest.java
│ │ │ │ ├── [2.8K] AllocateMessageQueueByConfigTest.java
│ │ │ │ ├── [3.4K] AllocateMessageQueueByMachineRoomTest.java
│ │ │ │ └── [ 10K] AllocateMessageQueueConsitentHashTest.java
│ │ │ └── [4.0K] store
│ │ │ ├── [3.8K] LocalFileOffsetStoreTest.java
│ │ │ └── [6.7K] RemoteBrokerOffsetStoreTest.java
│ │ ├── [4.0K] impl
│ │ │ ├── [4.0K] consumer
│ │ │ │ ├── [ 13K] ConsumeMessageConcurrentlyServiceTest.java
│ │ │ │ ├── [ 13K] ConsumeMessageOrderlyServiceTest.java
│ │ │ │ ├── [2.4K] DefaultMQPushConsumerImplTest.java
│ │ │ │ ├── [3.6K] ProcessQueueTest.java
│ │ │ │ ├── [4.9K] RebalanceLitePullImplTest.java
│ │ │ │ └── [ 13K] RebalancePushImplTest.java
│ │ │ ├── [4.0K] factory
│ │ │ │ └── [8.2K] MQClientInstanceTest.java
│ │ │ └── [ 23K] MQClientAPIImplTest.java
│ │ ├── [4.0K] latency
│ │ │ └── [2.6K] LatencyFaultToleranceImplTest.java
│ │ ├── [4.0K] producer
│ │ │ ├── [ 23K] DefaultMQProducerTest.java
│ │ │ ├── [1.7K] RequestResponseFutureTest.java
│ │ │ └── [4.0K] selector
│ │ │ ├── [2.2K] SelectMessageQueueByHashTest.java
│ │ │ └── [2.4K] SelectMessageQueueRetryTest.java
│ │ ├── [4.0K] trace
│ │ │ ├── [ 11K] DefaultMQConsumerWithOpenTracingTest.java
│ │ │ ├── [ 16K] DefaultMQConsumerWithTraceTest.java
│ │ │ ├── [ 15K] DefaultMQLitePullConsumerWithTraceTest.java
│ │ │ ├── [7.9K] DefaultMQProducerWithOpenTracingTest.java
│ │ │ ├── [9.8K] DefaultMQProducerWithTraceTest.java
│ │ │ ├── [ 12K] TraceDataEncoderTest.java
│ │ │ ├── [2.8K] TraceViewTest.java
│ │ │ ├── [9.1K] TransactionMQProducerWithOpenTracingTest.java
│ │ │ └── [9.8K] TransactionMQProducerWithTraceTest.java
│ │ ├── [4.0K] utils
│ │ │ └── [3.4K] MessageUtilsTest.java
│ │ └── [4.2K] ValidatorsTest.java
│ └── [4.0K] resources
│ └── [1.2K] log4j2.xml
├── [4.0K] common
│ ├── [2.0K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] common
│ │ ├── [1.4K] AclConfig.java
│ │ ├── [4.0K] admin
│ │ │ ├── [2.0K] ConsumeStats.java
│ │ │ ├── [1.5K] OffsetWrapper.java
│ │ │ ├── [2.1K] RollbackStats.java
│ │ │ ├── [1.5K] TopicOffset.java
│ │ │ └── [1.4K] TopicStatsTable.java
│ │ ├── [4.0K] annotation
│ │ │ └── [1.2K] ImportantField.java
│ │ ├── [ 26K] BrokerConfig.java
│ │ ├── [1.5K] BrokerConfigSingleton.java
│ │ ├── [4.0K] compression
│ │ │ ├── [2.9K] CompressionType.java
│ │ │ ├── [1.4K] CompressorFactory.java
│ │ │ ├── [1.4K] Compressor.java
│ │ │ ├── [3.3K] Lz4Compressor.java
│ │ │ ├── [3.6K] ZlibCompressor.java
│ │ │ └── [3.3K] ZstdCompressor.java
│ │ ├── [2.9K] ConfigManager.java
│ │ ├── [9.1K] Configuration.java
│ │ ├── [4.0K] consistenthash
│ │ │ ├── [4.6K] ConsistentHashRouter.java
│ │ │ ├── [ 952] HashFunction.java
│ │ │ ├── [1.0K] Node.java
│ │ │ └── [1.4K] VirtualNode.java
│ │ ├── [4.0K] constant
│ │ │ ├── [ 950] DBMsgConstants.java
│ │ │ ├── [2.4K] LoggerName.java
│ │ │ └── [1.8K] PermName.java
│ │ ├── [4.0K] consumer
│ │ │ └── [1.1K] ConsumeFromWhere.java
│ │ ├── [6.7K] CountDownLatch2.java
│ │ ├── [2.7K] DataVersion.java
│ │ ├── [4.0K] filter
│ │ │ ├── [2.3K] ExpressionType.java
│ │ │ ├── [3.2K] FilterAPI.java
│ │ │ ├── [1.1K] FilterContext.java
│ │ │ ├── [4.0K] impl
│ │ │ │ ├── [ 955] Operand.java
│ │ │ │ ├── [2.4K] Operator.java
│ │ │ │ ├── [1.1K] Op.java
│ │ │ │ ├── [6.8K] PolishExpr.java
│ │ │ │ └── [ 943] Type.java
│ │ │ └── [1007] MessageFilter.java
│ │ ├── [4.0K] help
│ │ │ └── [3.1K] FAQUrl.java
│ │ ├── [4.0K] hook
│ │ │ └── [1019] FilterCheckHook.java
│ │ ├── [4.0K] message
│ │ │ ├── [3.7K] MessageAccessor.java
│ │ │ ├── [2.9K] MessageBatch.java
│ │ │ ├── [1.4K] MessageClientExt.java
│ │ │ ├── [5.4K] MessageClientIDSetter.java
│ │ │ ├── [5.2K] MessageConst.java
│ │ │ ├── [ 21K] MessageDecoder.java
│ │ │ ├── [1.3K] MessageExtBatch.java
│ │ │ ├── [7.8K] MessageExt.java
│ │ │ ├── [1.4K] MessageId.java
│ │ │ ├── [5.9K] Message.java
│ │ │ ├── [3.8K] MessageQueueForC.java
│ │ │ ├── [3.3K] MessageQueue.java
│ │ │ └── [ 949] MessageType.java
│ │ ├── [ 18K] MixAll.java
│ │ ├── [ 14K] MQVersion.java
│ │ ├── [4.0K] namesrv
│ │ │ ├── [2.9K] NamesrvConfig.java
│ │ │ ├── [ 961] NamesrvUtil.java
│ │ │ ├── [1.5K] RegisterBrokerResult.java
│ │ │ └── [3.6K] TopAddressing.java
│ │ ├── [1.3K] Pair.java
│ │ ├── [2.5K] PlainAccessConfig.java
│ │ ├── [4.0K] protocol
│ │ │ ├── [4.0K] body
│ │ │ │ ├── [1.6K] BrokerStatsData.java
│ │ │ │ ├── [1.3K] BrokerStatsItem.java
│ │ │ │ ├── [1.6K] CheckClientRequestBody.java
│ │ │ │ ├── [2.3K] ClusterAclVersionInfo.java
│ │ │ │ ├── [2.4K] ClusterInfo.java
│ │ │ │ ├── [ 985] CMResult.java
│ │ │ │ ├── [1.7K] Connection.java
│ │ │ │ ├── [2.0K] ConsumeByWho.java
│ │ │ │ ├── [2.2K] ConsumeMessageDirectlyResult.java
│ │ │ │ ├── [2.5K] ConsumeQueueData.java
│ │ │ │ ├── [3.0K] ConsumerConnection.java
│ │ │ │ ├── [1.5K] ConsumerOffsetSerializeWrapper.java
│ │ │ │ ├── [ 11K] ConsumerRunningInfo.java
│ │ │ │ ├── [1.9K] ConsumeStatsList.java
│ │ │ │ ├── [2.1K] ConsumeStatus.java
│ │ │ │ ├── [1.8K] GetConsumerStatusBody.java
│ │ │ │ ├── [1.2K] GroupList.java
│ │ │ │ ├── [1.2K] KVTable.java
│ │ │ │ ├── [1.7K] LockBatchRequestBody.java
│ │ │ │ ├── [1.3K] LockBatchResponseBody.java
│ │ │ │ ├── [5.0K] ProcessQueueInfo.java
│ │ │ │ ├── [1.3K] ProducerConnection.java
│ │ │ │ ├── [2.5K] ProducerInfo.java
│ │ │ │ ├── [1.3K] ProducerTableInfo.java
│ │ │ │ ├── [2.2K] QueryConsumeQueueResponseBody.java
│ │ │ │ ├── [1.3K] QueryConsumeTimeSpanBody.java
│ │ │ │ ├── [1.3K] QueryCorrectionOffsetBody.java
│ │ │ │ ├── [2.4K] QueueTimeSpan.java
│ │ │ │ ├── [8.3K] RegisterBrokerBody.java
│ │ │ │ ├── [1.3K] ResetOffsetBodyForC.java
│ │ │ │ ├── [1.3K] ResetOffsetBody.java
│ │ │ │ ├── [1.9K] SubscriptionGroupWrapper.java
│ │ │ │ ├── [1.8K] TopicConfigSerializeWrapper.java
│ │ │ │ ├── [1.4K] TopicList.java
│ │ │ │ └── [1.7K] UnlockBatchRequestBody.java
│ │ │ ├── [4.0K] header
│ │ │ │ ├── [2.3K] CheckTransactionStateRequestHeader.java
│ │ │ │ ├── [2.7K] CheckTransactionStateResponseHeader.java
│ │ │ │ ├── [2.0K] CloneGroupOffsetRequestHeader.java
│ │ │ │ ├── [2.1K] ConsumeMessageDirectlyResultRequestHeader.java
│ │ │ │ ├── [2.9K] ConsumerSendMsgBackRequestHeader.java
│ │ │ │ ├── [2.9K] CreateAccessConfigRequestHeader.java
│ │ │ │ ├── [3.3K] CreateTopicRequestHeader.java
│ │ │ │ ├── [1.4K] DeleteAccessConfigRequestHeader.java
│ │ │ │ ├── [1.6K] DeleteSubscriptionGroupRequestHeader.java
│ │ │ │ ├── [1.4K] DeleteTopicRequestHeader.java
│ │ │ │ ├── [4.0K] EndTransactionRequestHeader.java
│ │ │ │ ├── [1.2K] EndTransactionResponseHeader.java
│ │ │ │ ├── [4.0K] filtersrv
│ │ │ │ │ ├── [1.4K] RegisterFilterServerRequestHeader.java
│ │ │ │ │ ├── [1.6K] RegisterFilterServerResponseHeader.java
│ │ │ │ │ └── [2.0K] RegisterMessageFilterClassRequestHeader.java
│ │ │ │ ├── [1.2K] GetAllProducerInfoRequestHeader.java
│ │ │ │ ├── [1.2K] GetAllTopicConfigResponseHeader.java
│ │ │ │ ├── [2.2K] GetBrokerAclConfigResponseHeader.java
│ │ │ │ ├── [1.6K] GetBrokerClusterAclConfigResponseBody.java
│ │ │ │ ├── [1.6K] GetBrokerClusterAclConfigResponseHeader.java
│ │ │ │ ├── [1.5K] GetBrokerConfigResponseHeader.java
│ │ │ │ ├── [1.5K] GetConsumerConnectionListRequestHeader.java
│ │ │ │ ├── [1.4K] GetConsumerListByGroupRequestHeader.java
│ │ │ │ ├── [1.2K] GetConsumerListByGroupResponseBody.java
│ │ │ │ ├── [1.1K] GetConsumerListByGroupResponseHeader.java
│ │ │ │ ├── [1.9K] GetConsumerRunningInfoRequestHeader.java
│ │ │ │ ├── [1.8K] GetConsumerStatusRequestHeader.java
│ │ │ │ ├── [1.4K] GetConsumeStatsInBrokerHeader.java
│ │ │ │ ├── [1.6K] GetConsumeStatsRequestHeader.java
│ │ │ │ ├── [1.6K] GetEarliestMsgStoretimeRequestHeader.java
│ │ │ │ ├── [1.5K] GetEarliestMsgStoretimeResponseHeader.java
│ │ │ │ ├── [1.6K] GetMaxOffsetRequestHeader.java
│ │ │ │ ├── [1.4K] GetMaxOffsetResponseHeader.java
│ │ │ │ ├── [1.6K] GetMinOffsetRequestHeader.java
│ │ │ │ ├── [1.4K] GetMinOffsetResponseHeader.java
│ │ │ │ ├── [1.5K] GetProducerConnectionListRequestHeader.java
│ │ │ │ ├── [1.4K] GetTopicsByClusterRequestHeader.java
│ │ │ │ ├── [1.4K] GetTopicStatsInfoRequestHeader.java
│ │ │ │ ├── [4.0K] namesrv
│ │ │ │ │ ├── [1.4K] AddWritePermOfBrokerRequestHeader.java
│ │ │ │ │ ├── [1.4K] AddWritePermOfBrokerResponseHeader.java
│ │ │ │ │ ├── [1.5K] DeleteKVConfigRequestHeader.java
│ │ │ │ │ ├── [1.6K] DeleteTopicFromNamesrvRequestHeader.java
│ │ │ │ │ ├── [1.5K] GetKVConfigRequestHeader.java
│ │ │ │ │ ├── [1.4K] GetKVConfigResponseHeader.java
│ │ │ │ │ ├── [1.4K] GetKVListByNamespaceRequestHeader.java
│ │ │ │ │ ├── [1.8K] GetRouteInfoRequestHeader.java
│ │ │ │ │ ├── [1.7K] PutKVConfigRequestHeader.java
│ │ │ │ │ ├── [2.0K] QueryDataVersionRequestHeader.java
│ │ │ │ │ ├── [1.6K] QueryDataVersionResponseHeader.java
│ │ │ │ │ ├── [2.7K] RegisterBrokerRequestHeader.java
│ │ │ │ │ ├── [1.6K] RegisterBrokerResponseHeader.java
│ │ │ │ │ ├── [1.7K] RegisterOrderTopicRequestHeader.java
│ │ │ │ │ ├── [2.1K] UnRegisterBrokerRequestHeader.java
│ │ │ │ │ ├── [1.4K] WipeWritePermOfBrokerRequestHeader.java
│ │ │ │ │ └── [1.4K] WipeWritePermOfBrokerResponseHeader.java
│ │ │ │ ├── [1.4K] NotifyConsumerIdsChangedRequestHeader.java
│ │ │ │ ├── [6.2K] PullMessageRequestHeader.java
│ │ │ │ ├── [3.3K] PullMessageResponseHeader.java
│ │ │ │ ├── [2.0K] QueryConsumeQueueRequestHeader.java
│ │ │ │ ├── [1.9K] QueryConsumerOffsetRequestHeader.java
│ │ │ │ ├── [1.5K] QueryConsumerOffsetResponseHeader.java
│ │ │ │ ├── [1.5K] QueryConsumeTimeSpanRequestHeader.java
│ │ │ │ ├── [1.9K] QueryCorrectionOffsetHeader.java
│ │ │ │ ├── [2.2K] QueryMessageRequestHeader.java
│ │ │ │ ├── [1.9K] QueryMessageResponseHeader.java
│ │ │ │ ├── [1.5K] QueryTopicConsumeByWhoRequestHeader.java
│ │ │ │ ├── [4.2K] ReplyMessageRequestHeader.java
│ │ │ │ ├── [1.9K] ResetOffsetRequestHeader.java
│ │ │ │ ├── [1.5K] ResumeCheckHalfMessageRequestHeader.java
│ │ │ │ ├── [1.8K] SearchOffsetRequestHeader.java
│ │ │ │ ├── [1.4K] SearchOffsetResponseHeader.java
│ │ │ │ ├── [4.1K] SendMessageRequestHeader.java
│ │ │ │ ├── [7.1K] SendMessageRequestHeaderV2.java
│ │ │ │ ├── [3.1K] SendMessageResponseHeader.java
│ │ │ │ ├── [1.9K] UnregisterClientRequestHeader.java
│ │ │ │ ├── [1.1K] UnregisterClientResponseHeader.java
│ │ │ │ ├── [2.1K] UpdateConsumerOffsetRequestHeader.java
│ │ │ │ ├── [1.2K] UpdateConsumerOffsetResponseHeader.java
│ │ │ │ ├── [1.7K] UpdateGlobalWhiteAddrsConfigRequestHeader.java
│ │ │ │ ├── [1.6K] ViewBrokerStatsDataRequestHeader.java
│ │ │ │ ├── [1.4K] ViewMessageRequestHeader.java
│ │ │ │ └── [1.2K] ViewMessageResponseHeader.java
│ │ │ ├── [4.0K] heartbeat
│ │ │ │ ├── [2.8K] ConsumerData.java
│ │ │ │ ├── [1.2K] ConsumeType.java
│ │ │ │ ├── [2.1K] HeartbeatData.java
│ │ │ │ ├── [1.3K] MessageModel.java
│ │ │ │ ├── [1.2K] ProducerData.java
│ │ │ │ └── [5.6K] SubscriptionData.java
│ │ │ ├── [2.1K] MQProtosHelper.java
│ │ │ ├── [6.7K] NamespaceUtil.java
│ │ │ ├── [6.6K] RequestCode.java
│ │ │ ├── [2.7K] ResponseCode.java
│ │ │ ├── [4.0K] route
│ │ │ │ ├── [3.6K] BrokerData.java
│ │ │ │ ├── [3.4K] QueueData.java
│ │ │ │ └── [4.7K] TopicRouteData.java
│ │ │ └── [4.0K] topic
│ │ │ └── [2.1K] OffsetMovedEvent.java
│ │ ├── [4.0K] queue
│ │ │ ├── [2.3K] ConcurrentTreeMap.java
│ │ │ └── [1.4K] RoundQueue.java
│ │ ├── [4.0K] rpc
│ │ │ └── [1.1K] RpcRequestHeader.java
│ │ ├── [4.0K] rpchook
│ │ │ └── [1.4K] StreamTypeRPCHook.java
│ │ ├── [4.0K] running
│ │ │ └── [1002] RunningStats.java
│ │ ├── [1.1K] ServiceState.java
│ │ ├── [4.8K] ServiceThread.java
│ │ ├── [4.0K] stats
│ │ │ ├── [2.5K] MomentStatsItem.java
│ │ │ ├── [4.1K] MomentStatsItemSet.java
│ │ │ ├── [1.7K] RTStatsItem.java
│ │ │ ├── [8.4K] StatsItem.java
│ │ │ ├── [9.1K] StatsItemSet.java
│ │ │ ├── [2.7K] Stats.java
│ │ │ └── [1.5K] StatsSnapshot.java
│ │ ├── [4.0K] subscription
│ │ │ └── [5.7K] SubscriptionGroupConfig.java
│ │ ├── [4.0K] sysflag
│ │ │ ├── [3.2K] MessageSysFlag.java
│ │ │ ├── [2.8K] PullSysFlag.java
│ │ │ ├── [1.5K] SubscriptionSysFlag.java
│ │ │ └── [1.9K] TopicSysFlag.java
│ │ ├── [ 941] SystemClock.java
│ │ ├── [1.6K] ThreadFactoryImpl.java
│ │ ├── [4.0K] topic
│ │ │ └── [6.2K] TopicValidator.java
│ │ ├── [5.3K] TopicConfig.java
│ │ ├── [ 902] TopicFilterType.java
│ │ ├── [ 21K] UtilAll.java
│ │ └── [4.0K] utils
│ │ ├── [1.3K] ChannelUtil.java
│ │ ├── [1005] CorrelationIdUtil.java
│ │ ├── [5.0K] HttpTinyClient.java
│ │ ├── [5.0K] IOTinyUtils.java
│ │ ├── [2.2K] NameServerAddressUtils.java
│ │ └── [6.6K] ThreadUtils.java
│ └── [4.0K] test
│ └── [4.0K] java
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] common
│ ├── [4.0K] admin
│ │ └── [3.4K] TopicStatsTableTest.java
│ ├── [2.2K] BrokerConfigTest.java
│ ├── [4.0K] compression
│ │ └── [4.4K] CompressionTest.java
│ ├── [3.7K] ConfigManagerTest.java
│ ├── [3.8K] CountDownLatch2Test.java
│ ├── [2.5K] DataVersionTest.java
│ ├── [4.0K] filter
│ │ └── [3.3K] FilterAPITest.java
│ ├── [4.0K] message
│ │ ├── [2.4K] MessageClientIDSetterTest.java
│ │ ├── [ 16K] MessageDecoderTest.java
│ │ └── [2.3K] MessageTest.java
│ ├── [2.6K] MessageBatchTest.java
│ ├── [2.9K] MessageEncodeDecodeTest.java
│ ├── [4.0K] MixAllTest.java
│ ├── [1.7K] MQVersionTest.java
│ ├── [4.0K] protocol
│ │ ├── [4.0K] body
│ │ │ ├── [3.3K] BrokerStatsDataTest.java
│ │ │ ├── [2.0K] CheckClientRequestBodyTest.java
│ │ │ ├── [2.1K] ConsumeMessageDirectlyResultTest.java
│ │ │ ├── [3.6K] ConsumerConnectionTest.java
│ │ │ ├── [4.2K] ConsumerRunningInfoTest.java
│ │ │ ├── [2.7K] ConsumeStatsListTest.java
│ │ │ ├── [1.7K] KVTableTest.java
│ │ │ ├── [2.8K] QueryConsumeQueueResponseBodyTest.java
│ │ │ ├── [1.8K] QueryCorrectionOffsetBodyTest.java
│ │ │ ├── [1.8K] ResetOffsetBodyTest.java
│ │ │ └── [2.5K] SubscriptionGroupWrapperTest.java
│ │ ├── [3.9K] ClusterInfoTest.java
│ │ ├── [1.7K] ConsumeStatusTest.java
│ │ ├── [1.9K] GroupListTest.java
│ │ ├── [4.0K] header
│ │ │ └── [3.6K] FastCodesHeaderTest.java
│ │ ├── [4.0K] heartbeat
│ │ │ └── [4.0K] SubscriptionDataTest.java
│ │ ├── [5.0K] NamespaceUtilTest.java
│ │ ├── [7.2K] QueryConsumeTimeSpanBodyTest.java
│ │ ├── [4.0K] route
│ │ │ └── [4.3K] TopicRouteDataTest.java
│ │ └── [4.0K] topic
│ │ └── [2.6K] OffsetMovedEventTest.java
│ ├── [2.3K] RegisterBrokerBodyTest.java
│ ├── [1.6K] RemotingUtilTest.java
│ ├── [4.6K] ServiceThreadTest.java
│ ├── [4.0K] stats
│ │ └── [5.9K] StatsItemSetTest.java
│ ├── [4.0K] sysflag
│ │ ├── [2.0K] CompressionFlagTest.java
│ │ └── [1.3K] PullSysFlagTest.java
│ ├── [4.0K] topic
│ │ └── [5.4K] TopicValidatorTest.java
│ ├── [6.1K] UtilAllTest.java
│ └── [4.0K] utils
│ ├── [5.1K] IOTinyUtilsTest.java
│ └── [2.6K] NameServerAddressUtilsTest.java
├── [2.8K] CONTRIBUTING.md
├── [4.0K] dev
│ └── [ 17K] merge_rocketmq_pr.py
├── [4.0K] distribution
│ ├── [4.0K] benchmark
│ │ ├── [ 867] batchproducer.sh
│ │ ├── [ 862] consumer.sh
│ │ ├── [ 909] producer.sh
│ │ ├── [2.7K] runclass.sh
│ │ ├── [2.5K] shutdown.sh
│ │ └── [ 891] tproducer.sh
│ ├── [4.0K] bin
│ │ ├── [1.6K] cachedog.sh
│ │ ├── [ 845] cleancache.sh
│ │ ├── [1.1K] cleancache.v1.sh
│ │ ├── [4.0K] dledger
│ │ │ └── [2.8K] fast-try.sh
│ │ ├── [2.5K] export.sh
│ │ ├── [1.4K] mqadmin
│ │ ├── [1.0K] mqadmin.cmd
│ │ ├── [1.4K] mqbroker
│ │ ├── [1.1K] mqbroker.cmd
│ │ ├── [1.3K] mqbroker.numanode0
│ │ ├── [1.3K] mqbroker.numanode1
│ │ ├── [1.3K] mqbroker.numanode2
│ │ ├── [1.3K] mqbroker.numanode3
│ │ ├── [1.4K] mqnamesrv
│ │ ├── [1.1K] mqnamesrv.cmd
│ │ ├── [1.5K] mqshutdown
│ │ ├── [1.4K] mqshutdown.cmd
│ │ ├── [2.2K] os.sh
│ │ ├── [1.1K] play.cmd
│ │ ├── [1008] play.sh
│ │ ├── [ 772] README.md
│ │ ├── [2.1K] runbroker.cmd
│ │ ├── [4.4K] runbroker.sh
│ │ ├── [1.8K] runserver.cmd
│ │ ├── [4.0K] runserver.sh
│ │ ├── [1.1K] setcache.sh
│ │ ├── [1.4K] startfsrv.sh
│ │ ├── [1.5K] tools.cmd
│ │ └── [2.0K] tools.sh
│ ├── [4.0K] conf
│ │ ├── [4.0K] 2m-2s-async
│ │ │ ├── [ 929] broker-a.properties
│ │ │ ├── [ 922] broker-a-s.properties
│ │ │ ├── [ 929] broker-b.properties
│ │ │ └── [ 922] broker-b-s.properties
│ │ ├── [4.0K] 2m-2s-sync
│ │ │ ├── [ 928] broker-a.properties
│ │ │ ├── [ 922] broker-a-s.properties
│ │ │ ├── [ 928] broker-b.properties
│ │ │ └── [ 922] broker-b-s.properties
│ │ ├── [4.0K] 2m-noslave
│ │ │ ├── [ 929] broker-a.properties
│ │ │ ├── [ 929] broker-b.properties
│ │ │ └── [ 937] broker-trace.properties
│ │ ├── [ 949] broker.conf
│ │ ├── [4.0K] dledger
│ │ │ ├── [1.1K] broker-n0.conf
│ │ │ ├── [1.1K] broker-n1.conf
│ │ │ └── [1.1K] broker-n2.conf
│ │ ├── [ 15K] logback_broker.xml
│ │ ├── [3.8K] logback_namesrv.xml
│ │ ├── [3.7K] logback_tools.xml
│ │ ├── [1.3K] plain_acl.yml
│ │ └── [ 834] tools.yml
│ ├── [ 17K] LICENSE-BIN
│ ├── [1.3K] NOTICE-BIN
│ ├── [4.6K] pom.xml
│ ├── [2.1K] release-client.xml
│ └── [3.0K] release.xml
├── [4.0K] docs
│ ├── [4.0K] cn
│ │ ├── [4.0K] acl
│ │ │ ├── [8.6K] RocketMQ_Multiple_ACL_Files_设计.md
│ │ │ └── [8.2K] user_guide.md
│ │ ├── [4.9K] architecture.md
│ │ ├── [ 28K] best_practice.md
│ │ ├── [4.0K] client
│ │ │ └── [4.0K] java
│ │ │ ├── [ 42K] API_Reference_DefaultMQProducer.md
│ │ │ └── [7.5K] API_Reference_ DefaultPullConsumer.md
│ │ ├── [4.4K] concept.md
│ │ ├── [2.7K] Configuration_System.md
│ │ ├── [4.3K] Configuration_TLS.md
│ │ ├── [6.3K] Deployment.md
│ │ ├── [ 27K] design.md
│ │ ├── [4.0K] dledger
│ │ │ ├── [3.5K] deploy_guide.md
│ │ │ └── [1.6K] quick_start.md
│ │ ├── [3.2K] Example_Batch.md
│ │ ├── [3.2K] Example_Delay.md
│ │ ├── [3.8K] Example_LMQ.md
│ │ ├── [5.2K] Example_Simple_cn.md
│ │ ├── [4.9K] FAQ.md
│ │ ├── [9.3K] features.md
│ │ ├── [4.0K] image
│ │ │ ├── [ 51K] consumer_reply.png
│ │ │ ├── [297K] LMQ_1.png
│ │ │ ├── [ 86K] producer_send_request.png
│ │ │ ├── [ 61K] rocketmq_architecture_1.png
│ │ │ ├── [ 18K] rocketmq_architecture_2.png
│ │ │ ├── [ 73K] rocketmq_architecture_3.png
│ │ │ ├── [ 35K] rocketmq_design_10.png
│ │ │ ├── [ 68K] rocketmq_design_11.png
│ │ │ ├── [ 53K] rocketmq_design_12.png
│ │ │ ├── [ 33K] rocketmq_design_13.png
│ │ │ ├── [109K] rocketmq_design_1.png
│ │ │ ├── [ 22K] rocketmq_design_2.png
│ │ │ ├── [ 65K] rocketmq_design_3.png
│ │ │ ├── [ 20K] rocketmq_design_4.png
│ │ │ ├── [136K] rocketmq_design_5.png
│ │ │ ├── [ 63K] rocketmq_design_6.png
│ │ │ ├── [6.6K] rocketmq_design_7.png
│ │ │ ├── [ 77K] rocketmq_design_8.png
│ │ │ └── [ 39K] rocketmq_design_9.png
│ │ ├── [4.0K] msg_trace
│ │ │ └── [5.4K] user_guide.md
│ │ ├── [ 69K] operation.md
│ │ ├── [1.8K] README.md
│ │ ├── [ 39K] RocketMQ_Example.md
│ │ └── [6.9K] rpc_request.md
│ └── [4.0K] en
│ ├── [4.0K] acl
│ │ └── [4.5K] Operations_ACL.md
│ ├── [6.2K] architecture.md
│ ├── [7.9K] best_practice.md
│ ├── [4.0K] client
│ │ └── [4.0K] java
│ │ └── [3.8K] API_Reference_DefaultMQProducer.md
│ ├── [ 66K] CLITools.md
│ ├── [5.1K] Concept.md
│ ├── [ 12K] Configuration_Client.md
│ ├── [3.0K] Configuration_System.md
│ ├── [4.4K] Configuration_TLS.md
│ ├── [7.5K] Deployment.md
│ ├── [2.1K] Design_Filter.md
│ ├── [7.1K] Design_LoadBlancing.md
│ ├── [7.8K] design.md
│ ├── [3.4K] Design_Query.md
│ ├── [6.5K] Design_Remoting.md
│ ├── [6.8K] Design_Store.md
│ ├── [6.8K] Design_Trancation.md
│ ├── [4.0K] dledger
│ │ ├── [3.3K] deploy_guide.md
│ │ └── [1.7K] quick_start.md
│ ├── [3.2K] Example_Batch.md
│ ├── [3.5K] Example_Delay.md
│ ├── [2.7K] Example_Filter.md
│ ├── [4.9K] Example_OpenMessaging.md
│ ├── [7.6K] Example_Orderly.md
│ ├── [5.4K] Example_Simple.md
│ ├── [6.0K] Example_Transaction.md
│ ├── [5.4K] FAQ.md
│ ├── [ 11K] Feature.md
│ ├── [4.0K] image
│ │ ├── [ 61K] rocketmq_architecture_1.png
│ │ ├── [ 18K] rocketmq_architecture_2.png
│ │ └── [ 73K] rocketmq_architecture_3.png
│ ├── [4.0K] images
│ │ ├── [6.6K] rocketmq_design_7.png
│ │ ├── [ 26K] rocketmq_design_message_query.png
│ │ ├── [109K] rocketmq_storage_arch.png
│ │ └── [ 22K] rocketmq_storage_flush.png
│ ├── [4.0K] msg_trace
│ │ └── [5.4K] user_guide.md
│ ├── [ 69K] operation.md
│ ├── [2.9K] Operations_Broker.md
│ ├── [6.9K] Operations_Consumer.md
│ ├── [5.1K] Operations_Producer.md
│ ├── [5.1K] Operations_Trace.md
│ ├── [1.9K] README.md
│ ├── [ 353] RocketMQ_Example.md
│ └── [4.5K] Troubleshoopting.md
├── [4.0K] example
│ ├── [2.5K] pom.xml
│ └── [4.0K] src
│ └── [4.0K] main
│ └── [4.0K] java
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] example
│ ├── [4.0K] batch
│ │ ├── [2.2K] SimpleBatchProducer.java
│ │ └── [4.1K] SplitBatchProducer.java
│ ├── [4.0K] benchmark
│ │ ├── [1.4K] AclClient.java
│ │ ├── [ 17K] BatchProducer.java
│ │ ├── [ 13K] Consumer.java
│ │ ├── [ 19K] Producer.java
│ │ └── [ 20K] TransactionProducer.java
│ ├── [4.0K] broadcast
│ │ └── [2.4K] PushConsumer.java
│ ├── [4.0K] filter
│ │ ├── [2.2K] SqlFilterConsumer.java
│ │ ├── [1.8K] SqlFilterProducer.java
│ │ ├── [2.1K] TagFilterConsumer.java
│ │ └── [1.7K] TagFilterProducer.java
│ ├── [4.0K] namespace
│ │ ├── [2.0K] ProducerWithNamespace.java
│ │ ├── [3.5K] PullConsumerWithNamespace.java
│ │ └── [2.0K] PushConsumerWithNamespace.java
│ ├── [4.0K] openmessaging
│ │ ├── [3.1K] SimpleProducer.java
│ │ ├── [3.0K] SimplePullConsumer.java
│ │ └── [2.1K] SimplePushConsumer.java
│ ├── [4.0K] operation
│ │ ├── [4.4K] Consumer.java
│ │ └── [4.1K] Producer.java
│ ├── [4.0K] ordermessage
│ │ ├── [2.7K] Consumer.java
│ │ └── [2.7K] Producer.java
│ ├── [4.0K] quickstart
│ │ ├── [3.1K] Consumer.java
│ │ └── [4.5K] Producer.java
│ ├── [4.0K] rpc
│ │ ├── [2.5K] AsyncRequestProducer.java
│ │ ├── [2.0K] RequestProducer.java
│ │ └── [4.0K] ResponseConsumer.java
│ ├── [4.0K] schedule
│ │ ├── [2.4K] ScheduledMessageConsumer.java
│ │ └── [2.1K] ScheduledMessageProducer.java
│ ├── [4.0K] simple
│ │ ├── [6.5K] AclClient.java
│ │ ├── [2.8K] AsyncProducer.java
│ │ ├── [1.1K] CachedQueue.java
│ │ ├── [2.1K] LitePullConsumerAssign.java
│ │ ├── [2.4K] LitePullConsumerAssignWithSubExpression.java
│ │ ├── [1.7K] LitePullConsumerSubscribe.java
│ │ ├── [2.0K] OnewayProducer.java
│ │ ├── [1.9K] Producer.java
│ │ ├── [7.0K] PullConsumer.java
│ │ ├── [1.9K] PullConsumerTest.java
│ │ ├── [2.9K] PullScheduleService.java
│ │ ├── [2.2K] PushConsumer.java
│ │ ├── [2.1K] RandomAsyncCommit.java
│ │ └── [2.3K] TestProducer.java
│ ├── [4.0K] tracemessage
│ │ ├── [3.1K] OpenTracingProducer.java
│ │ ├── [3.2K] OpenTracingPushConsumer.java
│ │ ├── [4.2K] OpenTracingTransactionProducer.java
│ │ ├── [2.4K] TraceProducer.java
│ │ └── [2.4K] TracePushConsumer.java
│ └── [4.0K] transaction
│ ├── [2.3K] TransactionListenerImpl.java
│ └── [3.3K] TransactionProducer.java
├── [4.0K] filter
│ ├── [1.8K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] filter
│ │ ├── [4.0K] constant
│ │ │ └── [ 930] UnaryType.java
│ │ ├── [4.0K] expression
│ │ │ ├── [2.3K] BinaryExpression.java
│ │ │ ├── [1.5K] BooleanConstantExpression.java
│ │ │ ├── [1.3K] BooleanExpression.java
│ │ │ ├── [ 16K] ComparisonExpression.java
│ │ │ ├── [3.9K] ConstantExpression.java
│ │ │ ├── [1.1K] EmptyEvaluationContext.java
│ │ │ ├── [1.2K] EvaluationContext.java
│ │ │ ├── [1.3K] Expression.java
│ │ │ ├── [3.2K] LogicExpression.java
│ │ │ ├── [1.5K] MQFilterException.java
│ │ │ ├── [1.2K] NowExpression.java
│ │ │ ├── [1.9K] PropertyExpression.java
│ │ │ ├── [8.6K] UnaryExpression.java
│ │ │ └── [1.7K] UnaryInExpression.java
│ │ ├── [2.0K] FilterFactory.java
│ │ ├── [1.2K] FilterSpi.java
│ │ ├── [4.0K] parser
│ │ │ ├── [7.3K] ParseException.java
│ │ │ ├── [2.9K] SelectorParserConstants.java
│ │ │ ├── [ 39K] SelectorParser.java
│ │ │ ├── [ 13K] SelectorParser.jj
│ │ │ ├── [ 32K] SelectorParserTokenManager.java
│ │ │ ├── [ 14K] SimpleCharStream.java
│ │ │ ├── [5.1K] Token.java
│ │ │ └── [5.7K] TokenMgrError.java
│ │ ├── [1.5K] SqlFilter.java
│ │ └── [4.0K] util
│ │ ├── [7.3K] BitsArray.java
│ │ ├── [2.3K] BloomFilterData.java
│ │ └── [8.6K] BloomFilter.java
│ └── [4.0K] test
│ └── [4.0K] java
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] filter
│ ├── [3.3K] BitsArrayTest.java
│ ├── [5.8K] BloomFilterTest.java
│ ├── [ 16K] ExpressionTest.java
│ ├── [2.7K] FilterSpiTest.java
│ └── [4.3K] ParserTest.java
├── [ 11K] LICENSE
├── [4.0K] logging
│ ├── [1.7K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] logging
│ │ ├── [4.0K] inner
│ │ │ ├── [6.3K] Appender.java
│ │ │ ├── [1.2K] Layout.java
│ │ │ ├── [4.3K] Level.java
│ │ │ ├── [ 13K] Logger.java
│ │ │ ├── [ 39K] LoggingBuilder.java
│ │ │ ├── [3.7K] LoggingEvent.java
│ │ │ └── [2.5K] SysLogger.java
│ │ ├── [ 16K] InnerLoggerFactory.java
│ │ ├── [2.9K] InternalLoggerFactory.java
│ │ ├── [1.7K] InternalLogger.java
│ │ ├── [1.2K] package-info.java
│ │ └── [3.9K] Slf4jLoggerFactory.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] logging
│ │ ├── [2.4K] BasicLoggerTest.java
│ │ ├── [4.0K] inner
│ │ │ ├── [6.5K] AppenderTest.java
│ │ │ ├── [2.1K] LayoutTest.java
│ │ │ ├── [1.2K] LevelTest.java
│ │ │ ├── [2.0K] LoggerRepositoryTest.java
│ │ │ ├── [4.3K] LoggerTest.java
│ │ │ ├── [4.1K] LoggingBuilderTest.java
│ │ │ └── [1.6K] MessageFormatterTest.java
│ │ ├── [3.5K] InnerLoggerFactoryTest.java
│ │ ├── [2.7K] InternalLoggerTest.java
│ │ └── [3.3K] Slf4jLoggerFactoryTest.java
│ └── [4.0K] resources
│ └── [1.8K] logback_test.xml
├── [4.0K] namesrv
│ ├── [2.2K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] namesrv
│ │ ├── [4.0K] kvconfig
│ │ │ ├── [7.8K] KVConfigManager.java
│ │ │ └── [1.3K] KVConfigSerializeWrapper.java
│ │ ├── [7.4K] NamesrvController.java
│ │ ├── [6.6K] NamesrvStartup.java
│ │ ├── [4.0K] processor
│ │ │ ├── [4.0K] ClusterTestRequestProcessor.java
│ │ │ └── [ 29K] DefaultRequestProcessor.java
│ │ └── [4.0K] routeinfo
│ │ ├── [2.1K] BrokerHousekeepingService.java
│ │ └── [ 33K] RouteInfoManager.java
│ └── [4.0K] test
│ └── [4.0K] java
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] namesrv
│ ├── [4.0K] kvconfig
│ │ ├── [2.2K] KVConfigManagerTest.java
│ │ └── [2.5K] KVConfigSerializeWrapperTest.java
│ ├── [1.8K] NameServerInstanceTest.java
│ ├── [3.0K] NamesrvControllerTest.java
│ ├── [2.1K] NamesrvStartupTest.java
│ ├── [4.0K] processor
│ │ ├── [5.1K] ClusterTestRequestProcessorTest.java
│ │ └── [ 22K] DefaultRequestProcessorTest.java
│ └── [4.0K] routeinfo
│ ├── [1.9K] BrokerHousekeepingServiceTest.java
│ ├── [3.9K] RouteInfoManagerBrokerPermTest.java
│ ├── [4.6K] RouteInfoManagerBrokerRegisterTest.java
│ ├── [5.2K] RouteInfoManagerStaticRegisterTest.java
│ └── [7.8K] RouteInfoManagerTestBase.java
├── [ 169] NOTICE
├── [4.0K] openmessaging
│ ├── [1.6K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] io
│ │ └── [4.0K] openmessaging
│ │ └── [4.0K] rocketmq
│ │ ├── [4.0K] config
│ │ │ └── [5.6K] ClientConfig.java
│ │ ├── [4.0K] consumer
│ │ │ ├── [9.1K] LocalMessageCache.java
│ │ │ ├── [7.4K] PullConsumerImpl.java
│ │ │ └── [8.0K] PushConsumerImpl.java
│ │ ├── [4.0K] domain
│ │ │ ├── [3.1K] BytesMessageImpl.java
│ │ │ ├── [1.9K] ConsumeRequest.java
│ │ │ ├── [1.5K] NonStandardKeys.java
│ │ │ ├── [1002] RocketMQConstants.java
│ │ │ └── [1.3K] SendResultImpl.java
│ │ ├── [3.2K] MessagingAccessPointImpl.java
│ │ ├── [4.0K] producer
│ │ │ ├── [6.6K] AbstractOMSProducer.java
│ │ │ └── [5.6K] ProducerImpl.java
│ │ ├── [4.0K] promise
│ │ │ ├── [6.3K] DefaultPromise.java
│ │ │ └── [1.3K] FutureState.java
│ │ └── [4.0K] utils
│ │ ├── [7.9K] BeanUtils.java
│ │ └── [6.5K] OMSUtil.java
│ └── [4.0K] test
│ └── [4.0K] java
│ └── [4.0K] io
│ └── [4.0K] openmessaging
│ └── [4.0K] rocketmq
│ ├── [4.0K] consumer
│ │ ├── [3.5K] LocalMessageCacheTest.java
│ │ ├── [3.9K] PullConsumerImplTest.java
│ │ └── [3.6K] PushConsumerImplTest.java
│ ├── [4.0K] producer
│ │ └── [4.3K] ProducerImplTest.java
│ ├── [4.0K] promise
│ │ └── [4.0K] DefaultPromiseTest.java
│ └── [4.0K] utils
│ └── [3.9K] BeanUtilsTest.java
├── [ 30K] pom.xml
├── [ 11K] README.md
├── [4.0K] remoting
│ ├── [1.9K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] remoting
│ │ ├── [4.0K] annotation
│ │ │ ├── [1.2K] CFNotNull.java
│ │ │ └── [1.2K] CFNullable.java
│ │ ├── [1.2K] ChannelEventListener.java
│ │ ├── [1011] CommandCustomHeader.java
│ │ ├── [4.0K] common
│ │ │ ├── [1.3K] Pair.java
│ │ │ ├── [7.6K] RemotingHelper.java
│ │ │ ├── [8.4K] RemotingUtil.java
│ │ │ ├── [1.4K] SemaphoreReleaseOnlyOnce.java
│ │ │ ├── [2.6K] ServiceThread.java
│ │ │ └── [1.8K] TlsMode.java
│ │ ├── [4.0K] exception
│ │ │ ├── [1.2K] RemotingCommandException.java
│ │ │ ├── [1.2K] RemotingConnectException.java
│ │ │ ├── [1.1K] RemotingException.java
│ │ │ ├── [1.2K] RemotingSendRequestException.java
│ │ │ ├── [1.4K] RemotingTimeoutException.java
│ │ │ └── [1.1K] RemotingTooMuchRequestException.java
│ │ ├── [1001] InvokeCallback.java
│ │ ├── [4.0K] netty
│ │ │ ├── [1.3K] AsyncNettyRequestProcessor.java
│ │ │ ├── [2.8K] FileRegionEncoder.java
│ │ │ ├── [5.5K] NettyClientConfig.java
│ │ │ ├── [2.3K] NettyDecoder.java
│ │ │ ├── [2.1K] NettyEncoder.java
│ │ │ ├── [1.5K] NettyEvent.java
│ │ │ ├── [ 926] NettyEventType.java
│ │ │ ├── [ 11K] NettyLogger.java
│ │ │ ├── [ 25K] NettyRemotingAbstract.java
│ │ │ ├── [ 30K] NettyRemotingClient.java
│ │ │ ├── [ 21K] NettyRemotingServer.java
│ │ │ ├── [1.2K] NettyRequestProcessor.java
│ │ │ ├── [5.3K] NettyServerConfig.java
│ │ │ ├── [4.3K] NettySystemConfig.java
│ │ │ ├── [1002] RemotingResponseCallback.java
│ │ │ ├── [3.0K] RequestTask.java
│ │ │ ├── [4.3K] ResponseFuture.java
│ │ │ ├── [ 11K] TlsHelper.java
│ │ │ └── [5.7K] TlsSystemConfig.java
│ │ ├── [4.0K] protocol
│ │ │ ├── [1.8K] FastCodesHeader.java
│ │ │ ├── [1.5K] LanguageCode.java
│ │ │ ├── [ 20K] RemotingCommand.java
│ │ │ ├── [ 929] RemotingCommandType.java
│ │ │ ├── [2.4K] RemotingSerializable.java
│ │ │ ├── [1.1K] RemotingSysResponseCode.java
│ │ │ ├── [1.3K] RequestType.java
│ │ │ ├── [8.8K] RocketMQSerializable.java
│ │ │ └── [1.3K] SerializeType.java
│ │ ├── [2.5K] RemotingClient.java
│ │ ├── [2.4K] RemotingServer.java
│ │ ├── [ 963] RemotingService.java
│ │ └── [1.1K] RPCHook.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] remoting
│ │ ├── [4.0K] netty
│ │ │ ├── [3.0K] FileRegionEncoderTest.java
│ │ │ ├── [3.4K] NettyClientConfigTest.java
│ │ │ ├── [4.5K] NettyRemotingAbstractTest.java
│ │ │ ├── [1.6K] NettyRemotingClientTest.java
│ │ │ └── [1.5K] NettyServerConfigTest.java
│ │ ├── [4.0K] protocol
│ │ │ ├── [1.2K] LanguageCodeTest.java
│ │ │ ├── [ 11K] RemotingCommandTest.java
│ │ │ ├── [6.3K] RemotingSerializableTest.java
│ │ │ ├── [1.2K] RequestTypeTest.java
│ │ │ └── [9.7K] RocketMQSerializableTest.java
│ │ ├── [5.7K] RemotingServerTest.java
│ │ └── [ 14K] TlsTest.java
│ └── [4.0K] resources
│ └── [4.0K] certs
│ ├── [ 993] badClient.key
│ ├── [1.1K] badClient.pem
│ ├── [ 916] badServer.key
│ ├── [1.0K] badServer.pem
│ ├── [1.3K] ca.pem
│ ├── [ 993] client.key
│ ├── [1.1K] client.pem
│ ├── [1.8K] privkey.pem
│ ├── [ 916] server.key
│ └── [1.1K] server.pem
├── [4.0K] srvutil
│ ├── [1.8K] pom.xml
│ └── [4.0K] src
│ └── [4.0K] main
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] srvutil
│ │ ├── [6.3K] AclFileWatchService.java
│ │ ├── [3.8K] FileWatchService.java
│ │ ├── [2.9K] ServerUtil.java
│ │ └── [2.6K] ShutdownHookThread.java
│ └── [4.0K] test
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] srvutil
│ └── [5.6K] FileWatchServiceTest.java
├── [4.0K] store
│ ├── [2.8K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] store
│ │ ├── [ 12K] AllocateMappedFileService.java
│ │ ├── [1.7K] AppendMessageCallback.java
│ │ ├── [4.3K] AppendMessageResult.java
│ │ ├── [1.0K] AppendMessageStatus.java
│ │ ├── [1.1K] CommitLogDispatcher.java
│ │ ├── [ 76K] CommitLog.java
│ │ ├── [4.0K] config
│ │ │ ├── [ 918] BrokerRole.java
│ │ │ ├── [ 907] FlushDiskType.java
│ │ │ ├── [ 26K] MessageStoreConfig.java
│ │ │ └── [2.1K] StorePathConfigHelper.java
│ │ ├── [ 19K] ConsumeQueueExt.java
│ │ ├── [ 25K] ConsumeQueue.java
│ │ ├── [1.8K] DefaultMessageFilter.java
│ │ ├── [ 86K] DefaultMessageStore.java
│ │ ├── [4.6K] DispatchRequest.java
│ │ ├── [4.0K] dledger
│ │ │ └── [ 44K] DLedgerCommitLog.java
│ │ ├── [3.0K] FlushDiskWatcher.java
│ │ ├── [4.1K] GetMessageResult.java
│ │ ├── [1.1K] GetMessageStatus.java
│ │ ├── [4.0K] ha
│ │ │ ├── [ 16K] HAConnection.java
│ │ │ ├── [ 23K] HAService.java
│ │ │ └── [3.7K] WaitNotifyObject.java
│ │ ├── [4.0K] index
│ │ │ ├── [9.1K] IndexFile.java
│ │ │ ├── [4.3K] IndexHeader.java
│ │ │ ├── [ 13K] IndexService.java
│ │ │ └── [1.6K] QueryOffsetResult.java
│ │ ├── [ 21K] MappedFile.java
│ │ ├── [ 21K] MappedFileQueue.java
│ │ ├── [1.4K] MessageArrivingListener.java
│ │ ├── [2.0K] MessageExtBrokerInner.java
│ │ ├── [1.8K] MessageFilter.java
│ │ ├── [ 12K] MessageStore.java
│ │ ├── [8.1K] MultiDispatch.java
│ │ ├── [4.6K] MultiPathMappedFileQueue.java
│ │ ├── [ 954] PutMessageLock.java
│ │ ├── [1.2K] PutMessageReentrantLock.java
│ │ ├── [1.9K] PutMessageResult.java
│ │ ├── [1.4K] PutMessageSpinLock.java
│ │ ├── [1.1K] PutMessageStatus.java
│ │ ├── [2.3K] QueryMessageResult.java
│ │ ├── [2.4K] ReferenceResource.java
│ │ ├── [3.7K] RunningFlags.java
│ │ ├── [4.0K] schedule
│ │ │ ├── [1.4K] DelayOffsetSerializeWrapper.java
│ │ │ └── [ 33K] ScheduleMessageService.java
│ │ ├── [1.7K] SelectMappedBufferResult.java
│ │ ├── [4.0K] stats
│ │ │ ├── [3.5K] BrokerStats.java
│ │ │ ├── [ 17K] BrokerStatsManager.java
│ │ │ └── [4.0K] LmqBrokerStatsManager.java
│ │ ├── [4.5K] StoreCheckpoint.java
│ │ ├── [ 24K] StoreStatsService.java
│ │ ├── [1.5K] StoreUtil.java
│ │ ├── [3.3K] TransientStorePool.java
│ │ └── [4.0K] util
│ │ └── [1.7K] LibC.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ ├── [4.0K] org
│ │ │ └── [4.0K] apache
│ │ │ └── [4.0K] rocketmq
│ │ │ └── [4.0K] store
│ │ │ ├── [ 12K] AppendCallbackTest.java
│ │ │ ├── [ 12K] BatchPutMessageTest.java
│ │ │ ├── [7.4K] ConsumeQueueExtTest.java
│ │ │ ├── [ 15K] ConsumeQueueTest.java
│ │ │ ├── [ 25K] DefaultMessageStoreCleanFilesTest.java
│ │ │ ├── [3.0K] DefaultMessageStoreShutDownTest.java
│ │ │ ├── [ 31K] DefaultMessageStoreTest.java
│ │ │ ├── [4.0K] dledger
│ │ │ │ ├── [ 20K] DLedgerCommitlogTest.java
│ │ │ │ ├── [5.0K] DLedgerMultiPathTest.java
│ │ │ │ ├── [6.9K] MessageStoreTestBase.java
│ │ │ │ └── [ 10K] MixCommitlogTest.java
│ │ │ ├── [3.1K] FlushDiskWatcherTest.java
│ │ │ ├── [4.0K] ha
│ │ │ │ └── [1.5K] WaitNotifyObjectTest.java
│ │ │ ├── [9.3K] HATest.java
│ │ │ ├── [4.0K] index
│ │ │ │ └── [2.7K] IndexFileTest.java
│ │ │ ├── [9.8K] MappedFileQueueTest.java
│ │ │ ├── [2.2K] MappedFileTest.java
│ │ │ ├── [4.3K] MultiDispatchTest.java
│ │ │ ├── [7.4K] MultiPathMappedFileQueueTest.java
│ │ │ ├── [4.0K] schedule
│ │ │ │ └── [8.7K] ScheduleMessageServiceTest.java
│ │ │ ├── [8.8K] ScheduleMessageServiceTest.java
│ │ │ ├── [2.1K] StoreCheckpointTest.java
│ │ │ ├── [4.7K] StoreStatsServiceTest.java
│ │ │ ├── [6.5K] StoreTestBase.java
│ │ │ └── [4.2K] StoreTestUtil.java
│ │ └── [4.0K] stats
│ │ └── [9.5K] BrokerStatsManagerTest.java
│ └── [4.0K] resources
│ └── [1.3K] logback-test.xml
├── [4.0K] style
│ ├── [4.0K] copyright
│ │ ├── [1.7K] Apache.xml
│ │ └── [2.7K] profiles_settings.xml
│ ├── [5.9K] rmq_checkstyle.xml
│ └── [6.9K] rmq_codeStyle.xml
├── [4.0K] test
│ ├── [3.0K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] test
│ │ ├── [4.0K] client
│ │ │ ├── [4.0K] mq
│ │ │ │ └── [2.9K] MQAsyncProducer.java
│ │ │ └── [4.0K] rmq
│ │ │ ├── [7.5K] RMQAsyncSendProducer.java
│ │ │ ├── [1.5K] RMQBroadCastConsumer.java
│ │ │ ├── [3.1K] RMQNormalConsumer.java
│ │ │ ├── [6.0K] RMQNormalProducer.java
│ │ │ ├── [1.6K] RMQSqlConsumer.java
│ │ │ └── [4.0K] RMQTransactionalProducer.java
│ │ ├── [4.0K] clientinterface
│ │ │ ├── [3.0K] AbstractMQConsumer.java
│ │ │ ├── [4.4K] AbstractMQProducer.java
│ │ │ ├── [3.9K] MQCollector.java
│ │ │ ├── [ 985] MQConsumer.java
│ │ │ └── [1.0K] MQProducer.java
│ │ ├── [4.0K] factory
│ │ │ ├── [3.1K] ConsumerFactory.java
│ │ │ ├── [2.2K] MessageFactory.java
│ │ │ ├── [4.4K] MQMessageFactory.java
│ │ │ ├── [1.5K] ProducerFactory.java
│ │ │ ├── [1.3K] SendCallBackFactory.java
│ │ │ └── [3.2K] TagMessage.java
│ │ ├── [4.0K] listener
│ │ │ ├── [4.3K] AbstractListener.java
│ │ │ └── [4.0K] rmq
│ │ │ ├── [4.0K] concurrent
│ │ │ │ ├── [2.5K] RMQDelayListner.java
│ │ │ │ └── [2.9K] RMQNormalListener.java
│ │ │ └── [4.0K] order
│ │ │ └── [3.0K] RMQOrderListener.java
│ │ ├── [4.0K] lmq
│ │ │ └── [4.0K] benchmark
│ │ │ └── [ 16K] BenchLmqStore.java
│ │ ├── [4.0K] message
│ │ │ └── [2.2K] MessageQueueMsg.java
│ │ ├── [4.0K] sendresult
│ │ │ └── [1.8K] ResultWrapper.java
│ │ └── [4.0K] util
│ │ ├── [ 909] Condition.java
│ │ ├── [4.0K] data
│ │ │ └── [4.0K] collect
│ │ │ ├── [1.3K] DataCollector.java
│ │ │ ├── [4.1K] DataCollectorManager.java
│ │ │ ├── [ 894] DataFilter.java
│ │ │ └── [4.0K] impl
│ │ │ ├── [2.5K] ListDataCollectorImpl.java
│ │ │ └── [3.1K] MapDataCollectorImpl.java
│ │ ├── [5.7K] DuplicateMessageInfo.java
│ │ ├── [3.5K] FileUtil.java
│ │ ├── [6.2K] MQAdmin.java
│ │ ├── [1.1K] MQRandomUtils.java
│ │ ├── [3.3K] MQWait.java
│ │ ├── [4.0K] parallel
│ │ │ ├── [2.0K] ParallelTaskExecutor.java
│ │ │ ├── [1.3K] ParallelTask.java
│ │ │ └── [1.0K] Task4Test.java
│ │ ├── [8.5K] RandomUtil.java
│ │ ├── [2.6K] RandomUtils.java
│ │ ├── [ 17K] StatUtil.java
│ │ ├── [3.7K] TestUtil.java
│ │ ├── [1.5K] TestUtils.java
│ │ └── [4.7K] VerifyUtils.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] test
│ │ ├── [4.0K] base
│ │ │ ├── [6.9K] BaseConf.java
│ │ │ ├── [4.0K] dledger
│ │ │ │ └── [5.6K] DLedgerProduceAndConsumeIT.java
│ │ │ └── [8.1K] IntegrationTestBase.java
│ │ ├── [4.0K] client
│ │ │ ├── [4.0K] consumer
│ │ │ │ ├── [4.0K] balance
│ │ │ │ │ ├── [4.6K] NormalMsgDynamicBalanceIT.java
│ │ │ │ │ └── [4.7K] NormalMsgStaticBalanceIT.java
│ │ │ │ ├── [4.0K] broadcast
│ │ │ │ │ ├── [2.3K] BaseBroadCastIT.java
│ │ │ │ │ ├── [4.0K] normal
│ │ │ │ │ │ ├── [2.9K] BroadCastNormalMsgNotRecvIT.java
│ │ │ │ │ │ ├── [3.6K] BroadCastNormalMsgRecvCrashIT.java
│ │ │ │ │ │ ├── [2.8K] BroadCastNormalMsgRecvFailIT.java
│ │ │ │ │ │ ├── [3.6K] BroadCastNormalMsgRecvStartLaterIT.java
│ │ │ │ │ │ ├── [3.1K] BroadCastNormalMsgTwoDiffGroupRecvIT.java
│ │ │ │ │ │ └── [3.1K] NormalMsgTwoSameGroupConsumerIT.java
│ │ │ │ │ ├── [4.0K] order
│ │ │ │ │ │ └── [3.1K] OrderMsgBroadCastIT.java
│ │ │ │ │ └── [4.0K] tag
│ │ │ │ │ ├── [3.1K] BroadCastTwoConsumerFilterIT.java
│ │ │ │ │ ├── [3.0K] BroadCastTwoConsumerSubDiffTagIT.java
│ │ │ │ │ └── [3.0K] BroadCastTwoConsumerSubTagIT.java
│ │ │ │ ├── [4.0K] cluster
│ │ │ │ │ ├── [4.1K] DynamicAddAndCrashIT.java
│ │ │ │ │ ├── [3.9K] DynamicAddConsumerIT.java
│ │ │ │ │ └── [3.9K] DynamicCrashConsumerIT.java
│ │ │ │ ├── [4.0K] filter
│ │ │ │ │ └── [5.6K] SqlFilterIT.java
│ │ │ │ ├── [4.0K] tag
│ │ │ │ │ ├── [6.2K] MulTagSubIT.java
│ │ │ │ │ ├── [8.0K] TagMessageWith1ConsumerIT.java
│ │ │ │ │ ├── [8.9K] TagMessageWithMulConsumerIT.java
│ │ │ │ │ └── [4.7K] TagMessageWithSameGroupConsumerIT.java
│ │ │ │ └── [4.0K] topic
│ │ │ │ ├── [4.4K] MulConsumerMulTopicIT.java
│ │ │ │ └── [4.2K] OneConsumerMulTopicIT.java
│ │ │ └── [4.0K] producer
│ │ │ ├── [4.0K] async
│ │ │ │ ├── [5.4K] AsyncSendExceptionIT.java
│ │ │ │ ├── [3.4K] AsyncSendWithMessageQueueIT.java
│ │ │ │ ├── [4.2K] AsyncSendWithMessageQueueSelectorIT.java
│ │ │ │ └── [2.5K] AsyncSendWithOnlySendCallBackIT.java
│ │ │ ├── [4.0K] batch
│ │ │ │ └── [5.0K] BatchSendIT.java
│ │ │ ├── [4.0K] exception
│ │ │ │ ├── [4.0K] msg
│ │ │ │ │ ├── [2.5K] ChinaPropIT.java
│ │ │ │ │ ├── [4.8K] MessageExceptionIT.java
│ │ │ │ │ └── [3.5K] MessageUserPropIT.java
│ │ │ │ └── [4.0K] producer
│ │ │ │ └── [2.5K] ProducerGroupAndInstanceNameValidityIT.java
│ │ │ ├── [4.0K] oneway
│ │ │ │ ├── [3.2K] OneWaySendExceptionIT.java
│ │ │ │ ├── [2.5K] OneWaySendIT.java
│ │ │ │ ├── [3.1K] OneWaySendWithMQIT.java
│ │ │ │ └── [4.1K] OneWaySendWithSelectorIT.java
│ │ │ ├── [4.0K] order
│ │ │ │ ├── [4.7K] OrderMsgDynamicRebalanceIT.java
│ │ │ │ ├── [4.2K] OrderMsgIT.java
│ │ │ │ ├── [6.0K] OrderMsgRebalanceIT.java
│ │ │ │ └── [6.5K] OrderMsgWithTagIT.java
│ │ │ ├── [4.0K] querymsg
│ │ │ │ ├── [2.6K] QueryMsgByIdExceptionIT.java
│ │ │ │ ├── [2.9K] QueryMsgByIdIT.java
│ │ │ │ └── [5.6K] QueryMsgByKeyIT.java
│ │ │ └── [4.0K] transaction
│ │ │ └── [4.6K] TransactionalMsgIT.java
│ │ ├── [4.0K] delay
│ │ │ ├── [1.1K] DelayConf.java
│ │ │ └── [5.1K] NormalMsgDelayIT.java
│ │ ├── [4.0K] lmq
│ │ │ └── [5.7K] TestBenchLmqStore.java
│ │ ├── [4.0K] smoke
│ │ │ └── [2.4K] NormalMessageSendAndRecvIT.java
│ │ └── [4.0K] tls
│ │ ├── [2.0K] TLS_IT.java
│ │ ├── [2.0K] TLS_Mix2_IT.java
│ │ └── [2.0K] TLS_Mix_IT.java
│ └── [4.0K] resources
│ ├── [1.9K] log4j.xml
│ └── [1.3K] logback-test.xml
└── [4.0K] tools
├── [2.3K] pom.xml
└── [4.0K] src
├── [4.0K] main
│ └── [4.0K] java
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] tools
│ ├── [4.0K] admin
│ │ ├── [4.0K] api
│ │ │ ├── [1.7K] MessageTrack.java
│ │ │ └── [ 975] TrackType.java
│ │ ├── [ 56K] DefaultMQAdminExtImpl.java
│ │ ├── [ 27K] DefaultMQAdminExt.java
│ │ └── [ 17K] MQAdminExt.java
│ ├── [4.0K] command
│ │ ├── [4.0K] acl
│ │ │ ├── [5.5K] ClusterAclConfigVersionListSubCommand.java
│ │ │ ├── [4.1K] DeleteAccessConfigSubCommand.java
│ │ │ ├── [5.2K] GetAccessConfigSubCommand.java
│ │ │ ├── [7.2K] UpdateAccessConfigSubCommand.java
│ │ │ └── [4.5K] UpdateGlobalWhiteAddrSubCommand.java
│ │ ├── [4.0K] broker
│ │ │ ├── [6.7K] BrokerConsumeStatsSubCommad.java
│ │ │ ├── [4.5K] BrokerStatusSubCommand.java
│ │ │ ├── [2.9K] CleanExpiredCQSubCommand.java
│ │ │ ├── [2.9K] CleanUnusedTopicCommand.java
│ │ │ ├── [3.2K] DeleteExpiredCommitLogSubCommand.java
│ │ │ ├── [5.0K] GetBrokerConfigCommand.java
│ │ │ ├── [3.7K] SendMsgStatusCommand.java
│ │ │ └── [4.1K] UpdateBrokerConfigSubCommand.java
│ │ ├── [4.0K] cluster
│ │ │ ├── [ 13K] ClusterListSubCommand.java
│ │ │ └── [7.8K] CLusterSendMsgRTCommand.java
│ │ ├── [6.5K] CommandUtil.java
│ │ ├── [4.0K] connection
│ │ │ ├── [4.2K] ConsumerConnectionSubCommand.java
│ │ │ └── [3.1K] ProducerConnectionSubCommand.java
│ │ ├── [4.0K] consumer
│ │ │ ├── [ 13K] ConsumerProgressSubCommand.java
│ │ │ ├── [6.7K] ConsumerStatusSubCommand.java
│ │ │ ├── [6.1K] ConsumerSubCommand.java
│ │ │ ├── [4.6K] DeleteSubscriptionGroupCommand.java
│ │ │ ├── [5.8K] GetConsumerConfigSubCommand.java
│ │ │ ├── [2.2K] StartMonitoringSubCommand.java
│ │ │ └── [7.4K] UpdateSubGroupSubCommand.java
│ │ ├── [4.0K] export
│ │ │ ├── [6.0K] ExportConfigsCommand.java
│ │ │ ├── [8.0K] ExportMetadataCommand.java
│ │ │ └── [ 13K] ExportMetricsCommand.java
│ │ ├── [4.0K] message
│ │ │ ├── [5.1K] CheckMsgSendRTCommand.java
│ │ │ ├── [ 11K] ConsumeMessageCommand.java
│ │ │ ├── [2.4K] DecodeMessageIdCommond.java
│ │ │ ├── [9.4K] PrintMessageByQueueCommand.java
│ │ │ ├── [6.7K] PrintMessageSubCommand.java
│ │ │ ├── [ 10K] QueryMsgByIdSubCommand.java
│ │ │ ├── [3.2K] QueryMsgByKeySubCommand.java
│ │ │ ├── [4.1K] QueryMsgByOffsetSubCommand.java
│ │ │ ├── [8.2K] QueryMsgByUniqueKeySubCommand.java
│ │ │ ├── [6.3K] QueryMsgTraceByIdSubCommand.java
│ │ │ └── [5.9K] SendMessageCommand.java
│ │ ├── [ 13K] MQAdminStartup.java
│ │ ├── [4.0K] namesrv
│ │ │ ├── [3.2K] AddWritePermSubCommand.java
│ │ │ ├── [2.6K] DeleteKvConfigCommand.java
│ │ │ ├── [3.1K] GetNamesrvConfigCommand.java
│ │ │ ├── [2.9K] UpdateKvConfigCommand.java
│ │ │ ├── [3.3K] UpdateNamesrvConfigCommand.java
│ │ │ └── [3.2K] WipeWritePermSubCommand.java
│ │ ├── [4.0K] offset
│ │ │ ├── [4.2K] CloneGroupOffsetCommand.java
│ │ │ ├── [4.0K] GetConsumerStatusCommand.java
│ │ │ ├── [5.2K] ResetOffsetByTimeCommand.java
│ │ │ ├── [5.4K] ResetOffsetByTimeOldCommand.java
│ │ │ └── [5.2K] SkipAccumulationSubCommand.java
│ │ ├── [4.0K] producer
│ │ │ └── [3.5K] ProducerSubCommand.java
│ │ ├── [4.0K] queue
│ │ │ └── [6.2K] QueryConsumeQueueCommand.java
│ │ ├── [4.0K] stats
│ │ │ └── [7.6K] StatsAllSubCommand.java
│ │ ├── [1.2K] SubCommandException.java
│ │ ├── [1.3K] SubCommand.java
│ │ └── [4.0K] topic
│ │ ├── [3.7K] AllocateMQSubCommand.java
│ │ ├── [3.9K] DeleteTopicSubCommand.java
│ │ ├── [1.3K] RebalanceResult.java
│ │ ├── [2.5K] TopicClusterSubCommand.java
│ │ ├── [5.5K] TopicListSubCommand.java
│ │ ├── [4.5K] TopicRouteSubCommand.java
│ │ ├── [3.7K] TopicStatusSubCommand.java
│ │ ├── [4.1K] UpdateOrderConfCommand.java
│ │ ├── [7.1K] UpdateTopicPermSubCommand.java
│ │ └── [7.5K] UpdateTopicSubCommand.java
│ └── [4.0K] monitor
│ ├── [3.3K] DefaultMonitorListener.java
│ ├── [1.6K] DeleteMsgsEvent.java
│ ├── [1.7K] FailedMsgs.java
│ ├── [1.4K] MonitorConfig.java
│ ├── [1.3K] MonitorListener.java
│ ├── [ 13K] MonitorService.java
│ └── [2.3K] UndoneMsgs.java
└── [4.0K] test
└── [4.0K] java
└── [4.0K] org
└── [4.0K] apache
└── [4.0K] rocketmq
└── [4.0K] tools
├── [4.0K] admin
│ └── [ 25K] DefaultMQAdminExtTest.java
├── [4.0K] command
│ ├── [4.0K] acl
│ │ ├── [1.7K] ClusterAclConfigVersionListSubCommandTest.java
│ │ ├── [1.7K] DeleteAccessConfigSubCommandTest.java
│ │ ├── [1.6K] GetAccessConfigSubCommandTest.java
│ │ ├── [3.8K] UpdateAccessConfigSubCommandTest.java
│ │ └── [1.8K] UpdateGlobalWhiteAddrSubCommandTest.java
│ ├── [4.0K] broker
│ │ ├── [4.7K] BrokerConsumeStatsSubCommadTest.java
│ │ ├── [2.2K] BrokerStatusSubCommandTest.java
│ │ ├── [1.9K] CleanExpiredCQSubCommandTest.java
│ │ ├── [1.9K] CleanUnusedTopicCommandTest.java
│ │ ├── [2.8K] DeleteExpiredCommitLogSubCommandTest.java
│ │ ├── [2.5K] GetBrokerConfigCommandTest.java
│ │ ├── [3.7K] SendMsgStatusCommandTest.java
│ │ └── [2.0K] UpdateBrokerConfigSubCommandTest.java
│ ├── [5.4K] CommandUtilTest.java
│ ├── [4.0K] connection
│ │ ├── [3.0K] ConsumerConnectionSubCommandTest.java
│ │ └── [3.0K] ProducerConnectionSubCommandTest.java
│ ├── [4.0K] consumer
│ │ ├── [3.3K] ConsumerProgressSubCommandTest.java
│ │ ├── [3.0K] ConsumerStatusSubCommandTest.java
│ │ └── [4.2K] GetConsumerConfigSubCommandTest.java
│ ├── [4.0K] message
│ │ ├── [8.7K] ConsumeMessageCommandTest.java
│ │ ├── [ 12K] QueryMsgByUniqueKeySubCommandTest.java
│ │ ├── [5.0K] QueryMsgTraceByIdSubCommandTest.java
│ │ └── [4.1K] SendMessageCommandTest.java
│ ├── [4.0K] namesrv
│ │ ├── [2.7K] AddWritePermSubCommandTest.java
│ │ ├── [2.4K] GetNamesrvConfigCommandTest.java
│ │ ├── [2.5K] UpdateKvConfigCommandTest.java
│ │ └── [2.8K] WipeWritePermSubCommandTest.java
│ ├── [4.0K] offset
│ │ ├── [2.7K] GetConsumerStatusCommandTest.java
│ │ ├── [2.6K] ResetOffsetByTimeCommandTest.java
│ │ ├── [1.9K] ResetOffsetByTimeOldCommandTest.java
│ │ └── [3.4K] SkipAccumulationCommandTest.java
│ ├── [4.0K] producer
│ │ └── [3.3K] ProducerSubCommandTest.java
│ ├── [4.0K] server
│ │ ├── [2.6K] NameServerMocker.java
│ │ └── [5.6K] ServerResponseMocker.java
│ └── [4.0K] topic
│ ├── [1.7K] AllocateMQSubCommandTest.java
│ ├── [1.7K] DeleteTopicSubCommandTest.java
│ ├── [1.6K] TopicClusterSubCommandTest.java
│ ├── [1.6K] TopicRouteSubCommandTest.java
│ ├── [1.6K] TopicStatusSubCommandTest.java
│ ├── [1.8K] UpdateOrderConfCommandTest.java
│ ├── [1.9K] UpdateTopicPermSubCommandTest.java
│ └── [2.3K] UpdateTopicSubCommandTest.java
└── [4.0K] monitor
├── [3.4K] DefaultMonitorListenerTest.java
└── [9.2K] MonitorServiceTest.java
480 directories, 1274 files
备注
1. 建议优先通过来源进行访问。
2. 如果因为来源失效或无法访问，请发送邮件到 f.jinxu#gmail.com 索取本地快照（把 # 换成 @）。
3. 神龙已为您对 POC 代码进行快照，为了长期维护，请考虑为本地 POC 付费/捐赠，感谢您的支持。