关联漏洞
介绍
## Apache RocketMQ
[![Build Status][maven-build-image]][maven-build-url]
[![CodeCov][codecov-image]][codecov-url]
[![Maven Central][maven-central-image]][maven-central-url]
[![Release][release-image]][release-url]
[![License][license-image]][license-url]
[![Average Time to Resolve An Issue][percentage-of-issues-still-open-image]][pencentage-of-issues-still-open-url]
[![Percentage of Issues Still Open][average-time-to-resolve-an-issue-image]][average-time-to-resolve-an-issue-url]
[![Twitter Follow][twitter-follow-image]][twitter-follow-url]
**[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 Controller](docs/en/controller/quick_start.md)
* 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.4/rocketmq-all-4.9.4-bin-release.zip) to download the 4.9.4 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.4/rocketmq-all-4.9.4-bin-release.zip
# Unpack the release
$ unzip rocketmq-all-4.9.4-bin-release.zip
```
Prepare a terminal and change to the extracted `bin` directory:
```shell
$ cd rocketmq-4.9.4/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 APIs](https://github.com/apache/rocketmq-apis): RocketMQ protobuf protocol.
* [RocketMQ Clients](https://github.com/apache/rocketmq-clients): gRPC/protobuf-based RocketMQ clients.
* RocketMQ Remoting-based 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.
[maven-build-image]: https://github.com/apache/rocketmq/actions/workflows/maven.yaml/badge.svg
[maven-build-url]: https://github.com/apache/rocketmq/actions/workflows/maven.yaml
[codecov-image]: https://codecov.io/gh/apache/rocketmq/branch/master/graph/badge.svg
[codecov-url]: https://codecov.io/gh/apache/rocketmq
[maven-central-image]: https://maven-badges.herokuapp.com/maven-central/org.apache.rocketmq/rocketmq-all/badge.svg
[maven-central-url]: http://search.maven.org/#search%7Cga%7C1%7Corg.apache.rocketmq
[release-image]: https://img.shields.io/badge/release-download-orange.svg
[release-url]: https://www.apache.org/licenses/LICENSE-2.0.html
[license-image]: https://img.shields.io/badge/license-Apache%202-4EB1BA.svg
[license-url]: https://www.apache.org/licenses/LICENSE-2.0.html
[average-time-to-resolve-an-issue-image]: http://isitmaintained.com/badge/resolution/apache/rocketmq.svg
[average-time-to-resolve-an-issue-url]: http://isitmaintained.com/project/apache/rocketmq
[percentage-of-issues-still-open-image]: http://isitmaintained.com/badge/open/apache/rocketmq.svg
[pencentage-of-issues-still-open-url]: http://isitmaintained.com/project/apache/rocketmq
[twitter-follow-image]: https://img.shields.io/twitter/follow/ApacheRocketMQ?style=social
[twitter-follow-url]: https://twitter.com/intent/follow?screen_name=ApacheRocketMQ
文件快照
[4.0K] /data/pocs/f7662d9e54695931c2af47b3b36431a0cb434c17
├── [4.0K] acl
│ ├── [2.5K] BUILD.bazel
│ ├── [3.1K] 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.9K] AccessValidator.java
│ │ ├── [4.0K] common
│ │ │ ├── [2.6K] AclClientRPCHook.java
│ │ │ ├── [2.1K] AclConstants.java
│ │ │ ├── [1.9K] AclException.java
│ │ │ ├── [4.1K] AclSigner.java
│ │ │ ├── [ 11K] AclUtils.java
│ │ │ ├── [7.3K] AuthenticationHeader.java
│ │ │ ├── [4.2K] AuthorizationHeader.java
│ │ │ ├── [4.4K] Permission.java
│ │ │ ├── [4.9K] SessionCredentials.java
│ │ │ └── [ 920] SigningAlgorithm.java
│ │ ├── [ 950] PermissionChecker.java
│ │ └── [4.0K] plain
│ │ ├── [ 19K] PlainAccessResource.java
│ │ ├── [3.0K] PlainAccessValidator.java
│ │ ├── [3.2K] PlainPermissionChecker.java
│ │ ├── [ 32K] 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.3K] AclClientRPCHookTest.java
│ │ │ ├── [1.4K] AclSignerTest.java
│ │ │ ├── [ 11K] AclUtilsTest.java
│ │ │ ├── [7.0K] PermissionTest.java
│ │ │ └── [4.0K] SessionCredentialsTest.java
│ │ └── [4.0K] plain
│ │ ├── [4.3K] AclTestHelper.java
│ │ ├── [ 16K] PlainAccessControlFlowTest.java
│ │ ├── [ 56K] PlainAccessValidatorTest.java
│ │ ├── [ 18K] 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_bak.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.2K] plain_acl.yml
│ │ └── [4.0K] watch
│ │ └── [1009] plain_acl_watch.yml
│ ├── [4.0K] empty_acl_folder_conf
│ │ └── [4.0K] conf
│ │ └── [ 848] plain_acl.yml
│ ├── [4.0K] only_acl_folder_conf
│ │ └── [4.0K] conf
│ │ └── [4.0K] acl
│ │ └── [1.3K] plain_acl.yml
│ ├── [1.3K] rmq.logback-test.xml
│ └── [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] bazel
│ ├── [ 784] BUILD.bazel
│ └── [3.5K] GenTestRules.bzl
├── [4.0K] broker
│ ├── [3.3K] BUILD.bazel
│ ├── [3.8K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ ├── [4.0K] java
│ │ │ └── [4.0K] org
│ │ │ └── [4.0K] apache
│ │ │ └── [4.0K] rocketmq
│ │ │ └── [4.0K] broker
│ │ │ ├── [100K] BrokerController.java
│ │ │ ├── [2.9K] BrokerPathConfigHelper.java
│ │ │ ├── [ 14K] BrokerPreOnlineService.java
│ │ │ ├── [ 12K] BrokerStartup.java
│ │ │ ├── [4.0K] client
│ │ │ │ ├── [3.2K] ClientChannelInfo.java
│ │ │ │ ├── [4.2K] ClientHousekeepingService.java
│ │ │ │ ├── [1.3K] ConsumerGroupEvent.java
│ │ │ │ ├── [9.8K] ConsumerGroupInfo.java
│ │ │ │ ├── [ 989] ConsumerIdsChangeListener.java
│ │ │ │ ├── [ 15K] ConsumerManager.java
│ │ │ │ ├── [5.4K] DefaultConsumerIdsChangeListener.java
│ │ │ │ ├── [4.0K] net
│ │ │ │ │ └── [ 14K] Broker2Client.java
│ │ │ │ ├── [1.1K] ProducerChangeListener.java
│ │ │ │ ├── [1.0K] ProducerGroupEvent.java
│ │ │ │ ├── [ 12K] ProducerManager.java
│ │ │ │ └── [4.0K] rebalance
│ │ │ │ └── [ 11K] RebalanceLockManager.java
│ │ │ ├── [4.0K] controller
│ │ │ │ └── [ 24K] ReplicasManager.java
│ │ │ ├── [4.0K] dledger
│ │ │ │ └── [8.6K] DLedgerRoleChangeHandler.java
│ │ │ ├── [4.0K] failover
│ │ │ │ └── [ 19K] EscapeBridge.java
│ │ │ ├── [4.0K] filter
│ │ │ │ ├── [4.4K] CommitLogDispatcherCalcBitMap.java
│ │ │ │ ├── [4.0K] ConsumerFilterData.java
│ │ │ │ ├── [ 18K] ConsumerFilterManager.java
│ │ │ │ ├── [3.7K] ExpressionForRetryMessageFilter.java
│ │ │ │ ├── [6.1K] ExpressionMessageFilter.java
│ │ │ │ └── [1.8K] MessageEvaluationContext.java
│ │ │ ├── [4.0K] filtersrv
│ │ │ │ ├── [6.6K] FilterServerManager.java
│ │ │ │ └── [1.6K] FilterServerUtil.java
│ │ │ ├── [4.0K] latency
│ │ │ │ ├── [6.9K] BrokerFastFailure.java
│ │ │ │ ├── [2.6K] BrokerFixedThreadPoolExecutor.java
│ │ │ │ └── [1.3K] FutureTaskExt.java
│ │ │ ├── [4.0K] loadbalance
│ │ │ │ └── [3.9K] MessageRequestModeManager.java
│ │ │ ├── [4.0K] longpolling
│ │ │ │ ├── [2.8K] LmqPullRequestHoldService.java
│ │ │ │ ├── [1.7K] ManyPullRequest.java
│ │ │ │ ├── [1.8K] NotificationRequest.java
│ │ │ │ ├── [2.2K] NotifyMessageArrivingListener.java
│ │ │ │ ├── [2.8K] PopRequest.java
│ │ │ │ ├── [8.7K] PullRequestHoldService.java
│ │ │ │ └── [2.5K] PullRequest.java
│ │ │ ├── [4.0K] metrics
│ │ │ │ ├── [3.2K] BrokerMetricsConstant.java
│ │ │ │ ├── [ 27K] BrokerMetricsManager.java
│ │ │ │ ├── [1.8K] ConsumerAttr.java
│ │ │ │ ├── [ 18K] ConsumerLagCalculator.java
│ │ │ │ ├── [1.9K] PopMetricsConstant.java
│ │ │ │ ├── [ 11K] PopMetricsManager.java
│ │ │ │ ├── [ 900] PopReviveMessageType.java
│ │ │ │ └── [1.5K] ProducerAttr.java
│ │ │ ├── [4.0K] mqtrace
│ │ │ │ ├── [5.9K] ConsumeMessageContext.java
│ │ │ │ ├── [1.0K] ConsumeMessageHook.java
│ │ │ │ ├── [7.8K] SendMessageContext.java
│ │ │ │ └── [1.0K] SendMessageHook.java
│ │ │ ├── [4.0K] offset
│ │ │ │ ├── [9.5K] BroadcastOffsetManager.java
│ │ │ │ ├── [1.9K] BroadcastOffsetStore.java
│ │ │ │ ├── [ 17K] ConsumerOffsetManager.java
│ │ │ │ ├── [7.2K] ConsumerOrderInfoLockManager.java
│ │ │ │ ├── [ 23K] ConsumerOrderInfoManager.java
│ │ │ │ └── [3.8K] LmqConsumerOffsetManager.java
│ │ │ ├── [4.0K] out
│ │ │ │ └── [ 65K] BrokerOuterAPI.java
│ │ │ ├── [4.0K] pagecache
│ │ │ │ ├── [3.3K] ManyMessageTransfer.java
│ │ │ │ ├── [3.0K] OneMessageTransfer.java
│ │ │ │ └── [3.3K] QueryMessageTransfer.java
│ │ │ ├── [4.0K] plugin
│ │ │ │ ├── [1.8K] BrokerAttachedPlugin.java
│ │ │ │ └── [2.5K] PullMessageResultHandler.java
│ │ │ ├── [4.0K] processor
│ │ │ │ ├── [ 28K] AbstractSendMessageProcessor.java
│ │ │ │ ├── [ 13K] AckMessageProcessor.java
│ │ │ │ ├── [137K] AdminBrokerProcessor.java
│ │ │ │ ├── [ 13K] ChangeInvisibleTimeProcessor.java
│ │ │ │ ├── [ 10K] ClientManageProcessor.java
│ │ │ │ ├── [ 18K] ConsumerManageProcessor.java
│ │ │ │ ├── [ 16K] DefaultPullMessageResultHandler.java
│ │ │ │ ├── [ 15K] EndTransactionProcessor.java
│ │ │ │ ├── [1.8K] ForwardRequestProcessor.java
│ │ │ │ ├── [ 15K] NotificationProcessor.java
│ │ │ │ ├── [ 17K] PeekMessageProcessor.java
│ │ │ │ ├── [6.1K] PollingInfoProcessor.java
│ │ │ │ ├── [ 33K] PopBufferMergeService.java
│ │ │ │ ├── [6.3K] PopInflightMessageCounter.java
│ │ │ │ ├── [ 57K] PopMessageProcessor.java
│ │ │ │ ├── [ 33K] PopReviveService.java
│ │ │ │ ├── [ 44K] PullMessageProcessor.java
│ │ │ │ ├── [ 15K] QueryAssignmentProcessor.java
│ │ │ │ ├── [8.7K] QueryMessageProcessor.java
│ │ │ │ ├── [ 18K] ReplyMessageProcessor.java
│ │ │ │ ├── [1.2K] SendMessageCallback.java
│ │ │ │ └── [ 36K] SendMessageProcessor.java
│ │ │ ├── [4.0K] schedule
│ │ │ │ ├── [1.7K] DelayOffsetSerializeWrapper.java
│ │ │ │ └── [ 37K] ScheduleMessageService.java
│ │ │ ├── [1.0K] ShutdownHook.java
│ │ │ ├── [4.0K] slave
│ │ │ │ └── [ 11K] SlaveSynchronize.java
│ │ │ ├── [4.0K] subscription
│ │ │ │ ├── [1.8K] LmqSubscriptionGroupManager.java
│ │ │ │ └── [ 13K] SubscriptionGroupManager.java
│ │ │ ├── [4.0K] topic
│ │ │ │ ├── [2.0K] LmqTopicConfigManager.java
│ │ │ │ ├── [ 31K] TopicConfigManager.java
│ │ │ │ ├── [ 17K] TopicQueueMappingCleanService.java
│ │ │ │ ├── [ 11K] TopicQueueMappingManager.java
│ │ │ │ └── [ 11K] TopicRouteInfoManager.java
│ │ │ ├── [4.0K] transaction
│ │ │ │ ├── [5.2K] AbstractTransactionalMessageCheckListener.java
│ │ │ │ ├── [1.6K] OperationResult.java
│ │ │ │ ├── [4.0K] queue
│ │ │ │ │ ├── [4.2K] DefaultTransactionalMessageCheckListener.java
│ │ │ │ │ ├── [1.3K] GetResult.java
│ │ │ │ │ ├── [1.7K] MessageQueueOpContext.java
│ │ │ │ │ ├── [ 17K] TransactionalMessageBridge.java
│ │ │ │ │ ├── [ 33K] TransactionalMessageServiceImpl.java
│ │ │ │ │ ├── [3.6K] TransactionalMessageUtil.java
│ │ │ │ │ └── [2.5K] TransactionalOpBatchService.java
│ │ │ │ ├── [2.7K] TransactionalMessageCheckService.java
│ │ │ │ └── [3.5K] TransactionalMessageService.java
│ │ │ └── [4.0K] util
│ │ │ ├── [ 13K] HookUtils.java
│ │ │ └── [1.3K] PositiveAtomicCounter.java
│ │ └── [4.0K] resources
│ │ ├── [ 26K] rmq.broker.logback.xml
│ │ └── [ 902] transaction.sql
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] broker
│ │ ├── [3.5K] BrokerControllerTest.java
│ │ ├── [ 11K] BrokerOuterAPITest.java
│ │ ├── [2.0K] BrokerPathConfigHelperTest.java
│ │ ├── [2.3K] BrokerStartupTest.java
│ │ ├── [4.0K] client
│ │ │ ├── [5.8K] ConsumerManagerScannerTest.java
│ │ │ ├── [9.0K] ConsumerManagerTest.java
│ │ │ └── [7.4K] ProducerManagerTest.java
│ │ ├── [4.0K] controller
│ │ │ └── [6.9K] ReplicasManagerTest.java
│ │ ├── [4.0K] failover
│ │ │ └── [8.7K] EscapeBridgeTest.java
│ │ ├── [4.0K] filter
│ │ │ ├── [6.5K] CommitLogDispatcherCalcBitMapTest.java
│ │ │ ├── [8.8K] ConsumerFilterManagerTest.java
│ │ │ └── [ 16K] MessageStoreWithFilterTest.java
│ │ ├── [4.0K] filtersrv
│ │ │ └── [3.0K] FilterServerManagerTest.java
│ │ ├── [4.0K] latency
│ │ │ └── [2.4K] BrokerFastFailureTest.java
│ │ ├── [4.0K] longpolling
│ │ │ └── [4.5K] PullRequestHoldServiceTest.java
│ │ ├── [4.0K] offset
│ │ │ ├── [7.4K] BroadcastOffsetManagerTest.java
│ │ │ ├── [1.2K] BroadcastOffsetStoreTest.java
│ │ │ ├── [3.1K] ConsumerOffsetManagerTest.java
│ │ │ ├── [5.9K] ConsumerOrderInfoManagerLockFreeNotifyTest.java
│ │ │ ├── [ 19K] ConsumerOrderInfoManagerTest.java
│ │ │ └── [4.7K] LmqConsumerOffsetManagerTest.java
│ │ ├── [4.0K] pagecache
│ │ │ ├── [2.5K] ManyMessageTransferTest.java
│ │ │ └── [2.3K] OneMessageTransferTest.java
│ │ ├── [4.0K] processor
│ │ │ ├── [6.2K] AckMessageProcessorTest.java
│ │ │ ├── [ 31K] AdminBrokerProcessorTest.java
│ │ │ ├── [6.5K] ChangeInvisibleTimeProcessorTest.java
│ │ │ ├── [6.0K] ClientManageProcessorTest.java
│ │ │ ├── [4.1K] ConsumerManageProcessorTest.java
│ │ │ ├── [7.3K] EndTransactionProcessorTest.java
│ │ │ ├── [5.5K] PopBufferMergeServiceTest.java
│ │ │ ├── [4.5K] PopInflightMessageCounterTest.java
│ │ │ ├── [8.1K] PopMessageProcessorTest.java
│ │ │ ├── [ 13K] PopReviveServiceTest.java
│ │ │ ├── [ 15K] PullMessageProcessorTest.java
│ │ │ ├── [ 10K] QueryAssignmentProcessorTest.java
│ │ │ ├── [6.6K] ReplyMessageProcessorTest.java
│ │ │ └── [ 18K] SendMessageProcessorTest.java
│ │ ├── [4.0K] schedule
│ │ │ └── [ 12K] ScheduleMessageServiceTest.java
│ │ ├── [4.0K] substription
│ │ │ └── [2.6K] ForbiddenTest.java
│ │ ├── [4.0K] topic
│ │ │ ├── [ 14K] TopicConfigManagerTest.java
│ │ │ └── [4.9K] TopicQueueMappingManagerTest.java
│ │ ├── [4.0K] transaction
│ │ │ └── [4.0K] queue
│ │ │ ├── [4.6K] DefaultTransactionalMessageCheckListenerTest.java
│ │ │ ├── [9.7K] TransactionalMessageBridgeTest.java
│ │ │ ├── [ 12K] TransactionalMessageServiceImplTest.java
│ │ │ └── [2.7K] TransactionalMessageUtilTest.java
│ │ └── [4.0K] util
│ │ ├── [3.6K] HookUtilsTest.java
│ │ ├── [1.1K] LogTransactionalMessageCheckListener.java
│ │ ├── [1.9K] ServiceProviderTest.java
│ │ └── [2.6K] TransactionalMessageServiceImpl.java
│ └── [4.0K] resources
│ ├── [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
│ └── [1.3K] rmq.logback-test.xml
├── [2.0K] BUILD.bazel
├── [ 997] BUILDING
├── [4.0K] client
│ ├── [2.3K] BUILD.bazel
│ ├── [2.6K] 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
│ │ │ ├── [ 14K] ClientConfig.java
│ │ │ ├── [4.0K] common
│ │ │ │ ├── [1.3K] ClientErrorCode.java
│ │ │ │ └── [1.5K] ThreadLocalIndex.java
│ │ │ ├── [4.0K] consumer
│ │ │ │ ├── [ 970] AckCallback.java
│ │ │ │ ├── [1.5K] AckResult.java
│ │ │ │ ├── [ 968] AckStatus.java
│ │ │ │ ├── [1.6K] AllocateMessageQueueStrategy.java
│ │ │ │ ├── [ 20K] DefaultLitePullConsumer.java
│ │ │ │ ├── [ 18K] DefaultMQPullConsumer.java
│ │ │ │ ├── [ 35K] 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
│ │ │ │ ├── [9.9K] LitePullConsumer.java
│ │ │ │ ├── [1.4K] MessageQueueListener.java
│ │ │ │ ├── [2.1K] MessageSelector.java
│ │ │ │ ├── [2.1K] MQConsumer.java
│ │ │ │ ├── [7.0K] MQPullConsumer.java
│ │ │ │ ├── [8.4K] MQPullConsumerScheduleService.java
│ │ │ │ ├── [3.6K] MQPushConsumer.java
│ │ │ │ ├── [1009] PopCallback.java
│ │ │ │ ├── [2.3K] PopResult.java
│ │ │ │ ├── [1.2K] PopStatus.java
│ │ │ │ ├── [1016] PullCallback.java
│ │ │ │ ├── [2.2K] PullResult.java
│ │ │ │ ├── [1.1K] PullStatus.java
│ │ │ │ ├── [1018] PullTaskCallback.java
│ │ │ │ ├── [1.4K] PullTaskContext.java
│ │ │ │ ├── [4.0K] rebalance
│ │ │ │ │ ├── [2.2K] AbstractAllocateMessageQueueStrategy.java
│ │ │ │ │ ├── [5.7K] 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.5K] OffsetSerializeWrapper.java
│ │ │ │ │ ├── [2.3K] OffsetStore.java
│ │ │ │ │ ├── [1.1K] ReadOffsetType.java
│ │ │ │ │ └── [ 10K] RemoteBrokerOffsetStore.java
│ │ │ │ └── [1.2K] TopicMessageQueueChangeListener.java
│ │ │ ├── [4.0K] exception
│ │ │ │ ├── [2.2K] MQBrokerException.java
│ │ │ │ ├── [2.3K] MQClientException.java
│ │ │ │ ├── [1.2K] OffsetNotFoundException.java
│ │ │ │ └── [1.9K] RequestTimeoutException.java
│ │ │ ├── [4.0K] hook
│ │ │ │ ├── [3.4K] CheckForbiddenContext.java
│ │ │ │ ├── [1.0K] CheckForbiddenHook.java
│ │ │ │ ├── [2.5K] 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
│ │ │ │ ├── [1.4K] BaseInvokeCallback.java
│ │ │ │ ├── [ 15K] ClientRemotingProcessor.java
│ │ │ │ ├── [ 911] CommunicationMode.java
│ │ │ │ ├── [4.0K] consumer
│ │ │ │ │ ├── [9.0K] AssignedMessageQueue.java
│ │ │ │ │ ├── [ 20K] ConsumeMessageConcurrentlyService.java
│ │ │ │ │ ├── [ 27K] ConsumeMessageOrderlyService.java
│ │ │ │ │ ├── [ 20K] ConsumeMessagePopConcurrentlyService.java
│ │ │ │ │ ├── [ 16K] ConsumeMessagePopOrderlyService.java
│ │ │ │ │ ├── [1.7K] ConsumeMessageService.java
│ │ │ │ │ ├── [ 54K] DefaultLitePullConsumerImpl.java
│ │ │ │ │ ├── [ 35K] DefaultMQPullConsumerImpl.java
│ │ │ │ │ ├── [ 72K] DefaultMQPushConsumerImpl.java
│ │ │ │ │ ├── [2.1K] MessageQueueLock.java
│ │ │ │ │ ├── [1000] MessageRequest.java
│ │ │ │ │ ├── [1.8K] MQConsumerInner.java
│ │ │ │ │ ├── [2.6K] PopProcessQueue.java
│ │ │ │ │ ├── [3.8K] PopRequest.java
│ │ │ │ │ ├── [ 16K] ProcessQueue.java
│ │ │ │ │ ├── [ 17K] PullAPIWrapper.java
│ │ │ │ │ ├── [6.0K] PullMessageService.java
│ │ │ │ │ ├── [3.4K] PullRequest.java
│ │ │ │ │ ├── [2.3K] PullResultExt.java
│ │ │ │ │ ├── [ 36K] RebalanceImpl.java
│ │ │ │ │ ├── [7.3K] RebalanceLitePullImpl.java
│ │ │ │ │ ├── [3.9K] RebalancePullImpl.java
│ │ │ │ │ ├── [ 13K] RebalancePushImpl.java
│ │ │ │ │ └── [1.9K] RebalanceService.java
│ │ │ │ ├── [4.0K] factory
│ │ │ │ │ └── [ 53K] MQClientInstance.java
│ │ │ │ ├── [1.5K] FindBrokerResult.java
│ │ │ │ ├── [ 23K] MQAdminImpl.java
│ │ │ │ ├── [154K] MQClientAPIImpl.java
│ │ │ │ ├── [2.8K] MQClientManager.java
│ │ │ │ └── [4.0K] producer
│ │ │ │ ├── [ 76K] DefaultMQProducerImpl.java
│ │ │ │ ├── [1.6K] MQProducerInner.java
│ │ │ │ └── [4.0K] TopicPublishInfo.java
│ │ │ ├── [4.0K] latency
│ │ │ │ ├── [6.1K] LatencyFaultToleranceImpl.java
│ │ │ │ ├── [1.1K] LatencyFaultTolerance.java
│ │ │ │ └── [4.2K] MQFaultStrategy.java
│ │ │ ├── [3.7K] MQAdmin.java
│ │ │ ├── [3.2K] MQHelper.java
│ │ │ ├── [4.0K] producer
│ │ │ │ ├── [ 48K] 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
│ │ │ │ ├── [4.0K] 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.9K] ConsumerStatsManager.java
│ │ │ ├── [4.0K] trace
│ │ │ │ ├── [ 18K] AsyncTraceDispatcher.java
│ │ │ │ ├── [4.0K] hook
│ │ │ │ │ ├── [3.8K] ConsumeMessageOpenTracingHookImpl.java
│ │ │ │ │ ├── [5.1K] 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.6K] 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
│ │ │ └── [5.2K] Validators.java
│ │ └── [4.0K] resources
│ │ └── [2.8K] rmq.client.logback.xml
│ └── [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
│ │ │ ├── [ 42K] DefaultLitePullConsumerTest.java
│ │ │ ├── [7.4K] DefaultMQPullConsumerTest.java
│ │ │ ├── [ 19K] DefaultMQPushConsumerTest.java
│ │ │ ├── [4.0K] rebalance
│ │ │ │ ├── [8.3K] AllocateMachineRoomNearByTest.java
│ │ │ │ ├── [3.0K] AllocateMessageQueueAveragelyByCircleTest.java
│ │ │ │ ├── [2.2K] AllocateMessageQueueAveragelyTest.java
│ │ │ │ ├── [2.7K] AllocateMessageQueueByConfigTest.java
│ │ │ │ ├── [3.4K] AllocateMessageQueueByMachineRoomTest.java
│ │ │ │ └── [8.9K] AllocateMessageQueueConsitentHashTest.java
│ │ │ └── [4.0K] store
│ │ │ ├── [3.8K] LocalFileOffsetStoreTest.java
│ │ │ └── [7.2K] RemoteBrokerOffsetStoreTest.java
│ │ ├── [4.0K] impl
│ │ │ ├── [4.0K] consumer
│ │ │ │ ├── [ 13K] ConsumeMessageConcurrentlyServiceTest.java
│ │ │ │ ├── [ 13K] ConsumeMessageOrderlyServiceTest.java
│ │ │ │ ├── [4.9K] DefaultMQPushConsumerImplTest.java
│ │ │ │ ├── [4.0K] ProcessQueueTest.java
│ │ │ │ ├── [4.9K] RebalanceLitePullImplTest.java
│ │ │ │ └── [ 12K] RebalancePushImplTest.java
│ │ │ ├── [4.0K] factory
│ │ │ │ └── [8.1K] MQClientInstanceTest.java
│ │ │ └── [ 46K] MQClientAPIImplTest.java
│ │ ├── [4.0K] latency
│ │ │ └── [2.6K] LatencyFaultToleranceImplTest.java
│ │ ├── [4.0K] producer
│ │ │ ├── [ 24K] 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.8K] DefaultMQProducerWithOpenTracingTest.java
│ │ │ ├── [9.9K] DefaultMQProducerWithTraceTest.java
│ │ │ ├── [ 12K] TraceDataEncoderTest.java
│ │ │ ├── [2.8K] TraceViewTest.java
│ │ │ ├── [9.0K] TransactionMQProducerWithOpenTracingTest.java
│ │ │ └── [9.8K] TransactionMQProducerWithTraceTest.java
│ │ ├── [4.0K] utils
│ │ │ └── [3.4K] MessageUtilsTest.java
│ │ └── [7.2K] ValidatorsTest.java
│ └── [4.0K] resources
│ ├── [4.0K] org
│ │ └── [4.0K] powermock
│ │ └── [4.0K] extensions
│ │ └── [ 824] configuration.properties
│ └── [1.3K] rmq.logback-test.xml
├── [4.0K] common
│ ├── [2.9K] BUILD.bazel
│ ├── [3.8K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ ├── [4.0K] java
│ │ │ └── [4.0K] org
│ │ │ └── [4.0K] apache
│ │ │ └── [4.0K] rocketmq
│ │ │ └── [4.0K] common
│ │ │ ├── [2.7K] AbortProcessException.java
│ │ │ ├── [1.6K] AbstractBrokerRunnable.java
│ │ │ ├── [1.6K] AclConfig.java
│ │ │ ├── [4.0K] annotation
│ │ │ │ └── [1.2K] ImportantField.java
│ │ │ ├── [4.0K] attribute
│ │ │ │ ├── [1.4K] Attribute.java
│ │ │ │ ├── [3.1K] AttributeParser.java
│ │ │ │ ├── [1.5K] BooleanAttribute.java
│ │ │ │ ├── [ 911] CleanupPolicy.java
│ │ │ │ ├── [ 899] CQType.java
│ │ │ │ ├── [1.5K] EnumAttribute.java
│ │ │ │ ├── [1.5K] LongRangeAttribute.java
│ │ │ │ └── [2.3K] TopicMessageType.java
│ │ │ ├── [2.3K] BrokerAddrInfo.java
│ │ │ ├── [ 50K] BrokerConfig.java
│ │ │ ├── [1.5K] BrokerConfigSingleton.java
│ │ │ ├── [4.8K] BrokerIdentity.java
│ │ │ ├── [4.0K] compression
│ │ │ │ ├── [2.9K] CompressionType.java
│ │ │ │ ├── [1.4K] CompressorFactory.java
│ │ │ │ ├── [1.4K] Compressor.java
│ │ │ │ ├── [3.2K] Lz4Compressor.java
│ │ │ │ ├── [3.6K] ZlibCompressor.java
│ │ │ │ └── [3.2K] ZstdCompressor.java
│ │ │ ├── [3.1K] ConfigManager.java
│ │ │ ├── [4.0K] consistenthash
│ │ │ │ ├── [4.7K] ConsistentHashRouter.java
│ │ │ │ ├── [ 952] HashFunction.java
│ │ │ │ ├── [1.0K] Node.java
│ │ │ │ └── [1.4K] VirtualNode.java
│ │ │ ├── [4.0K] constant
│ │ │ │ ├── [ 955] ConsumeInitMode.java
│ │ │ │ ├── [ 950] DBMsgConstants.java
│ │ │ │ ├── [3.2K] LoggerName.java
│ │ │ │ └── [2.4K] PermName.java
│ │ │ ├── [4.0K] consumer
│ │ │ │ ├── [1.1K] ConsumeFromWhere.java
│ │ │ │ └── [8.1K] ReceiptHandle.java
│ │ │ ├── [5.2K] ControllerConfig.java
│ │ │ ├── [6.7K] CountDownLatch2.java
│ │ │ ├── [4.0K] fastjson
│ │ │ │ └── [2.4K] GenericMapSuperclassDeserializer.java
│ │ │ ├── [4.0K] filter
│ │ │ │ ├── [2.3K] ExpressionType.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] future
│ │ │ │ └── [1.3K] FutureTaskExt.java
│ │ │ ├── [4.0K] help
│ │ │ │ └── [3.4K] FAQUrl.java
│ │ │ ├── [4.0K] hook
│ │ │ │ └── [1019] FilterCheckHook.java
│ │ │ ├── [1.6K] KeyBuilder.java
│ │ │ ├── [1.9K] LifecycleAwareServiceThread.java
│ │ │ ├── [1.0K] LockCallback.java
│ │ │ ├── [4.0K] logging
│ │ │ │ ├── [7.0K] DefaultJoranConfiguratorExt.java
│ │ │ │ └── [2.9K] JoranConfiguratorExt.java
│ │ │ ├── [4.0K] message
│ │ │ │ ├── [3.7K] MessageAccessor.java
│ │ │ │ ├── [2.9K] MessageBatch.java
│ │ │ │ ├── [1.4K] MessageClientExt.java
│ │ │ │ ├── [5.3K] MessageClientIDSetter.java
│ │ │ │ ├── [8.7K] MessageConst.java
│ │ │ │ ├── [ 28K] MessageDecoder.java
│ │ │ │ ├── [1.6K] MessageExtBatch.java
│ │ │ │ ├── [2.2K] MessageExtBrokerInner.java
│ │ │ │ ├── [9.4K] MessageExt.java
│ │ │ │ ├── [1.4K] MessageId.java
│ │ │ │ ├── [6.5K] Message.java
│ │ │ │ ├── [2.5K] MessageQueueAssignment.java
│ │ │ │ ├── [3.8K] MessageQueueForC.java
│ │ │ │ ├── [3.5K] MessageQueue.java
│ │ │ │ ├── [1.2K] MessageRequestMode.java
│ │ │ │ ├── [1.4K] MessageType.java
│ │ │ │ └── [2.8K] MessageVersion.java
│ │ │ ├── [4.0K] metrics
│ │ │ │ ├── [1.2K] NopLongCounter.java
│ │ │ │ ├── [1.2K] NopLongHistogram.java
│ │ │ │ ├── [1.2K] NopLongUpDownCounter.java
│ │ │ │ └── [ 976] NopObservableLongGauge.java
│ │ │ ├── [ 20K] MixAll.java
│ │ │ ├── [ 14K] MQVersion.java
│ │ │ ├── [4.0K] namesrv
│ │ │ │ ├── [5.7K] DefaultTopAddressing.java
│ │ │ │ ├── [ 954] NameServerUpdateCallback.java
│ │ │ │ ├── [7.7K] NamesrvConfig.java
│ │ │ │ ├── [ 961] NamesrvUtil.java
│ │ │ │ └── [ 985] TopAddressing.java
│ │ │ ├── [1.3K] Pair.java
│ │ │ ├── [3.0K] PlainAccessConfig.java
│ │ │ ├── [1.7K] PopAckConstants.java
│ │ │ ├── [4.0K] queue
│ │ │ │ ├── [2.3K] ConcurrentTreeMap.java
│ │ │ │ └── [1.4K] RoundQueue.java
│ │ │ ├── [4.0K] running
│ │ │ │ └── [1002] RunningStats.java
│ │ │ ├── [1.1K] ServiceState.java
│ │ │ ├── [4.8K] ServiceThread.java
│ │ │ ├── [4.0K] statistics
│ │ │ │ ├── [1.9K] FutureHolder.java
│ │ │ │ ├── [1.0K] Interceptor.java
│ │ │ │ ├── [2.6K] StatisticsBriefInterceptor.java
│ │ │ │ ├── [5.2K] StatisticsBrief.java
│ │ │ │ ├── [1.4K] StatisticsItemFormatter.java
│ │ │ │ ├── [5.1K] StatisticsItem.java
│ │ │ │ ├── [1.8K] StatisticsItemPrinter.java
│ │ │ │ ├── [ 10K] StatisticsItemScheduledIncrementPrinter.java
│ │ │ │ ├── [3.0K] StatisticsItemScheduledPrinter.java
│ │ │ │ ├── [ 938] StatisticsItemStateGetter.java
│ │ │ │ ├── [1.5K] StatisticsKindMeta.java
│ │ │ │ └── [5.6K] StatisticsManager.java
│ │ │ ├── [4.0K] stats
│ │ │ │ ├── [2.5K] MomentStatsItem.java
│ │ │ │ ├── [4.1K] MomentStatsItemSet.java
│ │ │ │ ├── [1.7K] RTStatsItem.java
│ │ │ │ ├── [8.3K] StatsItem.java
│ │ │ │ ├── [9.1K] StatsItemSet.java
│ │ │ │ ├── [2.7K] Stats.java
│ │ │ │ └── [1.5K] StatsSnapshot.java
│ │ │ ├── [4.0K] sysflag
│ │ │ │ ├── [3.3K] MessageSysFlag.java
│ │ │ │ ├── [3.0K] PullSysFlag.java
│ │ │ │ ├── [1.5K] SubscriptionSysFlag.java
│ │ │ │ └── [1.9K] TopicSysFlag.java
│ │ │ ├── [ 941] SystemClock.java
│ │ │ ├── [4.0K] thread
│ │ │ │ ├── [1.7K] FutureTaskExtThreadPoolExecutor.java
│ │ │ │ ├── [5.6K] ThreadPoolMonitor.java
│ │ │ │ ├── [1.4K] ThreadPoolQueueSizeMonitor.java
│ │ │ │ ├── [1.1K] ThreadPoolStatusMonitor.java
│ │ │ │ └── [4.2K] ThreadPoolWrapper.java
│ │ │ ├── [2.6K] ThreadFactoryImpl.java
│ │ │ ├── [4.0K] topic
│ │ │ │ └── [5.8K] TopicValidator.java
│ │ │ ├── [2.0K] TopicAttributes.java
│ │ │ ├── [8.5K] TopicConfig.java
│ │ │ ├── [ 902] TopicFilterType.java
│ │ │ ├── [1.8K] TopicQueueId.java
│ │ │ ├── [ 939] UnlockCallback.java
│ │ │ ├── [ 26K] UtilAll.java
│ │ │ └── [4.0K] utils
│ │ │ ├── [1.7K] BinaryUtil.java
│ │ │ ├── [1.3K] ChannelUtil.java
│ │ │ ├── [5.2K] CheckpointFile.java
│ │ │ ├── [2.1K] CleanupPolicyUtils.java
│ │ │ ├── [1.9K] ConcurrentHashMapUtils.java
│ │ │ ├── [1005] CorrelationIdUtil.java
│ │ │ ├── [1.4K] DataConverter.java
│ │ │ ├── [2.6K] FastJsonSerializer.java
│ │ │ ├── [5.0K] HttpTinyClient.java
│ │ │ ├── [4.9K] IOTinyUtils.java
│ │ │ ├── [1.9K] MessageUtils.java
│ │ │ ├── [2.2K] NameServerAddressUtils.java
│ │ │ ├── [6.6K] NetworkUtil.java
│ │ │ ├── [1.3K] PositiveAtomicCounter.java
│ │ │ ├── [2.0K] QueueTypeUtils.java
│ │ │ ├── [1.2K] Serializer.java
│ │ │ ├── [8.3K] ServiceProvider.java
│ │ │ └── [6.8K] ThreadUtils.java
│ │ └── [4.0K] resources
│ │ └── [4.0K] META-INF
│ │ └── [4.0K] services
│ │ └── [ 62] org.apache.rocketmq.logging.ch.qos.logback.classic.spi.Configurator
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] common
│ │ ├── [4.0K] attribute
│ │ │ ├── [2.8K] AttributeParserTest.java
│ │ │ └── [3.2K] AttributeTest.java
│ │ ├── [2.2K] BrokerConfigTest.java
│ │ ├── [4.0K] compression
│ │ │ └── [4.4K] CompressionTest.java
│ │ ├── [3.6K] ConfigManagerTest.java
│ │ ├── [3.8K] CountDownLatch2Test.java
│ │ ├── [4.0K] message
│ │ │ ├── [2.4K] MessageClientIDSetterTest.java
│ │ │ ├── [ 17K] MessageDecoderTest.java
│ │ │ └── [2.2K] MessageTest.java
│ │ ├── [2.6K] MessageBatchTest.java
│ │ ├── [2.9K] MessageEncodeDecodeTest.java
│ │ ├── [3.4K] MixAllTest.java
│ │ ├── [1.7K] MQVersionTest.java
│ │ ├── [1.7K] NetworkUtilTest.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
│ │ │ └── [4.1K] TopicValidatorTest.java
│ │ ├── [2.9K] TopicConfigTest.java
│ │ ├── [7.5K] UtilAllTest.java
│ │ └── [4.0K] utils
│ │ ├── [1.5K] ConcurrentHashMapUtilsTest.java
│ │ ├── [5.5K] IOTinyUtilsTest.java
│ │ └── [2.6K] NameServerAddressUtilsTest.java
│ └── [4.0K] resources
│ └── [1.3K] rmq.logback-test.xml
├── [4.0K] container
│ ├── [2.9K] BUILD.bazel
│ ├── [1.6K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] container
│ │ ├── [1.6K] BrokerBootHook.java
│ │ ├── [2.7K] BrokerContainerConfig.java
│ │ ├── [ 21K] BrokerContainer.java
│ │ ├── [ 12K] BrokerContainerProcessor.java
│ │ ├── [ 18K] BrokerContainerStartup.java
│ │ ├── [3.8K] ContainerClientHouseKeepingService.java
│ │ ├── [4.2K] IBrokerContainer.java
│ │ ├── [6.8K] InnerBrokerController.java
│ │ ├── [1.8K] InnerSalveBrokerController.java
│ │ └── [4.0K] logback
│ │ └── [1.7K] BrokerLogbackConfigurator.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] container
│ │ ├── [5.6K] BrokerContainerStartupTest.java
│ │ ├── [ 17K] BrokerContainerTest.java
│ │ └── [4.1K] BrokerPreOnlineTest.java
│ └── [4.0K] resources
│ └── [1.3K] rmq.logback-test.xml
├── [2.8K] CONTRIBUTING.md
├── [4.0K] controller
│ ├── [2.7K] BUILD.bazel
│ ├── [2.4K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ ├── [4.0K] java
│ │ │ └── [4.0K] org
│ │ │ └── [4.0K] apache
│ │ │ └── [4.0K] rocketmq
│ │ │ └── [4.0K] controller
│ │ │ ├── [2.1K] BrokerHeartbeatManager.java
│ │ │ ├── [2.0K] BrokerHousekeepingService.java
│ │ │ ├── [4.4K] BrokerLiveInfo.java
│ │ │ ├── [3.9K] Controller.java
│ │ │ ├── [ 13K] ControllerManager.java
│ │ │ ├── [6.0K] ControllerStartup.java
│ │ │ ├── [4.0K] elect
│ │ │ │ ├── [1.4K] ElectPolicy.java
│ │ │ │ └── [4.0K] impl
│ │ │ │ └── [5.8K] DefaultElectPolicy.java
│ │ │ ├── [4.0K] impl
│ │ │ │ ├── [8.2K] DefaultBrokerHeartbeatManager.java
│ │ │ │ ├── [ 21K] DLedgerController.java
│ │ │ │ ├── [3.2K] DLedgerControllerStateMachine.java
│ │ │ │ ├── [4.0K] event
│ │ │ │ │ ├── [1.8K] AlterSyncStateSetEvent.java
│ │ │ │ │ ├── [1.9K] ApplyBrokerIdEvent.java
│ │ │ │ │ ├── [1.9K] CleanBrokerDataEvent.java
│ │ │ │ │ ├── [2.4K] ControllerResult.java
│ │ │ │ │ ├── [2.5K] ElectMasterEvent.java
│ │ │ │ │ ├── [1.0K] EventMessage.java
│ │ │ │ │ ├── [3.1K] EventSerializer.java
│ │ │ │ │ └── [1.9K] EventType.java
│ │ │ │ └── [4.0K] manager
│ │ │ │ ├── [2.4K] BrokerInfo.java
│ │ │ │ ├── [ 27K] ReplicasInfoManager.java
│ │ │ │ └── [2.5K] SyncStateInfo.java
│ │ │ └── [4.0K] processor
│ │ │ └── [ 13K] ControllerRequestProcessor.java
│ │ └── [4.0K] resources
│ │ └── [4.9K] rmq.controller.logback.xml
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] controller
│ │ └── [4.0K] impl
│ │ └── [4.0K] controller
│ │ ├── [9.5K] ControllerManagerTest.java
│ │ └── [4.0K] impl
│ │ ├── [2.1K] DefaultBrokerHeartbeatManagerTest.java
│ │ ├── [ 16K] DLedgerControllerTest.java
│ │ └── [4.0K] manager
│ │ └── [ 20K] ReplicasInfoManagerTest.java
│ └── [4.0K] resources
│ └── [1.3K] rmq.logback-test.xml
├── [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] controller
│ │ │ ├── [2.0K] fast-try.cmd
│ │ │ ├── [2.2K] fast-try-independent-deployment.cmd
│ │ │ ├── [2.2K] fast-try-independent-deployment.sh
│ │ │ ├── [2.2K] fast-try-namesrv-plugin.cmd
│ │ │ ├── [2.2K] fast-try-namesrv-plugin.sh
│ │ │ └── [2.9K] fast-try.sh
│ │ ├── [4.0K] dledger
│ │ │ └── [2.8K] fast-try.sh
│ │ ├── [2.5K] export.sh
│ │ ├── [1.4K] mqadmin
│ │ ├── [1.1K] mqadmin.cmd
│ │ ├── [2.2K] mqbroker
│ │ ├── [1.1K] mqbroker.cmd
│ │ ├── [1.4K] mqbrokercontainer
│ │ ├── [1.3K] mqbroker.numanode0
│ │ ├── [1.3K] mqbroker.numanode1
│ │ ├── [1.3K] mqbroker.numanode2
│ │ ├── [1.3K] mqbroker.numanode3
│ │ ├── [1.4K] mqcontroller
│ │ ├── [1.1K] mqcontroller.cmd
│ │ ├── [1.4K] mqnamesrv
│ │ ├── [1.1K] mqnamesrv.cmd
│ │ ├── [1.4K] mqproxy
│ │ ├── [1.1K] mqproxy.cmd
│ │ ├── [3.0K] mqshutdown
│ │ ├── [1.6K] mqshutdown.cmd
│ │ ├── [2.2K] os.sh
│ │ ├── [1.1K] play.cmd
│ │ ├── [1008] play.sh
│ │ ├── [ 772] README.md
│ │ ├── [2.2K] runbroker.cmd
│ │ ├── [4.7K] runbroker.sh
│ │ ├── [1.8K] runserver.cmd
│ │ ├── [4.2K] 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] container
│ │ │ └── [4.0K] 2container-2m-2s
│ │ │ ├── [1.2K] broker-a-in-container1.conf
│ │ │ ├── [1.2K] broker-a-in-container2.conf
│ │ │ ├── [1.2K] broker-b-in-container1.conf
│ │ │ ├── [1.2K] broker-b-in-container2.conf
│ │ │ ├── [1.2K] broker-container1.conf
│ │ │ ├── [1.2K] broker-container2.conf
│ │ │ └── [ 811] nameserver.conf
│ │ ├── [4.0K] controller
│ │ │ ├── [4.0K] cluster-3n-independent
│ │ │ │ ├── [ 925] controller-n0.conf
│ │ │ │ ├── [ 925] controller-n1.conf
│ │ │ │ └── [ 925] controller-n2.conf
│ │ │ ├── [4.0K] cluster-3n-namesrv-plugin
│ │ │ │ ├── [1014] namesrv-n0.conf
│ │ │ │ ├── [1014] namesrv-n1.conf
│ │ │ │ └── [1014] namesrv-n2.conf
│ │ │ ├── [ 889] controller-standalone.conf
│ │ │ └── [4.0K] quick-start
│ │ │ ├── [1.1K] broker-n0.conf
│ │ │ ├── [1.1K] broker-n1.conf
│ │ │ └── [ 920] namesrv.conf
│ │ ├── [4.0K] dledger
│ │ │ ├── [1.1K] broker-n0.conf
│ │ │ ├── [1.1K] broker-n1.conf
│ │ │ └── [1.1K] broker-n2.conf
│ │ ├── [1.3K] plain_acl.yml
│ │ ├── [ 45] rmq-proxy.json
│ │ └── [ 834] tools.yml
│ ├── [ 17K] LICENSE-BIN
│ ├── [1.3K] NOTICE-BIN
│ ├── [5.0K] pom.xml
│ ├── [2.1K] release-client.xml
│ └── [4.1K] 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
│ │ ├── [8.2K] BrokerContainer.md
│ │ ├── [4.0K] client
│ │ │ └── [4.0K] java
│ │ │ ├── [ 42K] API_Reference_DefaultMQProducer.md
│ │ │ └── [9.3K] API_Reference_ DefaultPullConsumer.md
│ │ ├── [4.5K] concept.md
│ │ ├── [2.7K] Configuration_System.md
│ │ ├── [4.3K] Configuration_TLS.md
│ │ ├── [4.0K] controller
│ │ │ ├── [ 12K] deploy.md
│ │ │ ├── [ 11K] design.md
│ │ │ └── [5.6K] quick_start.md
│ │ ├── [6.5K] Deployment.md
│ │ ├── [ 27K] design.md
│ │ ├── [4.0K] dledger
│ │ │ ├── [3.6K] deploy_guide.md
│ │ │ └── [1.9K] quick_start.md
│ │ ├── [3.2K] Example_Batch.md
│ │ ├── [1.9K] Example_Compaction_Topic_cn.md
│ │ ├── [ 836] Example_CreateTopic.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
│ │ │ ├── [4.0K] controller
│ │ │ │ ├── [418K] controller_design_1.png
│ │ │ │ ├── [170K] controller_design_2.png
│ │ │ │ ├── [ 76K] controller_design_3.png
│ │ │ │ ├── [ 55K] controller_design_4.png
│ │ │ │ ├── [117K] controller_design_5.png
│ │ │ │ ├── [ 13K] controller_design_6.png
│ │ │ │ └── [4.0K] quick-start
│ │ │ │ ├── [ 13K] changemaster.png
│ │ │ │ ├── [262K] controller.png
│ │ │ │ ├── [ 14K] epoch.png
│ │ │ │ └── [ 13K] syncstateset.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
│ │ ├── [ 70K] operation.md
│ │ ├── [4.0K] proxy
│ │ │ └── [ 879] deploy_guide.md
│ │ ├── [6.3K] QuorumACK.md
│ │ ├── [2.4K] README.md
│ │ ├── [ 39K] RocketMQ_Example.md
│ │ ├── [6.9K] rpc_request.md
│ │ ├── [ 13K] SlaveActingMasterMode.md
│ │ └── [4.0K] statictopic
│ │ ├── [ 23K] RocketMQ_Static_Topic_Logic_Queue_设计.md
│ │ └── [5.2K] The_Scope_Of_Static_Topic.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.2K] Concept.md
│ ├── [ 12K] Configuration_Client.md
│ ├── [3.0K] Configuration_System.md
│ ├── [4.4K] Configuration_TLS.md
│ ├── [4.0K] controller
│ │ ├── [ 13K] deploy.md
│ │ ├── [ 13K] design.md
│ │ └── [6.4K] quick_start.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.9K] quick_start.md
│ ├── [3.2K] Example_Batch.md
│ ├── [1.7K] Example_Compaction_Topic.md
│ ├── [ 853] Example_CreateTopic.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
│ ├── [ 12K] Feature.md
│ ├── [4.0K] image
│ │ ├── [4.0K] controller
│ │ │ ├── [418K] controller_design_1.png
│ │ │ ├── [170K] controller_design_2.png
│ │ │ ├── [ 76K] controller_design_3.png
│ │ │ ├── [ 55K] controller_design_4.png
│ │ │ ├── [117K] controller_design_5.png
│ │ │ ├── [ 13K] controller_design_6.png
│ │ │ └── [4.0K] quick-start
│ │ │ ├── [ 13K] changemaster.png
│ │ │ ├── [262K] controller.png
│ │ │ ├── [ 14K] epoch.png
│ │ │ └── [ 13K] syncstateset.png
│ │ ├── [ 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
│ │ ├── [ 27K] rocketmq_proxy_cluster_mode.png
│ │ ├── [ 22K] rocketmq_proxy_local_mode.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
│ ├── [4.0K] proxy
│ │ └── [1.0K] deploy_guide.md
│ ├── [7.7K] QuorumACK.md
│ ├── [2.0K] README.md
│ ├── [ 353] RocketMQ_Example.md
│ └── [4.5K] Troubleshoopting.md
├── [4.0K] example
│ ├── [3.0K] 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.4K] SimpleBatchProducer.java
│ │ └── [4.2K] SplitBatchProducer.java
│ ├── [4.0K] benchmark
│ │ ├── [1.4K] AclClient.java
│ │ ├── [ 17K] BatchProducer.java
│ │ ├── [ 13K] Consumer.java
│ │ ├── [ 19K] Producer.java
│ │ ├── [4.0K] timer
│ │ │ ├── [8.4K] TimerConsumer.java
│ │ │ └── [ 14K] TimerProducer.java
│ │ └── [ 20K] TransactionProducer.java
│ ├── [4.0K] broadcast
│ │ └── [2.4K] PushConsumer.java
│ ├── [4.0K] filter
│ │ ├── [2.2K] SqlFilterConsumer.java
│ │ ├── [1.8K] SqlFilterProducer.java
│ │ ├── [2.0K] TagFilterConsumer.java
│ │ └── [1.7K] TagFilterProducer.java
│ ├── [4.0K] namespace
│ │ ├── [2.1K] ProducerWithNamespace.java
│ │ ├── [3.5K] PullConsumerWithNamespace.java
│ │ └── [2.0K] PushConsumerWithNamespace.java
│ ├── [4.0K] openmessaging
│ │ ├── [3.2K] SimpleProducer.java
│ │ ├── [3.1K] 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.5K] Producer.java
│ ├── [4.0K] quickstart
│ │ ├── [3.1K] Consumer.java
│ │ └── [4.5K] Producer.java
│ ├── [4.0K] rpc
│ │ ├── [2.6K] AsyncRequestProducer.java
│ │ ├── [2.0K] RequestProducer.java
│ │ └── [4.0K] ResponseConsumer.java
│ ├── [4.0K] schedule
│ │ ├── [2.4K] ScheduledMessageConsumer.java
│ │ ├── [2.2K] ScheduledMessageProducer.java
│ │ ├── [2.5K] TimerMessageConsumer.java
│ │ └── [2.6K] TimerMessageProducer.java
│ ├── [4.0K] simple
│ │ ├── [6.6K] AclClient.java
│ │ ├── [2.9K] AsyncProducer.java
│ │ ├── [1.1K] CachedQueue.java
│ │ ├── [2.1K] LitePullConsumerAssign.java
│ │ ├── [2.4K] LitePullConsumerAssignWithSubExpression.java
│ │ ├── [1.7K] LitePullConsumerSubscribe.java
│ │ ├── [1.9K] OnewayProducer.java
│ │ ├── [3.0K] PopConsumer.java
│ │ ├── [2.1K] Producer.java
│ │ ├── [7.0K] PullConsumer.java
│ │ ├── [2.9K] PullScheduleService.java
│ │ ├── [2.2K] PushConsumer.java
│ │ └── [2.0K] RandomAsyncCommit.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.9K] BUILD.bazel
│ ├── [1.9K] 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
│ └── [4.0K] resources
│ └── [1.3K] rmq.logback-test.xml
├── [ 11K] LICENSE
├── [4.0K] namesrv
│ ├── [2.5K] BUILD.bazel
│ ├── [2.6K] 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.4K] KVConfigManager.java
│ │ │ │ └── [1.3K] KVConfigSerializeWrapper.java
│ │ │ ├── [ 13K] NamesrvController.java
│ │ │ ├── [9.4K] NamesrvStartup.java
│ │ │ ├── [4.0K] processor
│ │ │ │ ├── [5.2K] ClientRequestProcessor.java
│ │ │ │ ├── [4.0K] ClusterTestRequestProcessor.java
│ │ │ │ └── [ 32K] DefaultRequestProcessor.java
│ │ │ ├── [4.0K] route
│ │ │ │ └── [4.2K] ZoneRouteRPCHook.java
│ │ │ └── [4.0K] routeinfo
│ │ │ ├── [3.2K] BatchUnregistrationService.java
│ │ │ ├── [1.8K] BrokerHousekeepingService.java
│ │ │ └── [ 50K] RouteInfoManager.java
│ │ └── [4.0K] resources
│ │ └── [5.0K] rmq.namesrv.logback.xml
│ └── [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
│ │ ├── [2.0K] NameServerInstanceTest.java
│ │ ├── [3.0K] NamesrvControllerTest.java
│ │ ├── [2.1K] NamesrvStartupTest.java
│ │ ├── [4.0K] processor
│ │ │ ├── [ 11K] ClusterTestRequestProcessorTest.java
│ │ │ └── [ 29K] RequestProcessorTest.java
│ │ └── [4.0K] routeinfo
│ │ ├── [1.9K] BrokerHousekeepingServiceTest.java
│ │ ├── [5.7K] GetRouteInfoBenchmark.java
│ │ ├── [6.8K] RegisterBrokerBenchmark.java
│ │ ├── [4.0K] RouteInfoManagerBrokerPermTest.java
│ │ ├── [4.6K] RouteInfoManagerBrokerRegisterTest.java
│ │ ├── [ 38K] RouteInfoManagerNewTest.java
│ │ ├── [5.3K] RouteInfoManagerStaticRegisterTest.java
│ │ ├── [7.8K] RouteInfoManagerTestBase.java
│ │ └── [8.7K] RouteInfoManagerTest.java
│ └── [4.0K] resources
│ └── [1.3K] rmq.logback-test.xml
├── [ 169] NOTICE
├── [4.0K] openmessaging
│ ├── [1.8K] 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.4K] AbstractOMSProducer.java
│ │ │ └── [5.8K] ProducerImpl.java
│ │ ├── [4.0K] promise
│ │ │ ├── [6.2K] 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
│ └── [4.0K] resources
│ └── [1.3K] rmq.logback-test.xml
├── [ 41K] pom.xml
├── [4.0K] proxy
│ ├── [4.5K] BUILD.bazel
│ ├── [4.1K] pom.xml
│ ├── [2.9K] README.md
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ ├── [4.0K] java
│ │ │ └── [4.0K] org
│ │ │ └── [4.0K] apache
│ │ │ └── [4.0K] rocketmq
│ │ │ └── [4.0K] proxy
│ │ │ ├── [1.7K] CommandLineArgument.java
│ │ │ ├── [4.0K] common
│ │ │ │ ├── [2.0K] AbstractCacheLoader.java
│ │ │ │ ├── [2.5K] AbstractStartAndShutdown.java
│ │ │ │ ├── [2.1K] Address.java
│ │ │ │ ├── [4.0K] channel
│ │ │ │ │ └── [1.9K] ChannelHelper.java
│ │ │ │ ├── [1.3K] ContextVariable.java
│ │ │ │ ├── [5.1K] MessageReceiptHandle.java
│ │ │ │ ├── [3.6K] ProxyContext.java
│ │ │ │ ├── [1.0K] ProxyExceptionCode.java
│ │ │ │ ├── [1.3K] ProxyException.java
│ │ │ │ ├── [8.0K] ReceiptHandleGroup.java
│ │ │ │ ├── [ 914] Shutdown.java
│ │ │ │ ├── [ 959] StartAndShutdown.java
│ │ │ │ ├── [ 908] Start.java
│ │ │ │ └── [4.0K] utils
│ │ │ │ ├── [1.7K] ExceptionUtils.java
│ │ │ │ ├── [1.5K] FilterUtils.java
│ │ │ │ ├── [1.8K] FutureUtils.java
│ │ │ │ └── [1003] ProxyUtils.java
│ │ │ ├── [4.0K] config
│ │ │ │ ├── [ 900] ConfigFile.java
│ │ │ │ ├── [3.4K] Configuration.java
│ │ │ │ ├── [1.7K] ConfigurationManager.java
│ │ │ │ ├── [1.6K] MetricCollectorMode.java
│ │ │ │ └── [ 47K] ProxyConfig.java
│ │ │ ├── [4.0K] grpc
│ │ │ │ ├── [7.7K] GrpcServerBuilder.java
│ │ │ │ ├── [1.7K] GrpcServer.java
│ │ │ │ ├── [4.0K] interceptor
│ │ │ │ │ ├── [4.8K] AuthenticationInterceptor.java
│ │ │ │ │ ├── [1.4K] ContextInterceptor.java
│ │ │ │ │ ├── [4.4K] GlobalExceptionInterceptor.java
│ │ │ │ │ ├── [2.3K] HeaderInterceptor.java
│ │ │ │ │ ├── [2.9K] InterceptorConstants.java
│ │ │ │ │ └── [2.8K] RequestMapping.java
│ │ │ │ ├── [4.0K] OptionalSSLProtocolNegotiator.java
│ │ │ │ └── [4.0K] v2
│ │ │ │ ├── [2.7K] AbstractMessingActivity.java
│ │ │ │ ├── [4.0K] channel
│ │ │ │ │ ├── [5.2K] GrpcChannelManager.java
│ │ │ │ │ └── [ 11K] GrpcClientChannel.java
│ │ │ │ ├── [4.0K] client
│ │ │ │ │ └── [ 23K] ClientActivity.java
│ │ │ │ ├── [4.0K] common
│ │ │ │ │ ├── [ 11K] GrpcClientSettingsManager.java
│ │ │ │ │ ├── [ 11K] GrpcConverter.java
│ │ │ │ │ ├── [2.5K] GrpcProxyException.java
│ │ │ │ │ ├── [4.9K] GrpcValidator.java
│ │ │ │ │ ├── [4.7K] ResponseBuilder.java
│ │ │ │ │ └── [3.0K] ResponseWriter.java
│ │ │ │ ├── [4.0K] consumer
│ │ │ │ │ ├── [7.4K] AckMessageActivity.java
│ │ │ │ │ ├── [4.6K] ChangeInvisibleDurationActivity.java
│ │ │ │ │ ├── [1.8K] PopMessageResultFilterImpl.java
│ │ │ │ │ ├── [9.8K] ReceiveMessageActivity.java
│ │ │ │ │ └── [7.3K] ReceiveMessageResponseStreamWriter.java
│ │ │ │ ├── [8.1K] DefaultGrpcMessingActivity.java
│ │ │ │ ├── [ 21K] GrpcMessagingApplication.java
│ │ │ │ ├── [3.5K] GrpcMessingActivity.java
│ │ │ │ ├── [4.0K] producer
│ │ │ │ │ ├── [4.0K] ForwardMessageToDLQActivity.java
│ │ │ │ │ └── [ 19K] SendMessageActivity.java
│ │ │ │ ├── [4.0K] route
│ │ │ │ │ └── [ 12K] RouteActivity.java
│ │ │ │ └── [4.0K] transaction
│ │ │ │ └── [3.7K] EndTransactionActivity.java
│ │ │ ├── [4.0K] metrics
│ │ │ │ ├── [1.1K] ProxyMetricsConstant.java
│ │ │ │ └── [ 10K] ProxyMetricsManager.java
│ │ │ ├── [4.0K] processor
│ │ │ │ ├── [1.7K] AbstractProcessor.java
│ │ │ │ ├── [4.0K] channel
│ │ │ │ │ ├── [ 948] ChannelExtendAttributeGetter.java
│ │ │ │ │ ├── [1.1K] ChannelProtocolType.java
│ │ │ │ │ ├── [ 939] RemoteChannelConverter.java
│ │ │ │ │ ├── [3.6K] RemoteChannel.java
│ │ │ │ │ └── [2.9K] RemoteChannelSerializer.java
│ │ │ │ ├── [4.3K] ClientProcessor.java
│ │ │ │ ├── [ 22K] ConsumerProcessor.java
│ │ │ │ ├── [ 14K] DefaultMessagingProcessor.java
│ │ │ │ ├── [9.2K] MessagingProcessor.java
│ │ │ │ ├── [1.3K] PopMessageResultFilter.java
│ │ │ │ ├── [ 11K] ProducerProcessor.java
│ │ │ │ ├── [1.1K] QueueSelector.java
│ │ │ │ ├── [ 16K] ReceiptHandleProcessor.java
│ │ │ │ ├── [1.7K] RequestBrokerProcessor.java
│ │ │ │ ├── [3.2K] TransactionProcessor.java
│ │ │ │ ├── [ 920] TransactionStatus.java
│ │ │ │ └── [4.0K] validator
│ │ │ │ ├── [1.6K] DefaultTopicMessageTypeValidator.java
│ │ │ │ └── [1.2K] TopicMessageTypeValidator.java
│ │ │ ├── [1.7K] ProxyMode.java
│ │ │ ├── [ 11K] ProxyStartup.java
│ │ │ ├── [4.0K] remoting
│ │ │ │ ├── [4.0K] activity
│ │ │ │ │ ├── [8.3K] AbstractRemotingActivity.java
│ │ │ │ │ ├── [1.6K] AckMessageActivity.java
│ │ │ │ │ ├── [1.6K] ChangeInvisibleTimeActivity.java
│ │ │ │ │ ├── [8.4K] ClientManagerActivity.java
│ │ │ │ │ ├── [6.0K] ConsumerManagerActivity.java
│ │ │ │ │ ├── [3.6K] GetTopicRouteActivity.java
│ │ │ │ │ ├── [1.9K] PopMessageActivity.java
│ │ │ │ │ ├── [3.3K] PullMessageActivity.java
│ │ │ │ │ ├── [4.3K] SendMessageActivity.java
│ │ │ │ │ └── [2.9K] TransactionActivity.java
│ │ │ │ ├── [4.0K] channel
│ │ │ │ │ ├── [ 11K] RemotingChannel.java
│ │ │ │ │ └── [5.4K] RemotingChannelManager.java
│ │ │ │ ├── [1.9K] ClientHousekeepingService.java
│ │ │ │ ├── [4.0K] common
│ │ │ │ │ └── [2.0K] RemotingConverter.java
│ │ │ │ ├── [3.7K] MultiProtocolRemotingServer.java
│ │ │ │ ├── [5.2K] MultiProtocolTlsHelper.java
│ │ │ │ ├── [4.0K] pipeline
│ │ │ │ │ ├── [2.1K] AuthenticationPipeline.java
│ │ │ │ │ └── [1.4K] RequestPipeline.java
│ │ │ │ ├── [4.0K] protocol
│ │ │ │ │ ├── [4.0K] http2proxy
│ │ │ │ │ │ ├── [5.4K] Http2ProtocolProxyHandler.java
│ │ │ │ │ │ ├── [2.5K] Http2ProxyBackendHandler.java
│ │ │ │ │ │ └── [3.1K] Http2ProxyFrontendHandler.java
│ │ │ │ │ ├── [1.1K] ProtocolHandler.java
│ │ │ │ │ ├── [2.2K] ProtocolNegotiationHandler.java
│ │ │ │ │ └── [4.0K] remoting
│ │ │ │ │ └── [2.5K] RemotingProtocolHandler.java
│ │ │ │ ├── [ 18K] RemotingProtocolServer.java
│ │ │ │ └── [1.1K] RemotingProxyOutClient.java
│ │ │ └── [4.0K] service
│ │ │ ├── [4.0K] admin
│ │ │ │ ├── [1.4K] AdminService.java
│ │ │ │ └── [5.7K] DefaultAdminService.java
│ │ │ ├── [4.0K] channel
│ │ │ │ ├── [3.9K] ChannelManager.java
│ │ │ │ ├── [3.0K] InvocationChannel.java
│ │ │ │ ├── [1.0K] InvocationContextInterface.java
│ │ │ │ ├── [1.6K] InvocationContext.java
│ │ │ │ ├── [7.0K] SimpleChannelHandlerContext.java
│ │ │ │ └── [5.7K] SimpleChannel.java
│ │ │ ├── [4.0K] client
│ │ │ │ └── [3.3K] ClusterConsumerManager.java
│ │ │ ├── [8.1K] ClusterServiceManager.java
│ │ │ ├── [5.7K] LocalServiceManager.java
│ │ │ ├── [4.0K] message
│ │ │ │ ├── [ 11K] ClusterMessageService.java
│ │ │ │ ├── [ 22K] LocalMessageService.java
│ │ │ │ ├── [1.7K] LocalRemotingCommand.java
│ │ │ │ └── [5.4K] MessageService.java
│ │ │ ├── [4.0K] metadata
│ │ │ │ ├── [7.3K] ClusterMetadataService.java
│ │ │ │ ├── [1.8K] LocalMetadataService.java
│ │ │ │ └── [1.1K] MetadataService.java
│ │ │ ├── [4.0K] mqclient
│ │ │ │ ├── [1.4K] DoNothingClientRemotingProcessor.java
│ │ │ │ ├── [ 29K] MQClientAPIExt.java
│ │ │ │ ├── [4.4K] MQClientAPIFactory.java
│ │ │ │ └── [3.7K] ProxyClientRemotingProcessor.java
│ │ │ ├── [4.0K] relay
│ │ │ │ ├── [2.9K] AbstractProxyRelayService.java
│ │ │ │ ├── [2.1K] ClusterProxyRelayService.java
│ │ │ │ ├── [5.0K] LocalProxyRelayService.java
│ │ │ │ ├── [8.3K] ProxyChannel.java
│ │ │ │ ├── [1.5K] ProxyRelayResult.java
│ │ │ │ ├── [2.2K] ProxyRelayService.java
│ │ │ │ └── [1.6K] RelayData.java
│ │ │ ├── [4.0K] route
│ │ │ │ ├── [2.5K] AddressableMessageQueue.java
│ │ │ │ ├── [3.2K] ClusterTopicRouteService.java
│ │ │ │ ├── [5.2K] LocalTopicRouteService.java
│ │ │ │ ├── [8.4K] MessageQueueSelector.java
│ │ │ │ ├── [2.3K] MessageQueueView.java
│ │ │ │ ├── [3.4K] ProxyTopicRouteData.java
│ │ │ │ ├── [2.0K] TopicRouteHelper.java
│ │ │ │ ├── [8.1K] TopicRouteService.java
│ │ │ │ └── [2.7K] TopicRouteWrapper.java
│ │ │ ├── [1.5K] ServiceManagerFactory.java
│ │ │ ├── [1.8K] ServiceManager.java
│ │ │ ├── [4.0K] sysmessage
│ │ │ │ ├── [7.9K] AbstractSystemMessageSyncer.java
│ │ │ │ ├── [5.3K] HeartbeatSyncerData.java
│ │ │ │ ├── [ 11K] HeartbeatSyncer.java
│ │ │ │ └── [ 918] HeartbeatType.java
│ │ │ └── [4.0K] transaction
│ │ │ ├── [4.0K] AbstractTransactionService.java
│ │ │ ├── [ 12K] ClusterTransactionService.java
│ │ │ ├── [1.6K] EndTransactionRequestData.java
│ │ │ ├── [1.8K] LocalTransactionService.java
│ │ │ ├── [3.7K] TransactionData.java
│ │ │ ├── [6.5K] TransactionDataManager.java
│ │ │ └── [1.9K] TransactionService.java
│ │ └── [4.0K] resources
│ │ └── [ 18K] rmq.proxy.logback.xml
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] proxy
│ │ ├── [4.0K] common
│ │ │ ├── [ 10K] ReceiptHandleGroupTest.java
│ │ │ └── [4.0K] utils
│ │ │ └── [2.1K] FilterUtilTest.java
│ │ ├── [4.0K] config
│ │ │ ├── [1.9K] ConfigurationManagerTest.java
│ │ │ ├── [1.7K] InitConfigTest.java
│ │ │ └── [1.5K] MetricCollectorModeTest.java
│ │ ├── [4.0K] grpc
│ │ │ └── [4.0K] v2
│ │ │ ├── [3.6K] AbstractMessingActivityTest.java
│ │ │ ├── [4.3K] BaseActivityTest.java
│ │ │ ├── [4.0K] channel
│ │ │ │ └── [3.4K] GrpcClientChannelTest.java
│ │ │ ├── [4.0K] client
│ │ │ │ └── [ 19K] ClientActivityTest.java
│ │ │ ├── [4.0K] common
│ │ │ │ ├── [5.4K] GrpcClientSettingsManagerTest.java
│ │ │ │ ├── [1.6K] GrpcConverterTest.java
│ │ │ │ └── [1.7K] GrpcValidatorTest.java
│ │ │ ├── [4.0K] consumer
│ │ │ │ ├── [4.3K] AckMessageActivityTest.java
│ │ │ │ ├── [8.7K] ChangeInvisibleDurationActivityTest.java
│ │ │ │ ├── [ 15K] ReceiveMessageActivityTest.java
│ │ │ │ └── [7.4K] ReceiveMessageResponseStreamWriterTest.java
│ │ │ ├── [5.4K] GrpcMessagingApplicationTest.java
│ │ │ ├── [4.0K] producer
│ │ │ │ ├── [4.8K] ForwardMessageToDLQActivityTest.java
│ │ │ │ └── [ 41K] SendMessageActivityTest.java
│ │ │ ├── [4.0K] route
│ │ │ │ └── [ 14K] RouteActivityTest.java
│ │ │ └── [4.0K] transaction
│ │ │ └── [4.4K] EndTransactionActivityTest.java
│ │ ├── [4.0K] processor
│ │ │ ├── [5.0K] BaseProcessorTest.java
│ │ │ ├── [4.0K] channel
│ │ │ │ └── [2.1K] RemoteChannelTest.java
│ │ │ ├── [ 13K] ConsumerProcessorTest.java
│ │ │ ├── [ 10K] ProducerProcessorTest.java
│ │ │ ├── [ 27K] ReceiptHandleProcessorTest.java
│ │ │ └── [3.2K] TransactionProcessorTest.java
│ │ ├── [ 12K] ProxyStartupTest.java
│ │ ├── [4.0K] remoting
│ │ │ ├── [4.0K] activity
│ │ │ │ ├── [ 10K] AbstractRemotingActivityTest.java
│ │ │ │ ├── [7.4K] PullMessageActivityTest.java
│ │ │ │ └── [4.6K] SendMessageActivityTest.java
│ │ │ └── [4.0K] channel
│ │ │ ├── [6.9K] RemotingChannelManagerTest.java
│ │ │ └── [3.5K] RemotingChannelTest.java
│ │ └── [4.0K] service
│ │ ├── [4.0K] admin
│ │ │ └── [4.3K] DefaultAdminServiceTest.java
│ │ ├── [3.7K] BaseServiceTest.java
│ │ ├── [4.0K] message
│ │ │ ├── [3.3K] ClusterMessageServiceTest.java
│ │ │ └── [ 25K] LocalMessageServiceTest.java
│ │ ├── [4.0K] metadata
│ │ │ └── [3.2K] ClusterMetadataServiceTest.java
│ │ ├── [4.0K] mqclient
│ │ │ ├── [ 18K] MQClientAPIExtTest.java
│ │ │ └── [6.4K] ProxyClientRemotingProcessorTest.java
│ │ ├── [4.0K] relay
│ │ │ ├── [5.3K] LocalProxyRelayServiceTest.java
│ │ │ └── [8.6K] ProxyChannelTest.java
│ │ ├── [4.0K] route
│ │ │ ├── [5.4K] ClusterTopicRouteServiceTest.java
│ │ │ ├── [5.1K] LocalTopicRouteServiceTest.java
│ │ │ └── [4.1K] MessageQueueSelectorTest.java
│ │ ├── [4.0K] sysmessage
│ │ │ └── [ 16K] HeartbeatSyncerTest.java
│ │ └── [4.0K] transaction
│ │ ├── [4.7K] AbstractTransactionServiceTest.java
│ │ ├── [8.9K] ClusterTransactionServiceTest.java
│ │ └── [6.5K] TransactionDataManagerTest.java
│ └── [4.0K] resources
│ ├── [4.0K] mockito-extensions
│ │ └── [ 17] org.mockito.plugins.MockMaker
│ ├── [1.3K] rmq.logback-test.xml
│ └── [4.0K] rmq-proxy-home
│ └── [4.0K] conf
│ ├── [ 949] broker.conf
│ ├── [ 19K] logback_proxy.xml
│ └── [ 28] rmq-proxy.json
├── [ 12K] README.md
├── [4.0K] remoting
│ ├── [3.1K] BUILD.bazel
│ ├── [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
│ │ │ ├── [ 10K] RemotingHelper.java
│ │ │ ├── [1.4K] SemaphoreReleaseOnlyOnce.java
│ │ │ ├── [2.5K] ServiceThread.java
│ │ │ └── [1.8K] TlsMode.java
│ │ ├── [ 10K] Configuration.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] metrics
│ │ │ ├── [2.8K] RemotingMetricsConstant.java
│ │ │ └── [4.7K] RemotingMetricsManager.java
│ │ ├── [4.0K] netty
│ │ │ ├── [2.9K] FileRegionEncoder.java
│ │ │ ├── [6.6K] NettyClientConfig.java
│ │ │ ├── [2.4K] NettyDecoder.java
│ │ │ ├── [2.1K] NettyEncoder.java
│ │ │ ├── [1.5K] NettyEvent.java
│ │ │ ├── [ 926] NettyEventType.java
│ │ │ ├── [ 11K] NettyLogger.java
│ │ │ ├── [ 28K] NettyRemotingAbstract.java
│ │ │ ├── [ 44K] NettyRemotingClient.java
│ │ │ ├── [ 31K] NettyRemotingServer.java
│ │ │ ├── [1.2K] NettyRequestProcessor.java
│ │ │ ├── [5.7K] NettyServerConfig.java
│ │ │ ├── [4.3K] NettySystemConfig.java
│ │ │ ├── [3.8K] RemotingCodeDistributionHandler.java
│ │ │ ├── [1002] RemotingResponseCallback.java
│ │ │ ├── [3.0K] RequestTask.java
│ │ │ ├── [4.9K] ResponseFuture.java
│ │ │ ├── [ 11K] TlsHelper.java
│ │ │ └── [5.7K] TlsSystemConfig.java
│ │ ├── [4.0K] protocol
│ │ │ ├── [4.0K] admin
│ │ │ │ ├── [2.2K] ConsumeStats.java
│ │ │ │ ├── [1.7K] OffsetWrapper.java
│ │ │ │ ├── [2.1K] RollbackStats.java
│ │ │ │ ├── [1.7K] TopicOffset.java
│ │ │ │ └── [1.4K] TopicStatsTable.java
│ │ │ ├── [4.0K] body
│ │ │ │ ├── [3.0K] BrokerMemberGroup.java
│ │ │ │ ├── [4.3K] BrokerReplicasInfo.java
│ │ │ │ ├── [1.6K] BrokerStatsData.java
│ │ │ │ ├── [1.3K] BrokerStatsItem.java
│ │ │ │ ├── [1.8K] CheckClientRequestBody.java
│ │ │ │ ├── [2.3K] ClusterAclVersionInfo.java
│ │ │ │ ├── [2.9K] ClusterInfo.java
│ │ │ │ ├── [ 987] CMResult.java
│ │ │ │ ├── [1.7K] Connection.java
│ │ │ │ ├── [2.0K] ConsumeByWho.java
│ │ │ │ ├── [2.2K] ConsumeMessageDirectlyResult.java
│ │ │ │ ├── [2.5K] ConsumeQueueData.java
│ │ │ │ ├── [3.0K] ConsumerConnection.java
│ │ │ │ ├── [1.7K] ConsumerOffsetSerializeWrapper.java
│ │ │ │ ├── [ 13K] ConsumerRunningInfo.java
│ │ │ │ ├── [2.1K] ConsumeStatsList.java
│ │ │ │ ├── [2.1K] ConsumeStatus.java
│ │ │ │ ├── [2.6K] EpochEntryCache.java
│ │ │ │ ├── [1.3K] GetBrokerMemberGroupResponseBody.java
│ │ │ │ ├── [1.7K] GetConsumerStatusBody.java
│ │ │ │ ├── [1.2K] GetRemoteClientConfigBody.java
│ │ │ │ ├── [1.2K] GroupList.java
│ │ │ │ ├── [5.5K] HARuntimeInfo.java
│ │ │ │ ├── [1.2K] KVTable.java
│ │ │ │ ├── [1.9K] LockBatchRequestBody.java
│ │ │ │ ├── [1.3K] LockBatchResponseBody.java
│ │ │ │ ├── [1.6K] MessageRequestModeSerializeWrapper.java
│ │ │ │ ├── [1.7K] PopProcessQueueInfo.java
│ │ │ │ ├── [5.0K] ProcessQueueInfo.java
│ │ │ │ ├── [1.3K] ProducerConnection.java
│ │ │ │ ├── [2.5K] ProducerInfo.java
│ │ │ │ ├── [1.3K] ProducerTableInfo.java
│ │ │ │ ├── [2.0K] QueryAssignmentRequestBody.java
│ │ │ │ ├── [1.4K] QueryAssignmentResponseBody.java
│ │ │ │ ├── [2.2K] QueryConsumeQueueResponseBody.java
│ │ │ │ ├── [1.3K] QueryConsumeTimeSpanBody.java
│ │ │ │ ├── [1.3K] QueryCorrectionOffsetBody.java
│ │ │ │ ├── [1.6K] QuerySubscriptionResponseBody.java
│ │ │ │ ├── [2.4K] QueueTimeSpan.java
│ │ │ │ ├── [9.9K] RegisterBrokerBody.java
│ │ │ │ ├── [1.3K] ResetOffsetBodyForC.java
│ │ │ │ ├── [1.4K] ResetOffsetBody.java
│ │ │ │ ├── [2.1K] SetMessageRequestModeRequestBody.java
│ │ │ │ ├── [1.9K] SubscriptionGroupWrapper.java
│ │ │ │ ├── [1.9K] SyncStateSet.java
│ │ │ │ ├── [2.9K] TopicConfigAndMappingSerializeWrapper.java
│ │ │ │ ├── [1.7K] TopicConfigSerializeWrapper.java
│ │ │ │ ├── [1.4K] TopicList.java
│ │ │ │ ├── [1.8K] TopicQueueMappingSerializeWrapper.java
│ │ │ │ └── [1.9K] UnlockBatchRequestBody.java
│ │ │ ├── [2.2K] BrokerSyncInfo.java
│ │ │ ├── [3.9K] DataVersion.java
│ │ │ ├── [2.6K] EpochEntry.java
│ │ │ ├── [1.8K] FastCodesHeader.java
│ │ │ ├── [4.0K] filter
│ │ │ │ └── [3.3K] FilterAPI.java
│ │ │ ├── [1.4K] ForbiddenType.java
│ │ │ ├── [4.0K] header
│ │ │ │ ├── [2.5K] AckMessageRequestHeader.java
│ │ │ │ ├── [1.4K] AddBrokerRequestHeader.java
│ │ │ │ ├── [2.9K] ChangeInvisibleTimeRequestHeader.java
│ │ │ │ ├── [1.8K] ChangeInvisibleTimeResponseHeader.java
│ │ │ │ ├── [2.8K] CheckTransactionStateRequestHeader.java
│ │ │ │ ├── [2.7K] CheckTransactionStateResponseHeader.java
│ │ │ │ ├── [2.3K] CloneGroupOffsetRequestHeader.java
│ │ │ │ ├── [3.1K] ConsumeMessageDirectlyResultRequestHeader.java
│ │ │ │ ├── [3.1K] ConsumerSendMsgBackRequestHeader.java
│ │ │ │ ├── [4.0K] controller
│ │ │ │ │ ├── [2.3K] AlterSyncStateSetRequestHeader.java
│ │ │ │ │ ├── [1.6K] AlterSyncStateSetResponseHeader.java
│ │ │ │ │ ├── [3.1K] CleanControllerBrokerDataRequestHeader.java
│ │ │ │ │ ├── [2.5K] ElectMasterRequestHeader.java
│ │ │ │ │ ├── [2.5K] ElectMasterResponseHeader.java
│ │ │ │ │ ├── [2.9K] GetMetaDataResponseHeader.java
│ │ │ │ │ ├── [2.1K] GetReplicaInfoRequestHeader.java
│ │ │ │ │ ├── [2.1K] GetReplicaInfoResponseHeader.java
│ │ │ │ │ ├── [4.4K] RegisterBrokerToControllerRequestHeader.java
│ │ │ │ │ └── [2.4K] RegisterBrokerToControllerResponseHeader.java
│ │ │ │ ├── [3.5K] CreateAccessConfigRequestHeader.java
│ │ │ │ ├── [4.3K] CreateTopicRequestHeader.java
│ │ │ │ ├── [1.4K] DeleteAccessConfigRequestHeader.java
│ │ │ │ ├── [1.6K] DeleteSubscriptionGroupRequestHeader.java
│ │ │ │ ├── [1.4K] DeleteTopicRequestHeader.java
│ │ │ │ ├── [3.9K] EndTransactionRequestHeader.java
│ │ │ │ ├── [1.2K] EndTransactionResponseHeader.java
│ │ │ │ ├── [1.9K] ExchangeHAInfoRequestHeader.java
│ │ │ │ ├── [1.9K] ExchangeHAInfoResponseHeader.java
│ │ │ │ ├── [ 12K] ExtraInfoUtil.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.6K] GetBrokerMemberGroupRequestHeader.java
│ │ │ │ ├── [1.5K] GetConsumerConnectionListRequestHeader.java
│ │ │ │ ├── [1.6K] GetConsumerListByGroupRequestHeader.java
│ │ │ │ ├── [1.2K] GetConsumerListByGroupResponseBody.java
│ │ │ │ ├── [1.1K] GetConsumerListByGroupResponseHeader.java
│ │ │ │ ├── [2.2K] GetConsumerRunningInfoRequestHeader.java
│ │ │ │ ├── [2.1K] GetConsumerStatusRequestHeader.java
│ │ │ │ ├── [1.4K] GetConsumeStatsInBrokerHeader.java
│ │ │ │ ├── [1.8K] GetConsumeStatsRequestHeader.java
│ │ │ │ ├── [1.7K] GetEarliestMsgStoretimeRequestHeader.java
│ │ │ │ ├── [1.5K] GetEarliestMsgStoretimeResponseHeader.java
│ │ │ │ ├── [2.6K] GetMaxOffsetRequestHeader.java
│ │ │ │ ├── [1.4K] GetMaxOffsetResponseHeader.java
│ │ │ │ ├── [1.9K] GetMinOffsetRequestHeader.java
│ │ │ │ ├── [1.4K] GetMinOffsetResponseHeader.java
│ │ │ │ ├── [1.5K] GetProducerConnectionListRequestHeader.java
│ │ │ │ ├── [1.6K] GetSubscriptionGroupConfigRequestHeader.java
│ │ │ │ ├── [1.4K] GetTopicConfigRequestHeader.java
│ │ │ │ ├── [1.4K] GetTopicsByClusterRequestHeader.java
│ │ │ │ ├── [1.4K] GetTopicStatsInfoRequestHeader.java
│ │ │ │ ├── [1.5K] InitConsumerOffsetRequestHeader.java
│ │ │ │ ├── [4.0K] namesrv
│ │ │ │ │ ├── [1.4K] AddWritePermOfBrokerRequestHeader.java
│ │ │ │ │ ├── [1.4K] AddWritePermOfBrokerResponseHeader.java
│ │ │ │ │ ├── [3.2K] BrokerHeartbeatRequestHeader.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
│ │ │ │ │ ├── [3.3K] RegisterBrokerRequestHeader.java
│ │ │ │ │ ├── [1.6K] RegisterBrokerResponseHeader.java
│ │ │ │ │ ├── [1.7K] RegisterOrderTopicRequestHeader.java
│ │ │ │ │ ├── [1.4K] RegisterTopicRequestHeader.java
│ │ │ │ │ ├── [2.1K] UnRegisterBrokerRequestHeader.java
│ │ │ │ │ ├── [1.4K] WipeWritePermOfBrokerRequestHeader.java
│ │ │ │ │ └── [1.4K] WipeWritePermOfBrokerResponseHeader.java
│ │ │ │ ├── [2.2K] NotificationRequestHeader.java
│ │ │ │ ├── [1.4K] NotificationResponseHeader.java
│ │ │ │ ├── [2.6K] NotifyBrokerRoleChangedRequestHeader.java
│ │ │ │ ├── [1.4K] NotifyConsumerIdsChangedRequestHeader.java
│ │ │ │ ├── [2.3K] NotifyMinBrokerIdChangeRequestHeader.java
│ │ │ │ ├── [2.0K] PeekMessageRequestHeader.java
│ │ │ │ ├── [1.8K] PollingInfoRequestHeader.java
│ │ │ │ ├── [1.4K] PollingInfoResponseHeader.java
│ │ │ │ ├── [4.3K] PopMessageRequestHeader.java
│ │ │ │ ├── [2.7K] PopMessageResponseHeader.java
│ │ │ │ ├── [9.1K] PullMessageRequestHeader.java
│ │ │ │ ├── [5.0K] PullMessageResponseHeader.java
│ │ │ │ ├── [2.0K] QueryConsumeQueueRequestHeader.java
│ │ │ │ ├── [2.2K] QueryConsumerOffsetRequestHeader.java
│ │ │ │ ├── [1.5K] QueryConsumerOffsetResponseHeader.java
│ │ │ │ ├── [1.5K] QueryConsumeTimeSpanRequestHeader.java
│ │ │ │ ├── [1.9K] QueryCorrectionOffsetHeader.java
│ │ │ │ ├── [2.2K] QueryMessageRequestHeader.java
│ │ │ │ ├── [1.9K] QueryMessageResponseHeader.java
│ │ │ │ ├── [1.6K] QuerySubscriptionByConsumerRequestHeader.java
│ │ │ │ ├── [1.5K] QueryTopicConsumeByWhoRequestHeader.java
│ │ │ │ ├── [1.5K] QueryTopicsByConsumerRequestHeader.java
│ │ │ │ ├── [1.8K] RemoveBrokerRequestHeader.java
│ │ │ │ ├── [4.2K] ReplyMessageRequestHeader.java
│ │ │ │ ├── [1.4K] ResetMasterFlushOffsetHeader.java
│ │ │ │ ├── [2.2K] ResetOffsetRequestHeader.java
│ │ │ │ ├── [1.5K] ResumeCheckHalfMessageRequestHeader.java
│ │ │ │ ├── [2.2K] SearchOffsetRequestHeader.java
│ │ │ │ ├── [1.4K] SearchOffsetResponseHeader.java
│ │ │ │ ├── [6.0K] SendMessageRequestHeader.java
│ │ │ │ ├── [7.6K] SendMessageRequestHeaderV2.java
│ │ │ │ ├── [3.4K] SendMessageResponseHeader.java
│ │ │ │ ├── [2.2K] StatisticsMessagesRequestHeader.java
│ │ │ │ ├── [1.9K] UnregisterClientRequestHeader.java
│ │ │ │ ├── [1.1K] UnregisterClientResponseHeader.java
│ │ │ │ ├── [2.5K] UpdateConsumerOffsetRequestHeader.java
│ │ │ │ ├── [1.2K] UpdateConsumerOffsetResponseHeader.java
│ │ │ │ ├── [1.7K] UpdateGlobalWhiteAddrsConfigRequestHeader.java
│ │ │ │ ├── [1.8K] UpdateGroupForbiddenRequestHeader.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.0K] HeartbeatData.java
│ │ │ │ ├── [1.3K] MessageModel.java
│ │ │ │ ├── [1.2K] ProducerData.java
│ │ │ │ └── [5.6K] SubscriptionData.java
│ │ │ ├── [1.5K] LanguageCode.java
│ │ │ ├── [2.0K] MQProtosHelper.java
│ │ │ ├── [6.7K] NamespaceUtil.java
│ │ │ ├── [4.0K] namesrv
│ │ │ │ └── [1.5K] RegisterBrokerResult.java
│ │ │ ├── [ 21K] RemotingCommand.java
│ │ │ ├── [ 929] RemotingCommandType.java
│ │ │ ├── [2.5K] RemotingSerializable.java
│ │ │ ├── [1.1K] RemotingSysResponseCode.java
│ │ │ ├── [9.0K] RequestCode.java
│ │ │ ├── [1.5K] RequestSource.java
│ │ │ ├── [1.3K] RequestType.java
│ │ │ ├── [4.1K] ResponseCode.java
│ │ │ ├── [8.5K] RocketMQSerializable.java
│ │ │ ├── [4.0K] route
│ │ │ │ ├── [5.6K] BrokerData.java
│ │ │ │ ├── [1013] MessageQueueRouteState.java
│ │ │ │ ├── [3.7K] QueueData.java
│ │ │ │ └── [9.0K] TopicRouteData.java
│ │ │ ├── [1.3K] SerializeType.java
│ │ │ ├── [4.0K] statictopic
│ │ │ │ ├── [6.3K] LogicQueueMappingItem.java
│ │ │ │ ├── [2.2K] TopicConfigAndQueueMapping.java
│ │ │ │ ├── [3.0K] TopicQueueMappingContext.java
│ │ │ │ ├── [5.5K] TopicQueueMappingDetail.java
│ │ │ │ ├── [4.5K] TopicQueueMappingInfo.java
│ │ │ │ ├── [3.0K] TopicQueueMappingOne.java
│ │ │ │ ├── [ 33K] TopicQueueMappingUtils.java
│ │ │ │ └── [3.1K] TopicRemappingDetailWrapper.java
│ │ │ ├── [4.0K] subscription
│ │ │ │ ├── [3.6K] CustomizedRetryPolicy.java
│ │ │ │ ├── [2.3K] ExponentialRetryPolicy.java
│ │ │ │ ├── [2.5K] GroupForbidden.java
│ │ │ │ ├── [2.8K] GroupRetryPolicy.java
│ │ │ │ ├── [ 934] GroupRetryPolicyType.java
│ │ │ │ ├── [1.1K] RetryPolicy.java
│ │ │ │ └── [6.8K] SubscriptionGroupConfig.java
│ │ │ └── [4.0K] topic
│ │ │ └── [2.1K] OffsetMovedEvent.java
│ │ ├── [4.0K] proxy
│ │ │ └── [1.8K] SocksProxyConfig.java
│ │ ├── [2.6K] RemotingClient.java
│ │ ├── [2.6K] RemotingServer.java
│ │ ├── [1.0K] RemotingService.java
│ │ ├── [4.0K] rpc
│ │ │ ├── [7.5K] ClientMetadata.java
│ │ │ ├── [3.6K] RequestBuilder.java
│ │ │ ├── [1.1K] RpcClientHook.java
│ │ │ ├── [ 17K] RpcClientImpl.java
│ │ │ ├── [1.5K] RpcClient.java
│ │ │ ├── [2.4K] RpcClientUtils.java
│ │ │ ├── [1.4K] RpcException.java
│ │ │ ├── [1.7K] RpcRequestHeader.java
│ │ │ ├── [1.3K] RpcRequest.java
│ │ │ ├── [1.9K] RpcResponse.java
│ │ │ ├── [1020] TopicQueueRequestHeader.java
│ │ │ └── [1.1K] TopicRequestHeader.java
│ │ ├── [4.0K] rpchook
│ │ │ ├── [1.8K] DynamicalExtFieldRPCHook.java
│ │ │ └── [1.4K] StreamTypeRPCHook.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.6K] NettyClientConfigTest.java
│ │ │ ├── [5.3K] NettyRemotingAbstractTest.java
│ │ │ ├── [1.6K] NettyRemotingClientTest.java
│ │ │ ├── [1.5K] NettyServerConfigTest.java
│ │ │ └── [3.3K] RemotingCodeDistributionHandlerTest.java
│ │ ├── [4.0K] protocol
│ │ │ ├── [4.0K] admin
│ │ │ │ ├── [2.7K] ConsumeStatsTest.java
│ │ │ │ └── [3.4K] TopicStatsTableTest.java
│ │ │ ├── [4.0K] body
│ │ │ │ ├── [3.3K] BrokerStatsDataTest.java
│ │ │ │ ├── [2.0K] CheckClientRequestBodyTest.java
│ │ │ │ ├── [2.1K] ConsumeMessageDirectlyResultTest.java
│ │ │ │ ├── [3.6K] ConsumerConnectionTest.java
│ │ │ │ ├── [4.1K] ConsumerRunningInfoTest.java
│ │ │ │ ├── [2.7K] ConsumeStatsListTest.java
│ │ │ │ ├── [1.7K] KVTableTest.java
│ │ │ │ ├── [3.0K] MessageRequestModeSerializeWrapperTest.java
│ │ │ │ ├── [2.8K] QueryConsumeQueueResponseBodyTest.java
│ │ │ │ ├── [1.8K] QueryCorrectionOffsetBodyTest.java
│ │ │ │ ├── [1.8K] ResetOffsetBodyTest.java
│ │ │ │ └── [2.5K] SubscriptionGroupWrapperTest.java
│ │ │ ├── [3.3K] CheckpointFileTest.java
│ │ │ ├── [3.9K] ClusterInfoTest.java
│ │ │ ├── [1.7K] ConsumeStatusTest.java
│ │ │ ├── [2.7K] DataVersionTest.java
│ │ │ ├── [4.0K] filter
│ │ │ │ └── [3.3K] FilterAPITest.java
│ │ │ ├── [1.9K] GroupListTest.java
│ │ │ ├── [4.0K] header
│ │ │ │ ├── [1.8K] ExtraInfoUtilTest.java
│ │ │ │ └── [3.6K] FastCodesHeaderTest.java
│ │ │ ├── [4.0K] heartbeat
│ │ │ │ └── [4.0K] SubscriptionDataTest.java
│ │ │ ├── [1.2K] LanguageCodeTest.java
│ │ │ ├── [5.0K] NamespaceUtilTest.java
│ │ │ ├── [7.1K] QueryConsumeTimeSpanBodyTest.java
│ │ │ ├── [2.4K] RegisterBrokerBodyTest.java
│ │ │ ├── [ 14K] RemotingCommandTest.java
│ │ │ ├── [6.2K] RemotingSerializableTest.java
│ │ │ ├── [1.8K] RequestSourceTest.java
│ │ │ ├── [1.2K] RequestTypeTest.java
│ │ │ ├── [9.3K] RocketMQSerializableTest.java
│ │ │ ├── [4.0K] route
│ │ │ │ └── [4.0K] TopicRouteDataTest.java
│ │ │ ├── [4.0K] statictopic
│ │ │ │ ├── [3.9K] TopicQueueMappingTest.java
│ │ │ │ └── [ 16K] TopicQueueMappingUtilsTest.java
│ │ │ ├── [4.0K] subscription
│ │ │ │ ├── [1.8K] CustomizedRetryPolicyTest.java
│ │ │ │ ├── [1.8K] ExponentialRetryPolicyTest.java
│ │ │ │ └── [2.1K] GroupRetryPolicyTest.java
│ │ │ └── [4.0K] topic
│ │ │ └── [2.7K] OffsetMovedEventTest.java
│ │ ├── [6.2K] RemotingServerTest.java
│ │ ├── [4.7K] SubRemotingServerTest.java
│ │ └── [ 16K] 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
│ └── [1.3K] rmq.logback-test.xml
├── [4.0K] srvutil
│ ├── [2.0K] BUILD.bazel
│ ├── [2.1K] 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
│ │ │ ├── [4.3K] FileWatchService.java
│ │ │ ├── [2.9K] ServerUtil.java
│ │ │ └── [2.6K] ShutdownHookThread.java
│ │ └── [4.0K] util
│ │ └── [4.0K] cache
│ │ ├── [ 953] CacheEvictHandler.java
│ │ ├── [1.2K] CacheObject.java
│ │ ├── [2.8K] ExpiredLocalCache.java
│ │ ├── [1.9K] LocalCache.java
│ │ └── [2.1K] LockManager.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] srvutil
│ │ └── [5.7K] FileWatchServiceTest.java
│ └── [4.0K] resources
│ └── [1.3K] rmq.logback-test.xml
├── [4.0K] store
│ ├── [3.2K] BUILD.bazel
│ ├── [2.6K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] store
│ │ ├── [ 13K] AllocateMappedFileService.java
│ │ ├── [1.7K] AppendMessageCallback.java
│ │ ├── [5.1K] AppendMessageResult.java
│ │ ├── [1.0K] AppendMessageStatus.java
│ │ ├── [1.1K] CommitLogDispatcher.java
│ │ ├── [ 85K] CommitLog.java
│ │ ├── [1022] CompactionAppendMsgCallback.java
│ │ ├── [4.0K] config
│ │ │ ├── [ 918] BrokerRole.java
│ │ │ ├── [ 907] FlushDiskType.java
│ │ │ ├── [ 50K] MessageStoreConfig.java
│ │ │ └── [2.3K] StorePathConfigHelper.java
│ │ ├── [ 19K] ConsumeQueueExt.java
│ │ ├── [ 43K] ConsumeQueue.java
│ │ ├── [1.8K] DefaultMessageFilter.java
│ │ ├── [130K] DefaultMessageStore.java
│ │ ├── [6.5K] DispatchRequest.java
│ │ ├── [4.0K] dledger
│ │ │ └── [ 43K] DLedgerCommitLog.java
│ │ ├── [2.7K] FileQueueSnapshot.java
│ │ ├── [3.0K] FlushDiskWatcher.java
│ │ ├── [1.3K] FlushManager.java
│ │ ├── [5.7K] GetMessageResult.java
│ │ ├── [1.1K] GetMessageStatus.java
│ │ ├── [4.0K] ha
│ │ │ ├── [4.0K] autoswitch
│ │ │ │ ├── [ 29K] AutoSwitchHAClient.java
│ │ │ │ ├── [ 35K] AutoSwitchHAConnection.java
│ │ │ │ ├── [ 18K] AutoSwitchHAService.java
│ │ │ │ └── [ 11K] EpochFileCache.java
│ │ │ ├── [ 14K] DefaultHAClient.java
│ │ │ ├── [ 19K] DefaultHAConnection.java
│ │ │ ├── [ 14K] DefaultHAService.java
│ │ │ ├── [2.5K] FlowMonitor.java
│ │ │ ├── [7.0K] GroupTransferService.java
│ │ │ ├── [2.3K] HAClient.java
│ │ │ ├── [1.8K] HAConnection.java
│ │ │ ├── [1.2K] HAConnectionState.java
│ │ │ ├── [1.7K] HAConnectionStateNotificationRequest.java
│ │ │ ├── [6.0K] HAConnectionStateNotificationService.java
│ │ │ ├── [3.8K] HAService.java
│ │ │ ├── [4.0K] io
│ │ │ │ ├── [2.8K] AbstractHAReader.java
│ │ │ │ ├── [ 911] HAReadHook.java
│ │ │ │ ├── [ 914] HAWriteHook.java
│ │ │ │ └── [2.2K] HAWriter.java
│ │ │ └── [3.8K] WaitNotifyObject.java
│ │ ├── [4.0K] hook
│ │ │ ├── [1.3K] PutMessageHook.java
│ │ │ └── [1.2K] SendMessageBackHook.java
│ │ ├── [4.0K] index
│ │ │ ├── [9.5K] IndexFile.java
│ │ │ ├── [4.3K] IndexHeader.java
│ │ │ ├── [ 14K] IndexService.java
│ │ │ └── [1.6K] QueryOffsetResult.java
│ │ ├── [4.0K] kv
│ │ │ ├── [1.3K] CommitLogDispatcherCompaction.java
│ │ │ ├── [ 45K] CompactionLog.java
│ │ │ ├── [2.9K] CompactionPositionMgr.java
│ │ │ ├── [6.1K] CompactionService.java
│ │ │ ├── [8.1K] CompactionStore.java
│ │ │ └── [9.8K] MessageFetcher.java
│ │ ├── [4.0K] logfile
│ │ │ ├── [ 992] AbstractMappedFile.java
│ │ │ ├── [ 33K] DefaultMappedFile.java
│ │ │ └── [ 11K] MappedFile.java
│ │ ├── [ 27K] MappedFileQueue.java
│ │ ├── [1.4K] MessageArrivingListener.java
│ │ ├── [ 13K] MessageExtEncoder.java
│ │ ├── [1.8K] MessageFilter.java
│ │ ├── [ 28K] MessageStore.java
│ │ ├── [4.0K] metrics
│ │ │ ├── [2.2K] DefaultStoreMetricsConstant.java
│ │ │ └── [10.0K] DefaultStoreMetricsManager.java
│ │ ├── [4.7K] MultiPathMappedFileQueue.java
│ │ ├── [4.0K] plugin
│ │ │ ├── [ 19K] AbstractPluginMessageStore.java
│ │ │ ├── [2.1K] MessageStoreFactory.java
│ │ │ └── [2.5K] MessageStorePluginContext.java
│ │ ├── [4.0K] pop
│ │ │ ├── [3.1K] AckMsg.java
│ │ │ └── [4.7K] PopCheckPoint.java
│ │ ├── [1.4K] PutMessageContext.java
│ │ ├── [ 954] PutMessageLock.java
│ │ ├── [1.2K] PutMessageReentrantLock.java
│ │ ├── [2.7K] PutMessageResult.java
│ │ ├── [1.4K] PutMessageSpinLock.java
│ │ ├── [1.3K] PutMessageStatus.java
│ │ ├── [2.4K] QueryMessageResult.java
│ │ ├── [4.0K] queue
│ │ │ ├── [ 44K] BatchConsumeQueue.java
│ │ │ ├── [1.7K] BatchOffsetIndex.java
│ │ │ ├── [4.3K] ConsumeQueueInterface.java
│ │ │ ├── [ 24K] ConsumeQueueStore.java
│ │ │ ├── [3.4K] CqUnit.java
│ │ │ ├── [2.4K] FileQueueLifeCycle.java
│ │ │ ├── [4.3K] QueueOffsetAssigner.java
│ │ │ ├── [1.0K] ReferredIterator.java
│ │ │ └── [ 15K] SparseConsumeQueue.java
│ │ ├── [2.4K] ReferenceResource.java
│ │ ├── [3.7K] RunningFlags.java
│ │ ├── [2.2K] SelectMappedBufferResult.java
│ │ ├── [1.3K] SelectMappedFileResult.java
│ │ ├── [4.0K] stats
│ │ │ ├── [3.5K] BrokerStats.java
│ │ │ ├── [ 37K] BrokerStatsManager.java
│ │ │ └── [4.0K] LmqBrokerStatsManager.java
│ │ ├── [5.0K] StoreCheckpoint.java
│ │ ├── [ 24K] StoreStatsService.java
│ │ ├── [3.8K] StoreUtil.java
│ │ ├── [1.0K] Swappable.java
│ │ ├── [4.0K] timer
│ │ │ ├── [1.5K] Slot.java
│ │ │ ├── [7.6K] TimerCheckpoint.java
│ │ │ ├── [4.8K] TimerLog.java
│ │ │ ├── [ 76K] TimerMessageStore.java
│ │ │ ├── [9.6K] TimerMetrics.java
│ │ │ ├── [2.9K] TimerRequest.java
│ │ │ └── [7.8K] TimerWheel.java
│ │ ├── [1.6K] TopicQueueLock.java
│ │ ├── [3.4K] TransientStorePool.java
│ │ └── [4.0K] util
│ │ ├── [1.7K] LibC.java
│ │ └── [ 12K] PerfCounter.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] store
│ │ ├── [ 12K] AppendCallbackTest.java
│ │ ├── [ 11K] BatchPutMessageTest.java
│ │ ├── [7.6K] ConsumeQueueExtTest.java
│ │ ├── [ 19K] ConsumeQueueTest.java
│ │ ├── [ 25K] DefaultMessageStoreCleanFilesTest.java
│ │ ├── [3.2K] DefaultMessageStoreShutDownTest.java
│ │ ├── [ 40K] DefaultMessageStoreTest.java
│ │ ├── [4.0K] dledger
│ │ │ ├── [ 22K] DLedgerCommitlogTest.java
│ │ │ ├── [5.9K] DLedgerMultiPathTest.java
│ │ │ ├── [7.0K] MessageStoreTestBase.java
│ │ │ └── [ 12K] MixCommitlogTest.java
│ │ ├── [3.1K] FlushDiskWatcherTest.java
│ │ ├── [2.0K] GetMessageResultTest.java
│ │ ├── [4.0K] ha
│ │ │ ├── [4.0K] autoswitch
│ │ │ │ ├── [ 25K] AutoSwitchHATest.java
│ │ │ │ └── [6.1K] EpochFileCacheTest.java
│ │ │ ├── [2.4K] FlowMonitorTest.java
│ │ │ ├── [2.5K] HAClientTest.java
│ │ │ ├── [ 12K] HAServerTest.java
│ │ │ └── [1.5K] WaitNotifyObjectTest.java
│ │ ├── [ 14K] HATest.java
│ │ ├── [4.0K] index
│ │ │ └── [2.7K] IndexFileTest.java
│ │ ├── [4.0K] kv
│ │ │ ├── [ 12K] CompactionLogTest.java
│ │ │ ├── [2.2K] CompactionPositionMgrTest.java
│ │ │ └── [2.0K] OffsetMapTest.java
│ │ ├── [4.0K] logfile
│ │ │ └── [2.4K] DefaultMappedFileTest.java
│ │ ├── [ 19K] MappedFileQueueTest.java
│ │ ├── [2.2K] MappedFileTest.java
│ │ ├── [4.4K] MultiDispatchTest.java
│ │ ├── [7.3K] MultiPathMappedFileQueueTest.java
│ │ ├── [4.0K] pop
│ │ │ └── [2.2K] AckMsgTest.java
│ │ ├── [4.0K] queue
│ │ │ ├── [ 27K] BatchConsumeMessageTest.java
│ │ │ ├── [ 14K] BatchConsumeQueueTest.java
│ │ │ ├── [3.8K] ConsumeQueueStoreTest.java
│ │ │ ├── [ 13K] ConsumeQueueTest.java
│ │ │ ├── [5.2K] QueueTestBase.java
│ │ │ └── [6.6K] SparseConsumeQueueTest.java
│ │ ├── [4.0K] stats
│ │ │ └── [ 11K] BrokerStatsManagerTest.java
│ │ ├── [2.1K] StoreCheckpointTest.java
│ │ ├── [4.6K] StoreStatsServiceTest.java
│ │ ├── [6.6K] StoreTestBase.java
│ │ ├── [4.2K] StoreTestUtil.java
│ │ └── [4.0K] timer
│ │ ├── [1.7K] StoreTestUtils.java
│ │ ├── [5.5K] TimerCheckPointTest.java
│ │ ├── [4.1K] TimerLogTest.java
│ │ ├── [ 24K] TimerMessageStoreTest.java
│ │ ├── [3.0K] TimerMetricsTest.java
│ │ └── [5.8K] TimerWheelTest.java
│ └── [4.0K] resources
│ └── [1.3K] rmq.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
│ └── [2.0K] spotbugs-suppressions.xml
├── [4.0K] test
│ ├── [6.0K] BUILD.bazel
│ ├── [4.5K] 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
│ │ │ │ └── [3.0K] MQAsyncProducer.java
│ │ │ └── [4.0K] rmq
│ │ │ ├── [7.9K] RMQAsyncSendProducer.java
│ │ │ ├── [1.6K] RMQBroadCastConsumer.java
│ │ │ ├── [3.4K] RMQNormalConsumer.java
│ │ │ ├── [6.5K] RMQNormalProducer.java
│ │ │ ├── [6.8K] RMQPopClient.java
│ │ │ ├── [4.1K] RMQPopConsumer.java
│ │ │ ├── [1.7K] RMQSqlConsumer.java
│ │ │ └── [4.2K] RMQTransactionalProducer.java
│ │ ├── [4.0K] clientinterface
│ │ │ ├── [3.0K] AbstractMQConsumer.java
│ │ │ ├── [4.5K] AbstractMQProducer.java
│ │ │ ├── [3.9K] MQCollector.java
│ │ │ ├── [ 985] MQConsumer.java
│ │ │ └── [1.0K] MQProducer.java
│ │ ├── [4.0K] factory
│ │ │ ├── [3.7K] ConsumerFactory.java
│ │ │ ├── [2.3K] MessageFactory.java
│ │ │ ├── [4.6K] MQMessageFactory.java
│ │ │ ├── [1.5K] ProducerFactory.java
│ │ │ ├── [1.3K] SendCallBackFactory.java
│ │ │ └── [3.2K] TagMessage.java
│ │ ├── [4.0K] listener
│ │ │ ├── [4.1K] AbstractListener.java
│ │ │ └── [4.0K] rmq
│ │ │ ├── [4.0K] concurrent
│ │ │ │ ├── [1.9K] RMQBlockListener.java
│ │ │ │ ├── [2.5K] RMQDelayListener.java
│ │ │ │ └── [3.1K] RMQNormalListener.java
│ │ │ └── [4.0K] order
│ │ │ └── [3.1K] RMQOrderListener.java
│ │ ├── [4.0K] lmq
│ │ │ └── [4.0K] benchmark
│ │ │ └── [ 16K] BenchLmqStore.java
│ │ ├── [4.0K] message
│ │ │ └── [2.2K] MessageQueueMsg.java
│ │ ├── [4.0K] schema
│ │ │ ├── [6.6K] SchemaDefiner.java
│ │ │ └── [ 11K] SchemaTools.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.7K] FileUtil.java
│ │ ├── [ 16K] MQAdminTestUtils.java
│ │ ├── [1.1K] MQRandomUtils.java
│ │ ├── [3.4K] 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.8K] TestUtil.java
│ │ ├── [1.5K] TestUtils.java
│ │ └── [4.6K] VerifyUtils.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] test
│ │ ├── [4.0K] autoswitchrole
│ │ │ ├── [8.5K] AutoSwitchRoleBase.java
│ │ │ └── [ 12K] AutoSwitchRoleIntegrationTest.java
│ │ ├── [4.0K] base
│ │ │ ├── [ 14K] BaseConf.java
│ │ │ ├── [4.0K] dledger
│ │ │ │ └── [5.7K] DLedgerProduceAndConsumeIT.java
│ │ │ └── [9.5K] IntegrationTestBase.java
│ │ ├── [4.0K] client
│ │ │ ├── [4.0K] consumer
│ │ │ │ ├── [4.0K] balance
│ │ │ │ │ ├── [4.8K] NormalMsgDynamicBalanceIT.java
│ │ │ │ │ └── [4.8K] NormalMsgStaticBalanceIT.java
│ │ │ │ ├── [4.0K] broadcast
│ │ │ │ │ ├── [2.4K] BaseBroadcast.java
│ │ │ │ │ ├── [4.0K] normal
│ │ │ │ │ │ ├── [3.0K] BroadcastNormalMsgNotReceiveIT.java
│ │ │ │ │ │ ├── [3.7K] BroadcastNormalMsgRecvCrashIT.java
│ │ │ │ │ │ ├── [2.9K] BroadcastNormalMsgRecvFailIT.java
│ │ │ │ │ │ ├── [3.7K] BroadcastNormalMsgRecvStartLaterIT.java
│ │ │ │ │ │ ├── [3.2K] BroadcastNormalMsgTwoDiffGroupRecvIT.java
│ │ │ │ │ │ └── [3.2K] NormalMsgTwoSameGroupConsumerIT.java
│ │ │ │ │ ├── [4.0K] order
│ │ │ │ │ │ └── [3.2K] OrderMsgBroadcastIT.java
│ │ │ │ │ └── [4.0K] tag
│ │ │ │ │ ├── [3.2K] BroadcastTwoConsumerFilterIT.java
│ │ │ │ │ ├── [3.1K] BroadcastTwoConsumerSubDiffTagIT.java
│ │ │ │ │ └── [3.1K] BroadcastTwoConsumerSubTagIT.java
│ │ │ │ ├── [4.0K] cluster
│ │ │ │ │ ├── [4.2K] DynamicAddAndCrashIT.java
│ │ │ │ │ ├── [4.0K] DynamicAddConsumerIT.java
│ │ │ │ │ └── [4.1K] DynamicCrashConsumerIT.java
│ │ │ │ ├── [4.0K] filter
│ │ │ │ │ └── [5.7K] SqlFilterIT.java
│ │ │ │ ├── [4.0K] pop
│ │ │ │ │ ├── [1.5K] BasePop.java
│ │ │ │ │ ├── [2.6K] BasePopNormally.java
│ │ │ │ │ ├── [5.1K] BasePopOrderly.java
│ │ │ │ │ ├── [4.1K] PopBigMessageIT.java
│ │ │ │ │ ├── [9.5K] PopOrderlyIT.java
│ │ │ │ │ └── [4.0K] PopSubCheckIT.java
│ │ │ │ ├── [4.0K] tag
│ │ │ │ │ ├── [6.4K] MulTagSubIT.java
│ │ │ │ │ ├── [8.2K] TagMessageWith1ConsumerIT.java
│ │ │ │ │ ├── [9.1K] TagMessageWithMulConsumerIT.java
│ │ │ │ │ └── [4.8K] TagMessageWithSameGroupConsumerIT.java
│ │ │ │ └── [4.0K] topic
│ │ │ │ ├── [4.4K] MulConsumerMulTopicIT.java
│ │ │ │ └── [4.2K] OneConsumerMulTopicIT.java
│ │ │ └── [4.0K] producer
│ │ │ ├── [4.0K] async
│ │ │ │ ├── [5.6K] AsyncSendExceptionIT.java
│ │ │ │ ├── [3.5K] AsyncSendWithMessageQueueIT.java
│ │ │ │ ├── [4.3K] AsyncSendWithMessageQueueSelectorIT.java
│ │ │ │ └── [2.6K] AsyncSendWithOnlySendCallBackIT.java
│ │ │ ├── [4.0K] batch
│ │ │ │ └── [ 15K] BatchSendIT.java
│ │ │ ├── [4.0K] exception
│ │ │ │ ├── [4.0K] msg
│ │ │ │ │ ├── [2.5K] ChinaPropIT.java
│ │ │ │ │ ├── [4.8K] MessageExceptionIT.java
│ │ │ │ │ └── [3.6K] MessageUserPropIT.java
│ │ │ │ └── [4.0K] producer
│ │ │ │ └── [2.6K] ProducerGroupAndInstanceNameValidityIT.java
│ │ │ ├── [4.0K] oneway
│ │ │ │ ├── [3.3K] OneWaySendExceptionIT.java
│ │ │ │ ├── [2.6K] OneWaySendIT.java
│ │ │ │ ├── [2.7K] OneWaySendWithMQIT.java
│ │ │ │ └── [4.2K] OneWaySendWithSelectorIT.java
│ │ │ ├── [4.0K] order
│ │ │ │ ├── [4.9K] OrderMsgDynamicRebalanceIT.java
│ │ │ │ ├── [4.3K] OrderMsgIT.java
│ │ │ │ ├── [6.1K] OrderMsgRebalanceIT.java
│ │ │ │ └── [6.6K] OrderMsgWithTagIT.java
│ │ │ ├── [4.0K] querymsg
│ │ │ │ ├── [2.7K] QueryMsgByIdExceptionIT.java
│ │ │ │ ├── [3.0K] QueryMsgByIdIT.java
│ │ │ │ └── [5.8K] QueryMsgByKeyIT.java
│ │ │ └── [4.0K] transaction
│ │ │ └── [4.7K] TransactionalMsgIT.java
│ │ ├── [4.0K] container
│ │ │ ├── [3.1K] AddAndRemoveBrokerIT.java
│ │ │ ├── [3.5K] BrokerFailoverIT.java
│ │ │ ├── [3.3K] BrokerMemberGroupIT.java
│ │ │ ├── [ 30K] ContainerIntegrationTestBase.java
│ │ │ ├── [4.4K] GetMaxOffsetFromSlaveIT.java
│ │ │ ├── [ 13K] GetMetadataReverseIT.java
│ │ │ ├── [ 21K] PopSlaveActingMasterIT.java
│ │ │ ├── [9.1K] PullMultipleReplicasIT.java
│ │ │ ├── [4.8K] PushMultipleReplicasIT.java
│ │ │ ├── [9.3K] RebalanceLockOnSlaveIT.java
│ │ │ ├── [7.8K] ScheduledMessageIT.java
│ │ │ ├── [ 16K] ScheduleSlaveActingMasterIT.java
│ │ │ ├── [7.2K] SendMultipleReplicasIT.java
│ │ │ ├── [5.2K] SlaveBrokerIT.java
│ │ │ ├── [6.2K] SyncConsumerOffsetIT.java
│ │ │ ├── [2.0K] TransactionListenerImpl.java
│ │ │ └── [ 12K] TransactionMessageIT.java
│ │ ├── [4.0K] delay
│ │ │ ├── [1.1K] DelayConf.java
│ │ │ └── [5.3K] NormalMsgDelayIT.java
│ │ ├── [4.0K] grpc
│ │ │ └── [4.0K] v2
│ │ │ ├── [3.9K] ClusterGrpcIT.java
│ │ │ ├── [ 38K] GrpcBaseIT.java
│ │ │ └── [3.5K] LocalGrpcIT.java
│ │ ├── [4.0K] lmq
│ │ │ └── [5.7K] TestBenchLmqStore.java
│ │ ├── [4.0K] offset
│ │ │ ├── [ 10K] LagCalculationIT.java
│ │ │ ├── [5.2K] OffsetNotFoundIT.java
│ │ │ ├── [ 14K] OffsetResetForPopIT.java
│ │ │ └── [8.6K] OffsetResetIT.java
│ │ ├── [4.0K] retry
│ │ │ └── [8.9K] PopConsumerRetryIT.java
│ │ ├── [4.0K] schema
│ │ │ └── [4.2K] SchemaTest.java
│ │ ├── [4.0K] smoke
│ │ │ └── [7.2K] NormalMessageSendAndRecvIT.java
│ │ ├── [4.0K] statictopic
│ │ │ └── [ 27K] StaticTopicIT.java
│ │ └── [4.0K] tls
│ │ ├── [2.0K] TlsIT.java
│ │ ├── [2.0K] TlsMix2IT.java
│ │ └── [2.0K] TlsMixIT.java
│ └── [4.0K] resources
│ ├── [1.3K] rmq.logback-test.xml
│ ├── [4.0K] rmq-proxy-home
│ │ └── [4.0K] conf
│ │ ├── [ 949] broker.conf
│ │ ├── [ 18K] logback_proxy.xml
│ │ └── [ 28] rmq-proxy.json
│ └── [4.0K] schema
│ ├── [4.0K] api
│ │ ├── [ 970] client.consumer.AllocateMessageQueueStrategy.schema
│ │ ├── [ 11K] client.consumer.DefaultLitePullConsumer.schema
│ │ ├── [ 11K] client.consumer.DefaultMQPullConsumer.schema
│ │ ├── [ 12K] client.consumer.DefaultMQPushConsumer.schema
│ │ ├── [1.2K] client.consumer.listener.ConsumeConcurrentlyContext.schema
│ │ ├── [ 878] client.consumer.listener.ConsumeConcurrentlyStatus.schema
│ │ ├── [1.3K] client.consumer.listener.ConsumeOrderlyContext.schema
│ │ ├── [ 943] client.consumer.listener.ConsumeOrderlyStatus.schema
│ │ ├── [1003] client.consumer.listener.MessageListenerConcurrently.schema
│ │ ├── [ 993] client.consumer.listener.MessageListenerOrderly.schema
│ │ ├── [ 804] client.consumer.listener.MessageListener.schema
│ │ ├── [ 955] client.consumer.PullCallback.schema
│ │ ├── [1.4K] client.consumer.PullResult.schema
│ │ ├── [ 935] client.consumer.PullStatus.schema
│ │ ├── [ 957] client.hook.CheckForbiddenHook.schema
│ │ ├── [2.1K] client.hook.ConsumeMessageContext.schema
│ │ ├── [1.0K] client.hook.ConsumeMessageHook.schema
│ │ ├── [2.2K] client.hook.EndTransactionContext.schema
│ │ ├── [ 957] client.hook.EndTransactionHook.schema
│ │ ├── [1.7K] client.hook.FilterMessageContext.schema
│ │ ├── [ 955] client.hook.FilterMessageHook.schema
│ │ ├── [3.5K] client.hook.SendMessageContext.schema
│ │ ├── [1.0K] client.hook.SendMessageHook.schema
│ │ ├── [ 13K] client.producer.DefaultMQProducer.schema
│ │ ├── [ 960] client.producer.MessageQueueSelector.schema
│ │ ├── [ 955] client.producer.SendCallback.schema
│ │ ├── [2.5K] client.producer.SendResult.schema
│ │ ├── [ 955] client.producer.SendStatus.schema
│ │ ├── [5.2K] common.message.MessageExt.schema
│ │ ├── [1.6K] common.message.MessageQueue.schema
│ │ ├── [2.4K] common.message.Message.schema
│ │ ├── [1.1K] remoting.RPCHook.schema
│ │ └── [ 14K] tools.admin.DefaultMQAdminExt.schema
│ └── [ 12K] protocol
│ ├── [1.7K] common.protocol.header.CheckTransactionStateRequestHeader.schema
│ ├── [1.5K] common.protocol.header.CheckTransactionStateResponseHeader.schema
│ ├── [1.4K] common.protocol.header.CloneGroupOffsetRequestHeader.schema
│ ├── [1.5K] common.protocol.header.ConsumeMessageDirectlyResultRequestHeader.schema
│ ├── [2.0K] common.protocol.header.ConsumerSendMsgBackRequestHeader.schema
│ ├── [2.2K] common.protocol.header.CreateAccessConfigRequestHeader.schema
│ ├── [2.3K] common.protocol.header.CreateTopicRequestHeader.schema
│ ├── [1014] common.protocol.header.DeleteAccessConfigRequestHeader.schema
│ ├── [1.1K] common.protocol.header.DeleteSubscriptionGroupRequestHeader.schema
│ ├── [1002] common.protocol.header.DeleteTopicRequestHeader.schema
│ ├── [2.1K] common.protocol.header.EndTransactionRequestHeader.schema
│ ├── [ 848] common.protocol.header.EndTransactionResponseHeader.schema
│ ├── [1.0K] common.protocol.header.filtersrv.RegisterFilterServerRequestHeader.schema
│ ├── [1.1K] common.protocol.header.filtersrv.RegisterFilterServerResponseHeader.schema
│ ├── [1.5K] common.protocol.header.filtersrv.RegisterMessageFilterClassRequestHeader.schema
│ ├── [ 848] common.protocol.header.GetAllProducerInfoRequestHeader.schema
│ ├── [ 848] common.protocol.header.GetAllTopicConfigResponseHeader.schema
│ ├── [1.7K] common.protocol.header.GetBrokerAclConfigResponseHeader.schema
│ ├── [1.0K] common.protocol.header.GetBrokerClusterAclConfigResponseHeader.schema
│ ├── [1008] common.protocol.header.GetBrokerConfigResponseHeader.schema
│ ├── [1.0K] common.protocol.header.GetConsumerConnectionListRequestHeader.schema
│ ├── [1.0K] common.protocol.header.GetConsumerListByGroupRequestHeader.schema
│ ├── [ 848] common.protocol.header.GetConsumerListByGroupResponseHeader.schema
│ ├── [1.3K] common.protocol.header.GetConsumerRunningInfoRequestHeader.schema
│ ├── [1.3K] common.protocol.header.GetConsumerStatusRequestHeader.schema
│ ├── [ 979] common.protocol.header.GetConsumeStatsInBrokerHeader.schema
│ ├── [1.2K] common.protocol.header.GetConsumeStatsRequestHeader.schema
│ ├── [1.1K] common.protocol.header.GetEarliestMsgStoretimeRequestHeader.schema
│ ├── [1008] common.protocol.header.GetEarliestMsgStoretimeResponseHeader.schema
│ ├── [1.1K] common.protocol.header.GetMaxOffsetRequestHeader.schema
│ ├── [ 999] common.protocol.header.GetMaxOffsetResponseHeader.schema
│ ├── [1.1K] common.protocol.header.GetMinOffsetRequestHeader.schema
│ ├── [ 999] common.protocol.header.GetMinOffsetResponseHeader.schema
│ ├── [1.0K] common.protocol.header.GetProducerConnectionListRequestHeader.schema
│ ├── [1008] common.protocol.header.GetTopicsByClusterRequestHeader.schema
│ ├── [1002] common.protocol.header.GetTopicStatsInfoRequestHeader.schema
│ ├── [1017] common.protocol.header.namesrv.AddWritePermOfBrokerRequestHeader.schema
│ ├── [1.0K] common.protocol.header.namesrv.AddWritePermOfBrokerResponseHeader.schema
│ ├── [1.1K] common.protocol.header.namesrv.DeleteKVConfigRequestHeader.schema
│ ├── [1.1K] common.protocol.header.namesrv.DeleteTopicFromNamesrvRequestHeader.schema
│ ├── [1.1K] common.protocol.header.namesrv.GetKVConfigRequestHeader.schema
│ ├── [1002] common.protocol.header.namesrv.GetKVConfigResponseHeader.schema
│ ├── [1014] common.protocol.header.namesrv.GetKVListByNamespaceRequestHeader.schema
│ ├── [1.2K] common.protocol.header.namesrv.GetRouteInfoRequestHeader.schema
│ ├── [1.3K] common.protocol.header.namesrv.PutKVConfigRequestHeader.schema
│ ├── [1.5K] common.protocol.header.namesrv.QueryDataVersionRequestHeader.schema
│ ├── [1.0K] common.protocol.header.namesrv.QueryDataVersionResponseHeader.schema
│ ├── [2.0K] common.protocol.header.namesrv.RegisterBrokerRequestHeader.schema
│ ├── [1.2K] common.protocol.header.namesrv.RegisterBrokerResponseHeader.schema
│ ├── [1.2K] common.protocol.header.namesrv.RegisterOrderTopicRequestHeader.schema
│ ├── [1.5K] common.protocol.header.namesrv.UnRegisterBrokerRequestHeader.schema
│ ├── [1017] common.protocol.header.namesrv.WipeWritePermOfBrokerRequestHeader.schema
│ ├── [1.0K] common.protocol.header.namesrv.WipeWritePermOfBrokerResponseHeader.schema
│ ├── [1.0K] common.protocol.header.NotifyConsumerIdsChangedRequestHeader.schema
│ ├── [2.8K] common.protocol.header.PullMessageRequestHeader.schema
│ ├── [1.6K] common.protocol.header.PullMessageResponseHeader.schema
│ ├── [1.5K] common.protocol.header.QueryConsumeQueueRequestHeader.schema
│ ├── [1.3K] common.protocol.header.QueryConsumerOffsetRequestHeader.schema
│ ├── [ 999] common.protocol.header.QueryConsumerOffsetResponseHeader.schema
│ ├── [1.1K] common.protocol.header.QueryConsumeTimeSpanRequestHeader.schema
│ ├── [1.3K] common.protocol.header.QueryCorrectionOffsetHeader.schema
│ ├── [1.6K] common.protocol.header.QueryMessageRequestHeader.schema
│ ├── [1.2K] common.protocol.header.QueryMessageResponseHeader.schema
│ ├── [1002] common.protocol.header.QueryTopicConsumeByWhoRequestHeader.schema
│ ├── [3.1K] common.protocol.header.ReplyMessageRequestHeader.schema
│ ├── [1.4K] common.protocol.header.ResetOffsetRequestHeader.schema
│ ├── [1.0K] common.protocol.header.ResumeCheckHalfMessageRequestHeader.schema
│ ├── [1.3K] common.protocol.header.SearchOffsetRequestHeader.schema
│ ├── [ 999] common.protocol.header.SearchOffsetResponseHeader.schema
│ ├── [3.0K] common.protocol.header.SendMessageRequestHeader.schema
│ ├── [3.1K] common.protocol.header.SendMessageRequestHeaderV2.schema
│ ├── [1.6K] common.protocol.header.SendMessageResponseHeader.schema
│ ├── [1.3K] common.protocol.header.UnregisterClientRequestHeader.schema
│ ├── [ 848] common.protocol.header.UnregisterClientResponseHeader.schema
│ ├── [1.5K] common.protocol.header.UpdateConsumerOffsetRequestHeader.schema
│ ├── [ 848] common.protocol.header.UpdateConsumerOffsetResponseHeader.schema
│ ├── [1.2K] common.protocol.header.UpdateGlobalWhiteAddrsConfigRequestHeader.schema
│ ├── [1.1K] common.protocol.header.ViewBrokerStatsDataRequestHeader.schema
│ ├── [ 999] common.protocol.header.ViewMessageRequestHeader.schema
│ ├── [ 848] common.protocol.header.ViewMessageResponseHeader.schema
│ └── [5.1K] common.protocol.RequestCode.schema
├── [4.0K] tieredstore
│ ├── [2.9K] BUILD.bazel
│ ├── [2.1K] pom.xml
│ ├── [6.3K] README.md
│ ├── [4.0K] src
│ │ ├── [4.0K] main
│ │ │ └── [4.0K] java
│ │ │ └── [4.0K] org
│ │ │ └── [4.0K] apache
│ │ │ └── [4.0K] rocketmq
│ │ │ └── [4.0K] tieredstore
│ │ │ ├── [4.0K] common
│ │ │ │ ├── [ 996] AppendResult.java
│ │ │ │ ├── [1.4K] BoundaryType.java
│ │ │ │ ├── [2.8K] InflightRequestFuture.java
│ │ │ │ ├── [1.9K] InflightRequestKey.java
│ │ │ │ ├── [1.8K] MessageCacheKey.java
│ │ │ │ ├── [2.3K] SelectMappedBufferResultWrapper.java
│ │ │ │ ├── [ 12K] TieredMessageStoreConfig.java
│ │ │ │ └── [4.1K] TieredStoreExecutor.java
│ │ │ ├── [4.0K] container
│ │ │ │ ├── [4.5K] TieredCommitLog.java
│ │ │ │ ├── [4.1K] TieredConsumeQueue.java
│ │ │ │ ├── [ 10K] TieredContainerManager.java
│ │ │ │ ├── [ 22K] TieredFileQueue.java
│ │ │ │ ├── [ 21K] TieredIndexFile.java
│ │ │ │ └── [ 20K] TieredMessageQueueContainer.java
│ │ │ ├── [4.0K] exception
│ │ │ │ ├── [1.0K] TieredStoreErrorCode.java
│ │ │ │ └── [2.0K] TieredStoreException.java
│ │ │ ├── [4.0K] metadata
│ │ │ │ ├── [3.3K] FileSegmentMetadata.java
│ │ │ │ ├── [2.0K] QueueMetadata.java
│ │ │ │ ├── [ 14K] TieredMetadataManager.java
│ │ │ │ ├── [3.3K] TieredMetadataSerializeWrapper.java
│ │ │ │ ├── [2.5K] TieredMetadataStore.java
│ │ │ │ └── [2.0K] TopicMetadata.java
│ │ │ ├── [4.0K] metrics
│ │ │ │ ├── [3.2K] TieredStoreMetricsConstant.java
│ │ │ │ └── [ 18K] TieredStoreMetricsManager.java
│ │ │ ├── [4.0K] provider
│ │ │ │ ├── [4.0K] posix
│ │ │ │ │ └── [9.9K] PosixFileSegment.java
│ │ │ │ ├── [ 20K] TieredFileSegment.java
│ │ │ │ └── [2.3K] TieredStoreProvider.java
│ │ │ ├── [ 25K] TieredDispatcher.java
│ │ │ ├── [ 33K] TieredMessageFetcher.java
│ │ │ ├── [ 21K] TieredMessageStore.java
│ │ │ └── [4.0K] util
│ │ │ ├── [1.2K] CQItemBufferUtil.java
│ │ │ ├── [6.9K] MessageBufferUtil.java
│ │ │ └── [5.9K] TieredStoreUtil.java
│ │ └── [4.0K] test
│ │ ├── [4.0K] java
│ │ │ └── [4.0K] org
│ │ │ └── [4.0K] apache
│ │ │ └── [4.0K] rocketmq
│ │ │ └── [4.0K] tieredstore
│ │ │ ├── [4.0K] common
│ │ │ │ └── [2.7K] CommonTest.java
│ │ │ ├── [4.0K] container
│ │ │ │ ├── [3.7K] TieredContainerManagerTest.java
│ │ │ │ ├── [ 11K] TieredFileQueueTest.java
│ │ │ │ ├── [6.2K] TieredIndexFileTest.java
│ │ │ │ └── [ 11K] TieredMessageQueueContainerTest.java
│ │ │ ├── [4.0K] metadata
│ │ │ │ └── [9.9K] MetadataStoreTest.java
│ │ │ ├── [4.0K] metrics
│ │ │ │ └── [1.7K] TieredStoreMetricsManagerTest.java
│ │ │ ├── [4.0K] mock
│ │ │ │ └── [3.8K] MemoryFileSegment.java
│ │ │ ├── [4.0K] provider
│ │ │ │ ├── [4.0K] posix
│ │ │ │ │ └── [2.7K] PosixFileSegmentTest.java
│ │ │ │ └── [7.8K] TieredFileSegmentTest.java
│ │ │ ├── [8.7K] TieredDispatcherTest.java
│ │ │ ├── [ 17K] TieredMessageFetcherTest.java
│ │ │ ├── [ 15K] TieredMessageStoreTest.java
│ │ │ └── [4.0K] util
│ │ │ ├── [1.6K] CQItemBufferUtilTest.java
│ │ │ ├── [9.4K] MessageBufferUtilTest.java
│ │ │ └── [2.1K] TieredStoreUtilTest.java
│ │ └── [4.0K] resources
│ │ └── [1.2K] rmq.logback-test.xml
│ └── [430K] tiered_storage_arch.png
├── [4.0K] tools
│ ├── [2.3K] BUILD.bazel
│ ├── [2.4K] 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.5K] BrokerOperatorResult.java
│ │ │ │ │ ├── [1.7K] MessageTrack.java
│ │ │ │ │ └── [1001] TrackType.java
│ │ │ │ ├── [4.0K] common
│ │ │ │ │ ├── [ 939] AdminToolHandler.java
│ │ │ │ │ ├── [2.3K] AdminToolResult.java
│ │ │ │ │ └── [1.3K] AdminToolsResultCodeEnum.java
│ │ │ │ ├── [ 95K] DefaultMQAdminExtImpl.java
│ │ │ │ ├── [ 38K] DefaultMQAdminExt.java
│ │ │ │ ├── [ 24K] MQAdminExt.java
│ │ │ │ └── [ 19K] MQAdminUtils.java
│ │ │ ├── [4.0K] command
│ │ │ │ ├── [4.0K] acl
│ │ │ │ │ ├── [5.5K] ClusterAclConfigVersionListSubCommand.java
│ │ │ │ │ ├── [4.1K] DeleteAccessConfigSubCommand.java
│ │ │ │ │ ├── [5.2K] GetAccessConfigSubCommand.java
│ │ │ │ │ ├── [7.1K] UpdateAccessConfigSubCommand.java
│ │ │ │ │ └── [4.5K] UpdateGlobalWhiteAddrSubCommand.java
│ │ │ │ ├── [4.0K] broker
│ │ │ │ │ ├── [6.7K] BrokerConsumeStatsSubCommad.java
│ │ │ │ │ ├── [4.6K] BrokerStatusSubCommand.java
│ │ │ │ │ ├── [2.9K] CleanExpiredCQSubCommand.java
│ │ │ │ │ ├── [2.9K] CleanUnusedTopicCommand.java
│ │ │ │ │ ├── [3.2K] DeleteExpiredCommitLogSubCommand.java
│ │ │ │ │ ├── [5.2K] GetBrokerConfigCommand.java
│ │ │ │ │ ├── [5.1K] GetBrokerEpochSubCommand.java
│ │ │ │ │ ├── [2.7K] ResetMasterFlushOffsetSubCommand.java
│ │ │ │ │ ├── [3.8K] SendMsgStatusCommand.java
│ │ │ │ │ └── [4.4K] UpdateBrokerConfigSubCommand.java
│ │ │ │ ├── [4.0K] cluster
│ │ │ │ │ ├── [ 14K] ClusterListSubCommand.java
│ │ │ │ │ └── [7.8K] CLusterSendMsgRTCommand.java
│ │ │ │ ├── [8.2K] CommandUtil.java
│ │ │ │ ├── [4.0K] connection
│ │ │ │ │ ├── [4.2K] ConsumerConnectionSubCommand.java
│ │ │ │ │ └── [3.3K] ProducerConnectionSubCommand.java
│ │ │ │ ├── [4.0K] consumer
│ │ │ │ │ ├── [ 15K] ConsumerProgressSubCommand.java
│ │ │ │ │ ├── [6.8K] ConsumerStatusSubCommand.java
│ │ │ │ │ ├── [6.0K] ConsumerSubCommand.java
│ │ │ │ │ ├── [4.6K] DeleteSubscriptionGroupCommand.java
│ │ │ │ │ ├── [6.0K] GetConsumerConfigSubCommand.java
│ │ │ │ │ ├── [5.2K] SetConsumeModeSubCommand.java
│ │ │ │ │ ├── [2.0K] StartMonitoringSubCommand.java
│ │ │ │ │ └── [8.7K] UpdateSubGroupSubCommand.java
│ │ │ │ ├── [4.0K] container
│ │ │ │ │ ├── [2.7K] AddBrokerSubCommand.java
│ │ │ │ │ └── [3.3K] RemoveBrokerSubCommand.java
│ │ │ │ ├── [4.0K] controller
│ │ │ │ │ ├── [4.0K] CleanControllerBrokerDataSubCommand.java
│ │ │ │ │ ├── [3.3K] GetControllerConfigSubCommand.java
│ │ │ │ │ ├── [3.2K] GetControllerMetaDataSubCommand.java
│ │ │ │ │ ├── [4.0K] ReElectMasterSubCommand.java
│ │ │ │ │ └── [3.5K] UpdateControllerConfigSubCommand.java
│ │ │ │ ├── [4.0K] export
│ │ │ │ │ ├── [6.0K] ExportConfigsCommand.java
│ │ │ │ │ ├── [8.0K] ExportMetadataCommand.java
│ │ │ │ │ └── [ 13K] ExportMetricsCommand.java
│ │ │ │ ├── [4.0K] ha
│ │ │ │ │ ├── [5.9K] GetSyncStateSetSubCommand.java
│ │ │ │ │ └── [6.3K] HAStatusSubCommand.java
│ │ │ │ ├── [4.0K] message
│ │ │ │ │ ├── [5.1K] CheckMsgSendRTCommand.java
│ │ │ │ │ ├── [ 11K] ConsumeMessageCommand.java
│ │ │ │ │ ├── [2.4K] DecodeMessageIdCommond.java
│ │ │ │ │ ├── [3.8K] DumpCompactionLogCommand.java
│ │ │ │ │ ├── [9.4K] PrintMessageByQueueCommand.java
│ │ │ │ │ ├── [6.7K] PrintMessageSubCommand.java
│ │ │ │ │ ├── [ 11K] QueryMsgByIdSubCommand.java
│ │ │ │ │ ├── [3.2K] QueryMsgByKeySubCommand.java
│ │ │ │ │ ├── [4.5K] QueryMsgByOffsetSubCommand.java
│ │ │ │ │ ├── [8.9K] QueryMsgByUniqueKeySubCommand.java
│ │ │ │ │ ├── [6.4K] QueryMsgTraceByIdSubCommand.java
│ │ │ │ │ └── [5.9K] SendMessageCommand.java
│ │ │ │ ├── [ 14K] MQAdminStartup.java
│ │ │ │ ├── [4.0K] namesrv
│ │ │ │ │ ├── [3.2K] AddWritePermSubCommand.java
│ │ │ │ │ ├── [2.6K] DeleteKvConfigCommand.java
│ │ │ │ │ ├── [3.1K] GetNamesrvConfigCommand.java
│ │ │ │ │ ├── [3.0K] UpdateKvConfigCommand.java
│ │ │ │ │ ├── [3.3K] UpdateNamesrvConfigCommand.java
│ │ │ │ │ └── [3.2K] WipeWritePermSubCommand.java
│ │ │ │ ├── [4.0K] offset
│ │ │ │ │ ├── [4.2K] CloneGroupOffsetCommand.java
│ │ │ │ │ ├── [4.2K] GetConsumerStatusCommand.java
│ │ │ │ │ ├── [7.0K] ResetOffsetByTimeCommand.java
│ │ │ │ │ ├── [5.4K] ResetOffsetByTimeOldCommand.java
│ │ │ │ │ └── [5.2K] SkipAccumulationSubCommand.java
│ │ │ │ ├── [4.0K] producer
│ │ │ │ │ └── [3.5K] ProducerSubCommand.java
│ │ │ │ ├── [4.0K] queue
│ │ │ │ │ └── [6.3K] QueryConsumeQueueCommand.java
│ │ │ │ ├── [4.0K] stats
│ │ │ │ │ └── [7.6K] StatsAllSubCommand.java
│ │ │ │ ├── [1.3K] SubCommandException.java
│ │ │ │ ├── [1.3K] SubCommand.java
│ │ │ │ └── [4.0K] topic
│ │ │ │ ├── [3.7K] AllocateMQSubCommand.java
│ │ │ │ ├── [3.9K] DeleteTopicSubCommand.java
│ │ │ │ ├── [1.3K] RebalanceResult.java
│ │ │ │ ├── [9.0K] RemappingStaticTopicSubCommand.java
│ │ │ │ ├── [2.5K] TopicClusterSubCommand.java
│ │ │ │ ├── [5.5K] TopicListSubCommand.java
│ │ │ │ ├── [4.5K] TopicRouteSubCommand.java
│ │ │ │ ├── [3.7K] TopicStatusSubCommand.java
│ │ │ │ ├── [4.1K] UpdateOrderConfCommand.java
│ │ │ │ ├── [9.1K] UpdateStaticTopicSubCommand.java
│ │ │ │ ├── [7.1K] UpdateTopicPermSubCommand.java
│ │ │ │ └── [8.1K] UpdateTopicSubCommand.java
│ │ │ └── [4.0K] monitor
│ │ │ ├── [3.4K] 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] resources
│ │ └── [3.7K] rmq.tools.logback.xml
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] tools
│ │ ├── [4.0K] admin
│ │ │ └── [ 29K] DefaultMQAdminExtTest.java
│ │ ├── [4.0K] command
│ │ │ ├── [4.0K] acl
│ │ │ │ ├── [1.7K] ClusterAclConfigVersionListSubCommandTest.java
│ │ │ │ ├── [1.8K] DeleteAccessConfigSubCommandTest.java
│ │ │ │ ├── [1.7K] GetAccessConfigSubCommandTest.java
│ │ │ │ ├── [3.7K] UpdateAccessConfigSubCommandTest.java
│ │ │ │ └── [1.8K] UpdateGlobalWhiteAddrSubCommandTest.java
│ │ │ ├── [4.0K] broker
│ │ │ │ ├── [4.6K] BrokerConsumeStatsSubCommadTest.java
│ │ │ │ ├── [2.1K] BrokerStatusSubCommandTest.java
│ │ │ │ ├── [1.8K] CleanExpiredCQSubCommandTest.java
│ │ │ │ ├── [1.8K] CleanUnusedTopicCommandTest.java
│ │ │ │ ├── [2.7K] DeleteExpiredCommitLogSubCommandTest.java
│ │ │ │ ├── [2.4K] GetBrokerConfigCommandTest.java
│ │ │ │ ├── [3.7K] SendMsgStatusCommandTest.java
│ │ │ │ └── [1.9K] UpdateBrokerConfigSubCommandTest.java
│ │ │ ├── [5.5K] CommandUtilTest.java
│ │ │ ├── [4.0K] connection
│ │ │ │ ├── [2.9K] ConsumerConnectionSubCommandTest.java
│ │ │ │ └── [3.0K] ProducerConnectionSubCommandTest.java
│ │ │ ├── [4.0K] consumer
│ │ │ │ ├── [3.3K] ConsumerProgressSubCommandTest.java
│ │ │ │ ├── [2.9K] ConsumerStatusSubCommandTest.java
│ │ │ │ └── [4.0K] GetConsumerConfigSubCommandTest.java
│ │ │ ├── [4.0K] message
│ │ │ │ ├── [8.9K] ConsumeMessageCommandTest.java
│ │ │ │ ├── [ 12K] QueryMsgByUniqueKeySubCommandTest.java
│ │ │ │ ├── [4.8K] QueryMsgTraceByIdSubCommandTest.java
│ │ │ │ └── [4.2K] SendMessageCommandTest.java
│ │ │ ├── [4.0K] namesrv
│ │ │ │ ├── [2.7K] AddWritePermSubCommandTest.java
│ │ │ │ ├── [2.3K] GetNamesrvConfigCommandTest.java
│ │ │ │ ├── [2.5K] UpdateKvConfigCommandTest.java
│ │ │ │ └── [2.7K] WipeWritePermSubCommandTest.java
│ │ │ ├── [4.0K] offset
│ │ │ │ ├── [2.8K] GetConsumerStatusCommandTest.java
│ │ │ │ ├── [2.6K] ResetOffsetByTimeCommandTest.java
│ │ │ │ ├── [1.9K] ResetOffsetByTimeOldCommandTest.java
│ │ │ │ └── [3.4K] SkipAccumulationCommandTest.java
│ │ │ ├── [4.0K] producer
│ │ │ │ └── [3.2K] ProducerSubCommandTest.java
│ │ │ ├── [4.0K] server
│ │ │ │ ├── [2.2K] 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.1K] DefaultMonitorListenerTest.java
│ │ └── [8.9K] MonitorServiceTest.java
│ └── [4.0K] resources
│ └── [1.3K] rmq.logback-test.xml
└── [5.5K] WORKSPACE
711 directories, 2169 files
备注
1. 建议优先通过来源进行访问。
2. 如果因为来源失效或无法访问，请发送邮箱到 f.jinxu#gmail.com 索取本地快照（把 # 换成 @）。
3. 神龙已为您对POC代码进行快照，为了长期维护，请考虑为本地POC付费，感谢您的支持。