关联漏洞
介绍
## Apache RocketMQ [](https://travis-ci.org/apache/rocketmq) [](https://coveralls.io/github/apache/rocketmq?branch=master)
[](http://search.maven.org/#search%7Cga%7C1%7Corg.apache.rocketmq)
[](https://rocketmq.apache.org/dowloading/releases)
[](https://www.apache.org/licenses/LICENSE-2.0.html)
**[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:
* Pub/Sub messaging model
* Financial grade transactional message
* A variety of cross language clients, such as Java, C/C++, Python, Go
* Pluggable transport protocols, such as TCP, SSL, AIO
* Inbuilt message tracing capability, also support opentracing
* Versatile big-data and streaming ecosytem integration
* Message retroactivity by time or offset
* Reliable FIFO and strict ordered messaging in the same queue
* Efficient pull&push consumption model
* Million-level message accumulation capacity in a single queue
* Multiple messaging protocols like 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 authorisation
----------
## 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/>
----------
## Apache RocketMQ Community
* [RocketMQ Community Projects](https://github.com/apache/rocketmq-externals)
----------
## Contributing
We always welcome new contributions, whether for trivial cleanups, [big new features](https://github.com/apache/rocketmq/wiki/RocketMQ-Improvement-Proposal) or other material rewards, more details see [here](http://rocketmq.apache.org/docs/how-to-contribute/).
----------
## License
[Apache License, Version 2.0](http://www.apache.org/licenses/LICENSE-2.0.html) Copyright (C) Apache Software Foundation
----------
## Export Control Notice
This distribution includes cryptographic software. The country in which you currently reside may have
restrictions on the import, possession, use, and/or re-export to another country, of encryption software.
BEFORE using any encryption software, please check your country's laws, regulations and policies concerning
the import, possession, or use, and re-export of encryption software, to see if this is permitted. See
<http://www.wassenaar.org/> for more information.
The U.S. Government Department of Commerce, Bureau of Industry and Security (BIS), has classified this
software as Export Commodity Control Number (ECCN) 5D002.C.1, which includes information security software
using or performing cryptographic functions with asymmetric algorithms. The form and manner of this Apache
Software Foundation distribution makes it eligible for export under the License Exception ENC Technology
Software Unrestricted (TSU) exception (see the BIS Export Administration Regulations, Section 740.13) for
both object code and source code.
The following provides more details on the included cryptographic software:
This software uses Apache Commons Crypto (https://commons.apache.org/proper/commons-crypto/) to
support authentication, and encryption and decryption of data sent across the network between
services.
文件快照
[4.0K] /data/pocs/66049529b7f288b7da3a4741ba140097b4524a03
├── [4.0K] acl
│ ├── [3.0K] 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.2K] AccessValidator.java
│ │ ├── [4.0K] common
│ │ │ ├── [4.1K] AclClientRPCHook.java
│ │ │ ├── [1.8K] AclConstants.java
│ │ │ ├── [1.9K] AclException.java
│ │ │ ├── [4.1K] AclSigner.java
│ │ │ ├── [ 12K] AclUtils.java
│ │ │ ├── [3.6K] Permission.java
│ │ │ ├── [4.9K] SessionCredentials.java
│ │ │ └── [ 920] SigningAlgorithm.java
│ │ └── [4.0K] plain
│ │ ├── [5.1K] PlainAccessResource.java
│ │ ├── [8.0K] PlainAccessValidator.java
│ │ ├── [ 19K] 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
│ │ │ ├── [1.2K] AclSignerTest.java
│ │ │ ├── [ 12K] AclUtilsTest.java
│ │ │ ├── [6.1K] PermissionTest.java
│ │ │ └── [4.0K] SessionCredentialsTest.java
│ │ └── [4.0K] plain
│ │ ├── [ 29K] PlainAccessValidatorTest.java
│ │ ├── [ 13K] PlainPermissionManagerTest.java
│ │ └── [ 19K] RemoteAddressStrategyTest.java
│ └── [4.0K] resources
│ ├── [4.0K] conf
│ │ ├── [1.2K] plain_acl_correct.yml
│ │ ├── [1.2K] plain_acl_delete.yml
│ │ ├── [ 952] plain_acl_format_error.yml
│ │ ├── [1.2K] plain_acl_global_white_addrs.yml
│ │ ├── [ 942] plain_acl_incomplete.yml
│ │ ├── [ 809] plain_acl_null.yml
│ │ ├── [1.2K] plain_acl_update_create.yml
│ │ ├── [ 863] plain_acl_with_no_accouts.yml
│ │ ├── [1.3K] plain_acl.yml
│ │ └── [4.0K] watch
│ │ └── [1009] plain_acl_watch.yml
│ └── [1.3K] logback-test.xml
├── [4.0K] broker
│ ├── [3.3K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ ├── [4.0K] java
│ │ │ └── [4.0K] org
│ │ │ └── [4.0K] apache
│ │ │ └── [4.0K] rocketmq
│ │ │ └── [4.0K] broker
│ │ │ ├── [ 54K] BrokerController.java
│ │ │ ├── [1.9K] BrokerPathConfigHelper.java
│ │ │ ├── [ 12K] BrokerStartup.java
│ │ │ ├── [4.0K] client
│ │ │ │ ├── [3.2K] ClientChannelInfo.java
│ │ │ │ ├── [3.9K] ClientHousekeepingService.java
│ │ │ │ ├── [1.1K] ConsumerGroupEvent.java
│ │ │ │ ├── [8.9K] ConsumerGroupInfo.java
│ │ │ │ ├── [ 967] ConsumerIdsChangeListener.java
│ │ │ │ ├── [8.5K] ConsumerManager.java
│ │ │ │ ├── [2.6K] DefaultConsumerIdsChangeListener.java
│ │ │ │ ├── [4.0K] net
│ │ │ │ │ └── [ 14K] Broker2Client.java
│ │ │ │ ├── [ 11K] ProducerManager.java
│ │ │ │ └── [4.0K] rebalance
│ │ │ │ └── [ 11K] RebalanceLockManager.java
│ │ │ ├── [4.0K] dledger
│ │ │ │ └── [5.2K] DLedgerRoleChangeHandler.java
│ │ │ ├── [4.0K] filter
│ │ │ │ ├── [4.5K] CommitLogDispatcherCalcBitMap.java
│ │ │ │ ├── [4.0K] ConsumerFilterData.java
│ │ │ │ ├── [ 18K] ConsumerFilterManager.java
│ │ │ │ ├── [3.7K] ExpressionForRetryMessageFilter.java
│ │ │ │ ├── [6.1K] ExpressionMessageFilter.java
│ │ │ │ └── [1.7K] MessageEvaluationContext.java
│ │ │ ├── [4.0K] filtersrv
│ │ │ │ ├── [6.4K] FilterServerManager.java
│ │ │ │ └── [1.6K] FilterServerUtil.java
│ │ │ ├── [4.0K] latency
│ │ │ │ ├── [5.7K] BrokerFastFailure.java
│ │ │ │ ├── [2.6K] BrokerFixedThreadPoolExecutor.java
│ │ │ │ └── [1.3K] FutureTaskExt.java
│ │ │ ├── [4.0K] longpolling
│ │ │ │ ├── [1.5K] ManyPullRequest.java
│ │ │ │ ├── [1.5K] NotifyMessageArrivingListener.java
│ │ │ │ ├── [7.3K] PullRequestHoldService.java
│ │ │ │ └── [2.5K] PullRequest.java
│ │ │ ├── [4.0K] mqtrace
│ │ │ │ ├── [4.1K] ConsumeMessageContext.java
│ │ │ │ ├── [1.0K] ConsumeMessageHook.java
│ │ │ │ ├── [5.9K] SendMessageContext.java
│ │ │ │ └── [1.0K] SendMessageHook.java
│ │ │ ├── [4.0K] offset
│ │ │ │ └── [9.3K] ConsumerOffsetManager.java
│ │ │ ├── [4.0K] out
│ │ │ │ └── [ 19K] BrokerOuterAPI.java
│ │ │ ├── [4.0K] pagecache
│ │ │ │ ├── [2.8K] ManyMessageTransfer.java
│ │ │ │ ├── [2.6K] OneMessageTransfer.java
│ │ │ │ └── [2.8K] QueryMessageTransfer.java
│ │ │ ├── [4.0K] plugin
│ │ │ │ ├── [7.3K] AbstractPluginMessageStore.java
│ │ │ │ ├── [2.1K] MessageStoreFactory.java
│ │ │ │ └── [2.2K] MessageStorePluginContext.java
│ │ │ ├── [4.0K] processor
│ │ │ │ ├── [ 16K] AbstractSendMessageProcessor.java
│ │ │ │ ├── [ 81K] AdminBrokerProcessor.java
│ │ │ │ ├── [9.2K] ClientManageProcessor.java
│ │ │ │ ├── [7.4K] ConsumerManageProcessor.java
│ │ │ │ ├── [ 13K] EndTransactionProcessor.java
│ │ │ │ ├── [1.8K] ForwardRequestProcessor.java
│ │ │ │ ├── [ 31K] PullMessageProcessor.java
│ │ │ │ ├── [7.3K] QueryMessageProcessor.java
│ │ │ │ ├── [ 16K] ReplyMessageProcessor.java
│ │ │ │ └── [ 28K] SendMessageProcessor.java
│ │ │ ├── [4.0K] slave
│ │ │ │ └── [6.6K] SlaveSynchronize.java
│ │ │ ├── [4.0K] subscription
│ │ │ │ └── [8.1K] SubscriptionGroupManager.java
│ │ │ ├── [4.0K] topic
│ │ │ │ └── [ 20K] TopicConfigManager.java
│ │ │ ├── [4.0K] transaction
│ │ │ │ ├── [5.0K] AbstractTransactionalMessageCheckListener.java
│ │ │ │ ├── [4.0K] jdbc
│ │ │ │ │ ├── [1.8K] JDBCTransactionStoreConfig.java
│ │ │ │ │ └── [7.6K] JDBCTransactionStore.java
│ │ │ │ ├── [1.6K] OperationResult.java
│ │ │ │ ├── [4.0K] queue
│ │ │ │ │ ├── [4.2K] DefaultTransactionalMessageCheckListener.java
│ │ │ │ │ ├── [1.3K] GetResult.java
│ │ │ │ │ ├── [ 16K] TransactionalMessageBridge.java
│ │ │ │ │ ├── [ 22K] TransactionalMessageServiceImpl.java
│ │ │ │ │ └── [1.3K] TransactionalMessageUtil.java
│ │ │ │ ├── [2.5K] TransactionalMessageCheckService.java
│ │ │ │ ├── [3.0K] TransactionalMessageService.java
│ │ │ │ ├── [1.4K] TransactionRecord.java
│ │ │ │ └── [1.3K] TransactionStore.java
│ │ │ └── [4.0K] util
│ │ │ ├── [1.3K] PositiveAtomicCounter.java
│ │ │ └── [8.6K] ServiceProvider.java
│ │ └── [4.0K] resources
│ │ ├── [4.0K] META-INF
│ │ │ └── [4.0K] service
│ │ │ └── [ 50] org.apache.rocketmq.acl.AccessValidator
│ │ └── [ 902] transaction.sql
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] broker
│ │ ├── [1.8K] BrokerControllerTest.java
│ │ ├── [8.9K] BrokerOuterAPITest.java
│ │ ├── [1.6K] BrokerStartupTest.java
│ │ ├── [4.0K] client
│ │ │ └── [4.7K] ProducerManagerTest.java
│ │ ├── [4.0K] filter
│ │ │ ├── [6.6K] CommitLogDispatcherCalcBitMapTest.java
│ │ │ ├── [8.9K] ConsumerFilterManagerTest.java
│ │ │ └── [ 15K] MessageStoreWithFilterTest.java
│ │ ├── [4.0K] latency
│ │ │ └── [2.4K] BrokerFastFailureTest.java
│ │ ├── [4.0K] pagecache
│ │ │ ├── [2.5K] ManyMessageTransferTest.java
│ │ │ └── [2.3K] OneMessageTransferTest.java
│ │ ├── [4.0K] processor
│ │ │ ├── [5.8K] AdminBrokerProcessorTest.java
│ │ │ ├── [6.0K] ClientManageProcessorTest.java
│ │ │ ├── [7.2K] EndTransactionProcessorTest.java
│ │ │ ├── [ 12K] PullMessageProcessorTest.java
│ │ │ ├── [6.7K] ReplyMessageProcessorTest.java
│ │ │ └── [ 13K] SendMessageProcessorTest.java
│ │ ├── [4.0K] transaction
│ │ │ └── [4.0K] queue
│ │ │ ├── [4.6K] DefaultTransactionalMessageCheckListenerTest.java
│ │ │ ├── [8.9K] TransactionalMessageBridgeTest.java
│ │ │ └── [ 11K] TransactionalMessageServiceImplTest.java
│ │ └── [4.0K] util
│ │ ├── [1.1K] LogTransactionalMessageCheckListener.java
│ │ ├── [2.0K] ServiceProviderTest.java
│ │ └── [2.4K] TransactionalMessageServiceImpl.java
│ └── [4.0K] resources
│ ├── [1.2K] logback-test.xml
│ └── [4.0K] META-INF
│ └── [4.0K] service
│ ├── [ 50] org.apache.rocketmq.acl.AccessValidator
│ ├── [ 68] org.apache.rocketmq.broker.transaction.AbstractTransactionalMessageCheckListener
│ └── [ 63] org.apache.rocketmq.broker.transaction.TransactionalMessageService
├── [ 997] BUILDING
├── [4.0K] client
│ ├── [2.5K] 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
│ │ ├── [ 11K] ClientConfig.java
│ │ ├── [4.0K] common
│ │ │ ├── [1.3K] ClientErrorCode.java
│ │ │ └── [1.6K] ThreadLocalIndex.java
│ │ ├── [4.0K] consumer
│ │ │ ├── [1.6K] AllocateMessageQueueStrategy.java
│ │ │ ├── [ 13K] DefaultLitePullConsumer.java
│ │ │ ├── [ 17K] DefaultMQPullConsumer.java
│ │ │ ├── [ 32K] 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
│ │ │ ├── [6.2K] LitePullConsumer.java
│ │ │ ├── [1.4K] MessageQueueListener.java
│ │ │ ├── [2.1K] MessageSelector.java
│ │ │ ├── [2.1K] MQConsumer.java
│ │ │ ├── [6.7K] MQPullConsumer.java
│ │ │ ├── [8.2K] MQPullConsumerScheduleService.java
│ │ │ ├── [3.6K] MQPushConsumer.java
│ │ │ ├── [1016] PullCallback.java
│ │ │ ├── [2.2K] PullResult.java
│ │ │ ├── [1.1K] PullStatus.java
│ │ │ ├── [1018] PullTaskCallback.java
│ │ │ ├── [1.4K] PullTaskContext.java
│ │ │ ├── [4.0K] rebalance
│ │ │ │ ├── [6.4K] AllocateMachineRoomNearby.java
│ │ │ │ ├── [2.5K] AllocateMessageQueueAveragelyByCircle.java
│ │ │ │ ├── [2.8K] AllocateMessageQueueAveragely.java
│ │ │ │ ├── [1.6K] AllocateMessageQueueByConfig.java
│ │ │ │ ├── [2.6K] AllocateMessageQueueByMachineRoom.java
│ │ │ │ └── [4.2K] AllocateMessageQueueConsistentHash.java
│ │ │ ├── [4.0K] store
│ │ │ │ ├── [8.7K] LocalFileOffsetStore.java
│ │ │ │ ├── [1.6K] OffsetSerializeWrapper.java
│ │ │ │ ├── [2.3K] OffsetStore.java
│ │ │ │ ├── [1.1K] ReadOffsetType.java
│ │ │ │ └── [10.0K] RemoteBrokerOffsetStore.java
│ │ │ └── [1.2K] TopicMessageQueueChangeListener.java
│ │ ├── [4.0K] exception
│ │ │ ├── [1.5K] MQBrokerException.java
│ │ │ ├── [2.0K] MQClientException.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.1K] FilterMessageContext.java
│ │ │ ├── [ 967] FilterMessageHook.java
│ │ │ ├── [3.9K] SendMessageContext.java
│ │ │ └── [1.0K] SendMessageHook.java
│ │ ├── [4.0K] impl
│ │ │ ├── [ 14K] ClientRemotingProcessor.java
│ │ │ ├── [ 911] CommunicationMode.java
│ │ │ ├── [4.0K] consumer
│ │ │ │ ├── [8.8K] AssignedMessageQueue.java
│ │ │ │ ├── [ 20K] ConsumeMessageConcurrentlyService.java
│ │ │ │ ├── [ 26K] ConsumeMessageOrderlyService.java
│ │ │ │ ├── [1.5K] ConsumeMessageService.java
│ │ │ │ ├── [ 46K] DefaultLitePullConsumerImpl.java
│ │ │ │ ├── [ 34K] DefaultMQPullConsumerImpl.java
│ │ │ │ ├── [ 52K] DefaultMQPushConsumerImpl.java
│ │ │ │ ├── [1.6K] MessageQueueLock.java
│ │ │ │ ├── [1.8K] MQConsumerInner.java
│ │ │ │ ├── [ 15K] ProcessQueue.java
│ │ │ │ ├── [ 11K] PullAPIWrapper.java
│ │ │ │ ├── [4.5K] PullMessageService.java
│ │ │ │ ├── [3.1K] PullRequest.java
│ │ │ │ ├── [1.8K] PullResultExt.java
│ │ │ │ ├── [ 20K] RebalanceImpl.java
│ │ │ │ ├── [3.1K] RebalanceLitePullImpl.java
│ │ │ │ ├── [3.2K] RebalancePullImpl.java
│ │ │ │ ├── [9.8K] RebalancePushImpl.java
│ │ │ │ └── [1.9K] RebalanceService.java
│ │ │ ├── [4.0K] factory
│ │ │ │ └── [ 52K] MQClientInstance.java
│ │ │ ├── [1.5K] FindBrokerResult.java
│ │ │ ├── [ 21K] MQAdminImpl.java
│ │ │ ├── [107K] MQClientAPIImpl.java
│ │ │ ├── [2.8K] MQClientManager.java
│ │ │ └── [4.0K] producer
│ │ │ ├── [ 73K] DefaultMQProducerImpl.java
│ │ │ ├── [1.6K] MQProducerInner.java
│ │ │ └── [4.1K] TopicPublishInfo.java
│ │ ├── [4.0K] latency
│ │ │ ├── [6.2K] LatencyFaultToleranceImpl.java
│ │ │ ├── [1.1K] LatencyFaultTolerance.java
│ │ │ └── [4.4K] MQFaultStrategy.java
│ │ ├── [4.0K] log
│ │ │ └── [5.3K] ClientLogger.java
│ │ ├── [3.6K] MQAdmin.java
│ │ ├── [3.2K] MQHelper.java
│ │ ├── [4.0K] producer
│ │ │ ├── [ 45K] DefaultMQProducer.java
│ │ │ ├── [1.1K] LocalTransactionExecuter.java
│ │ │ ├── [ 940] LocalTransactionState.java
│ │ │ ├── [1.1K] MessageQueueSelector.java
│ │ │ ├── [6.2K] MQProducer.java
│ │ │ ├── [1023] RequestCallback.java
│ │ │ ├── [2.6K] RequestFutureTable.java
│ │ │ ├── [3.6K] RequestResponseFuture.java
│ │ │ ├── [4.0K] selector
│ │ │ │ ├── [1.4K] SelectMessageQueueByHash.java
│ │ │ │ ├── [1.5K] SelectMessageQueueByMachineRoom.java
│ │ │ │ └── [1.4K] SelectMessageQueueByRandom.java
│ │ │ ├── [ 973] SendCallback.java
│ │ │ ├── [3.8K] SendResult.java
│ │ │ ├── [ 962] SendStatus.java
│ │ │ ├── [1.1K] TransactionCheckListener.java
│ │ │ ├── [1.6K] TransactionListener.java
│ │ │ ├── [5.3K] TransactionMQProducer.java
│ │ │ └── [1.2K] TransactionSendResult.java
│ │ ├── [1.6K] QueryResult.java
│ │ ├── [4.0K] stat
│ │ │ └── [5.8K] ConsumerStatsManager.java
│ │ ├── [4.0K] trace
│ │ │ ├── [ 17K] AsyncTraceDispatcher.java
│ │ │ ├── [4.0K] hook
│ │ │ │ ├── [5.0K] ConsumeMessageTraceHookImpl.java
│ │ │ │ └── [4.3K] SendMessageTraceHookImpl.java
│ │ │ ├── [3.0K] TraceBean.java
│ │ │ ├── [1.3K] TraceConstants.java
│ │ │ ├── [3.6K] TraceContext.java
│ │ │ ├── [8.5K] TraceDataEncoder.java
│ │ │ ├── [1.5K] TraceDispatcher.java
│ │ │ ├── [ 908] TraceDispatcherType.java
│ │ │ ├── [1.3K] TraceTransferBean.java
│ │ │ └── [ 909] TraceType.java
│ │ ├── [4.0K] utils
│ │ │ └── [3.0K] MessageUtil.java
│ │ └── [4.7K] Validators.java
│ └── [4.0K] test
│ └── [4.0K] java
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] client
│ ├── [4.0K] common
│ │ └── [1.2K] ThreadLocalIndexTest.java
│ ├── [4.0K] consumer
│ │ ├── [ 23K] DefaultLitePullConsumerTest.java
│ │ ├── [7.4K] DefaultMQPullConsumerTest.java
│ │ ├── [ 14K] DefaultMQPushConsumerTest.java
│ │ ├── [4.0K] rebalance
│ │ │ ├── [9.6K] AllocateMachineRoomNearByTest.java
│ │ │ └── [ 10K] AllocateMessageQueueConsitentHashTest.java
│ │ └── [4.0K] store
│ │ ├── [3.8K] LocalFileOffsetStoreTest.java
│ │ └── [6.7K] RemoteBrokerOffsetStoreTest.java
│ ├── [4.0K] impl
│ │ ├── [4.0K] consumer
│ │ │ ├── [ 10K] ConsumeMessageConcurrentlyServiceTest.java
│ │ │ ├── [3.8K] ConsumeMessageOrderlyServiceTest.java
│ │ │ ├── [2.4K] DefaultMQPushConsumerImplTest.java
│ │ │ ├── [3.6K] ProcessQueueTest.java
│ │ │ └── [9.1K] RebalancePushImplTest.java
│ │ ├── [4.0K] factory
│ │ │ └── [4.9K] MQClientInstanceTest.java
│ │ └── [ 21K] MQClientAPIImplTest.java
│ ├── [4.0K] latency
│ │ └── [2.6K] LatencyFaultToleranceImplTest.java
│ ├── [4.0K] producer
│ │ ├── [ 21K] DefaultMQProducerTest.java
│ │ ├── [1.7K] RequestResponseFutureTest.java
│ │ └── [4.0K] selector
│ │ └── [1.8K] SelectMessageQueueByHashTest.java
│ ├── [4.0K] trace
│ │ ├── [ 15K] DefaultMQConsumerWithTraceTest.java
│ │ └── [9.4K] DefaultMQProducerWithTraceTest.java
│ ├── [4.0K] utils
│ │ └── [3.4K] MessageUtilsTest.java
│ └── [3.3K] ValidatorsTest.java
├── [4.0K] common
│ ├── [1.9K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] common
│ │ ├── [1.4K] AclConfig.java
│ │ ├── [4.0K] admin
│ │ │ ├── [2.0K] ConsumeStats.java
│ │ │ ├── [1.5K] OffsetWrapper.java
│ │ │ ├── [2.1K] RollbackStats.java
│ │ │ ├── [1.5K] TopicOffset.java
│ │ │ └── [1.4K] TopicStatsTable.java
│ │ ├── [4.0K] annotation
│ │ │ └── [1.2K] ImportantField.java
│ │ ├── [ 25K] BrokerConfig.java
│ │ ├── [1.5K] BrokerConfigSingleton.java
│ │ ├── [2.9K] ConfigManager.java
│ │ ├── [9.0K] Configuration.java
│ │ ├── [4.0K] consistenthash
│ │ │ ├── [4.6K] ConsistentHashRouter.java
│ │ │ ├── [ 952] HashFunction.java
│ │ │ ├── [1.0K] Node.java
│ │ │ └── [1.4K] VirtualNode.java
│ │ ├── [4.0K] constant
│ │ │ ├── [ 950] DBMsgConstants.java
│ │ │ ├── [2.4K] LoggerName.java
│ │ │ └── [1.8K] PermName.java
│ │ ├── [4.0K] consumer
│ │ │ └── [1.1K] ConsumeFromWhere.java
│ │ ├── [6.7K] CountDownLatch2.java
│ │ ├── [2.7K] DataVersion.java
│ │ ├── [4.0K] filter
│ │ │ ├── [2.3K] ExpressionType.java
│ │ │ ├── [3.2K] FilterAPI.java
│ │ │ ├── [1.1K] FilterContext.java
│ │ │ ├── [4.0K] impl
│ │ │ │ ├── [ 955] Operand.java
│ │ │ │ ├── [2.4K] Operator.java
│ │ │ │ ├── [1.1K] Op.java
│ │ │ │ ├── [6.8K] PolishExpr.java
│ │ │ │ └── [ 943] Type.java
│ │ │ └── [1007] MessageFilter.java
│ │ ├── [4.0K] help
│ │ │ └── [3.1K] FAQUrl.java
│ │ ├── [4.0K] hook
│ │ │ └── [1.0K] FilterCheckHook.java
│ │ ├── [4.0K] message
│ │ │ ├── [3.7K] MessageAccessor.java
│ │ │ ├── [2.9K] MessageBatch.java
│ │ │ ├── [1.4K] MessageClientExt.java
│ │ │ ├── [5.3K] MessageClientIDSetter.java
│ │ │ ├── [5.0K] MessageConst.java
│ │ │ ├── [ 19K] MessageDecoder.java
│ │ │ ├── [1.3K] MessageExtBatch.java
│ │ │ ├── [7.4K] MessageExt.java
│ │ │ ├── [1.4K] MessageId.java
│ │ │ ├── [6.0K] Message.java
│ │ │ ├── [3.8K] MessageQueueForC.java
│ │ │ ├── [3.3K] MessageQueue.java
│ │ │ └── [ 949] MessageType.java
│ │ ├── [ 18K] MixAll.java
│ │ ├── [ 14K] MQVersion.java
│ │ ├── [4.0K] namesrv
│ │ │ ├── [2.9K] NamesrvConfig.java
│ │ │ ├── [ 961] NamesrvUtil.java
│ │ │ ├── [1.5K] RegisterBrokerResult.java
│ │ │ └── [3.6K] TopAddressing.java
│ │ ├── [1.3K] Pair.java
│ │ ├── [2.5K] PlainAccessConfig.java
│ │ ├── [4.0K] protocol
│ │ │ ├── [4.0K] body
│ │ │ │ ├── [1.6K] BrokerStatsData.java
│ │ │ │ ├── [1.3K] BrokerStatsItem.java
│ │ │ │ ├── [1.6K] CheckClientRequestBody.java
│ │ │ │ ├── [1.9K] ClusterAclVersionInfo.java
│ │ │ │ ├── [2.4K] ClusterInfo.java
│ │ │ │ ├── [ 985] CMResult.java
│ │ │ │ ├── [1.7K] Connection.java
│ │ │ │ ├── [2.0K] ConsumeByWho.java
│ │ │ │ ├── [2.2K] ConsumeMessageDirectlyResult.java
│ │ │ │ ├── [2.5K] ConsumeQueueData.java
│ │ │ │ ├── [3.0K] ConsumerConnection.java
│ │ │ │ ├── [1.5K] ConsumerOffsetSerializeWrapper.java
│ │ │ │ ├── [ 11K] ConsumerRunningInfo.java
│ │ │ │ ├── [1.9K] ConsumeStatsList.java
│ │ │ │ ├── [2.1K] ConsumeStatus.java
│ │ │ │ ├── [1.8K] GetConsumerStatusBody.java
│ │ │ │ ├── [1.2K] GroupList.java
│ │ │ │ ├── [1.2K] KVTable.java
│ │ │ │ ├── [1.7K] LockBatchRequestBody.java
│ │ │ │ ├── [1.3K] LockBatchResponseBody.java
│ │ │ │ ├── [5.0K] ProcessQueueInfo.java
│ │ │ │ ├── [1.3K] ProducerConnection.java
│ │ │ │ ├── [2.2K] QueryConsumeQueueResponseBody.java
│ │ │ │ ├── [1.3K] QueryConsumeTimeSpanBody.java
│ │ │ │ ├── [1.3K] QueryCorrectionOffsetBody.java
│ │ │ │ ├── [2.4K] QueueTimeSpan.java
│ │ │ │ ├── [8.3K] RegisterBrokerBody.java
│ │ │ │ ├── [1.3K] ResetOffsetBodyForC.java
│ │ │ │ ├── [1.3K] ResetOffsetBody.java
│ │ │ │ ├── [1.9K] SubscriptionGroupWrapper.java
│ │ │ │ ├── [1.8K] TopicConfigSerializeWrapper.java
│ │ │ │ ├── [1.4K] TopicList.java
│ │ │ │ └── [1.7K] UnlockBatchRequestBody.java
│ │ │ ├── [4.0K] header
│ │ │ │ ├── [2.4K] CheckTransactionStateRequestHeader.java
│ │ │ │ ├── [2.7K] CheckTransactionStateResponseHeader.java
│ │ │ │ ├── [2.0K] CloneGroupOffsetRequestHeader.java
│ │ │ │ ├── [2.1K] ConsumeMessageDirectlyResultRequestHeader.java
│ │ │ │ ├── [2.9K] ConsumerSendMsgBackRequestHeader.java
│ │ │ │ ├── [2.9K] CreateAccessConfigRequestHeader.java
│ │ │ │ ├── [3.3K] CreateTopicRequestHeader.java
│ │ │ │ ├── [1.4K] DeleteAccessConfigRequestHeader.java
│ │ │ │ ├── [1.4K] DeleteSubscriptionGroupRequestHeader.java
│ │ │ │ ├── [1.4K] DeleteTopicRequestHeader.java
│ │ │ │ ├── [3.9K] EndTransactionRequestHeader.java
│ │ │ │ ├── [1.2K] EndTransactionResponseHeader.java
│ │ │ │ ├── [4.0K] filtersrv
│ │ │ │ │ ├── [1.4K] RegisterFilterServerRequestHeader.java
│ │ │ │ │ ├── [1.6K] RegisterFilterServerResponseHeader.java
│ │ │ │ │ └── [2.0K] RegisterMessageFilterClassRequestHeader.java
│ │ │ │ ├── [1.2K] GetAllTopicConfigResponseHeader.java
│ │ │ │ ├── [2.0K] GetBrokerAclConfigResponseHeader.java
│ │ │ │ ├── [1.6K] GetBrokerClusterAclConfigResponseBody.java
│ │ │ │ ├── [1.6K] GetBrokerClusterAclConfigResponseHeader.java
│ │ │ │ ├── [1.5K] GetBrokerConfigResponseHeader.java
│ │ │ │ ├── [1.5K] GetConsumerConnectionListRequestHeader.java
│ │ │ │ ├── [1.4K] GetConsumerListByGroupRequestHeader.java
│ │ │ │ ├── [1.2K] GetConsumerListByGroupResponseBody.java
│ │ │ │ ├── [1.1K] GetConsumerListByGroupResponseHeader.java
│ │ │ │ ├── [1.9K] GetConsumerRunningInfoRequestHeader.java
│ │ │ │ ├── [1.8K] GetConsumerStatusRequestHeader.java
│ │ │ │ ├── [1.4K] GetConsumeStatsInBrokerHeader.java
│ │ │ │ ├── [1.6K] GetConsumeStatsRequestHeader.java
│ │ │ │ ├── [1.7K] GetEarliestMsgStoretimeRequestHeader.java
│ │ │ │ ├── [1.5K] GetEarliestMsgStoretimeResponseHeader.java
│ │ │ │ ├── [1.6K] GetMaxOffsetRequestHeader.java
│ │ │ │ ├── [1.4K] GetMaxOffsetResponseHeader.java
│ │ │ │ ├── [1.6K] GetMinOffsetRequestHeader.java
│ │ │ │ ├── [1.4K] GetMinOffsetResponseHeader.java
│ │ │ │ ├── [1.5K] GetProducerConnectionListRequestHeader.java
│ │ │ │ ├── [1.4K] GetTopicsByClusterRequestHeader.java
│ │ │ │ ├── [1.4K] GetTopicStatsInfoRequestHeader.java
│ │ │ │ ├── [4.0K] namesrv
│ │ │ │ │ ├── [1.5K] DeleteKVConfigRequestHeader.java
│ │ │ │ │ ├── [1.4K] DeleteTopicInNamesrvRequestHeader.java
│ │ │ │ │ ├── [1.5K] GetKVConfigRequestHeader.java
│ │ │ │ │ ├── [1.4K] GetKVConfigResponseHeader.java
│ │ │ │ │ ├── [1.4K] GetKVListByNamespaceRequestHeader.java
│ │ │ │ │ ├── [1.5K] GetRouteInfoRequestHeader.java
│ │ │ │ │ ├── [1.7K] PutKVConfigRequestHeader.java
│ │ │ │ │ ├── [2.0K] QueryDataVersionRequestHeader.java
│ │ │ │ │ ├── [1.6K] QueryDataVersionResponseHeader.java
│ │ │ │ │ ├── [2.7K] RegisterBrokerRequestHeader.java
│ │ │ │ │ ├── [1.6K] RegisterBrokerResponseHeader.java
│ │ │ │ │ ├── [1.7K] RegisterOrderTopicRequestHeader.java
│ │ │ │ │ ├── [2.1K] UnRegisterBrokerRequestHeader.java
│ │ │ │ │ ├── [1.4K] WipeWritePermOfBrokerRequestHeader.java
│ │ │ │ │ └── [1.4K] WipeWritePermOfBrokerResponseHeader.java
│ │ │ │ ├── [1.4K] NotifyConsumerIdsChangedRequestHeader.java
│ │ │ │ ├── [3.7K] PullMessageRequestHeader.java
│ │ │ │ ├── [2.2K] PullMessageResponseHeader.java
│ │ │ │ ├── [2.0K] QueryConsumeQueueRequestHeader.java
│ │ │ │ ├── [1.9K] QueryConsumerOffsetRequestHeader.java
│ │ │ │ ├── [1.5K] QueryConsumerOffsetResponseHeader.java
│ │ │ │ ├── [1.5K] QueryConsumeTimeSpanRequestHeader.java
│ │ │ │ ├── [1.9K] QueryCorrectionOffsetHeader.java
│ │ │ │ ├── [2.2K] QueryMessageRequestHeader.java
│ │ │ │ ├── [1.9K] QueryMessageResponseHeader.java
│ │ │ │ ├── [1.5K] QueryTopicConsumeByWhoRequestHeader.java
│ │ │ │ ├── [4.2K] ReplyMessageRequestHeader.java
│ │ │ │ ├── [1.9K] ResetOffsetRequestHeader.java
│ │ │ │ ├── [1.5K] ResumeCheckHalfMessageRequestHeader.java
│ │ │ │ ├── [1.8K] SearchOffsetRequestHeader.java
│ │ │ │ ├── [1.4K] SearchOffsetResponseHeader.java
│ │ │ │ ├── [4.1K] SendMessageRequestHeader.java
│ │ │ │ ├── [4.7K] SendMessageRequestHeaderV2.java
│ │ │ │ ├── [2.1K] SendMessageResponseHeader.java
│ │ │ │ ├── [1.9K] UnregisterClientRequestHeader.java
│ │ │ │ ├── [1.1K] UnregisterClientResponseHeader.java
│ │ │ │ ├── [2.1K] UpdateConsumerOffsetRequestHeader.java
│ │ │ │ ├── [1.2K] UpdateConsumerOffsetResponseHeader.java
│ │ │ │ ├── [1.4K] UpdateGlobalWhiteAddrsConfigRequestHeader.java
│ │ │ │ ├── [1.6K] ViewBrokerStatsDataRequestHeader.java
│ │ │ │ ├── [1.4K] ViewMessageRequestHeader.java
│ │ │ │ └── [1.2K] ViewMessageResponseHeader.java
│ │ │ ├── [4.0K] heartbeat
│ │ │ │ ├── [2.8K] ConsumerData.java
│ │ │ │ ├── [1.2K] ConsumeType.java
│ │ │ │ ├── [2.1K] HeartbeatData.java
│ │ │ │ ├── [1.3K] MessageModel.java
│ │ │ │ ├── [1.2K] ProducerData.java
│ │ │ │ └── [5.6K] SubscriptionData.java
│ │ │ ├── [2.1K] MQProtosHelper.java
│ │ │ ├── [6.7K] NamespaceUtil.java
│ │ │ ├── [6.4K] RequestCode.java
│ │ │ ├── [2.7K] ResponseCode.java
│ │ │ ├── [4.0K] route
│ │ │ │ ├── [3.7K] BrokerData.java
│ │ │ │ ├── [3.4K] QueueData.java
│ │ │ │ └── [4.7K] TopicRouteData.java
│ │ │ └── [4.0K] topic
│ │ │ └── [2.1K] OffsetMovedEvent.java
│ │ ├── [4.0K] queue
│ │ │ ├── [2.3K] ConcurrentTreeMap.java
│ │ │ └── [1.4K] RoundQueue.java
│ │ ├── [4.0K] running
│ │ │ └── [1002] RunningStats.java
│ │ ├── [1.1K] ServiceState.java
│ │ ├── [4.8K] ServiceThread.java
│ │ ├── [4.0K] stats
│ │ │ ├── [2.5K] MomentStatsItem.java
│ │ │ ├── [3.3K] MomentStatsItemSet.java
│ │ │ ├── [7.9K] StatsItem.java
│ │ │ ├── [7.1K] StatsItemSet.java
│ │ │ └── [1.3K] StatsSnapshot.java
│ │ ├── [4.0K] subscription
│ │ │ └── [5.7K] SubscriptionGroupConfig.java
│ │ ├── [4.0K] sysflag
│ │ │ ├── [1.7K] MessageSysFlag.java
│ │ │ ├── [2.2K] PullSysFlag.java
│ │ │ ├── [1.5K] SubscriptionSysFlag.java
│ │ │ └── [1.9K] TopicSysFlag.java
│ │ ├── [ 941] SystemClock.java
│ │ ├── [1.6K] ThreadFactoryImpl.java
│ │ ├── [5.3K] TopicConfig.java
│ │ ├── [ 902] TopicFilterType.java
│ │ ├── [ 20K] UtilAll.java
│ │ └── [4.0K] utils
│ │ ├── [1.3K] ChannelUtil.java
│ │ ├── [1005] CorrelationIdUtil.java
│ │ ├── [5.0K] HttpTinyClient.java
│ │ ├── [5.0K] IOTinyUtils.java
│ │ ├── [1.9K] NameServerAddressUtils.java
│ │ └── [6.6K] ThreadUtils.java
│ └── [4.0K] test
│ └── [4.0K] java
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] common
│ ├── [4.0K] admin
│ │ └── [3.4K] TopicStatsTableTest.java
│ ├── [2.0K] BrokerConfigTest.java
│ ├── [3.7K] ConfigManagerTest.java
│ ├── [3.8K] CountDownLatch2Test.java
│ ├── [2.5K] DataVersionTest.java
│ ├── [4.0K] filter
│ │ └── [3.2K] FilterAPITest.java
│ ├── [4.0K] message
│ │ ├── [1.4K] MessageClientIDSetterTest.java
│ │ ├── [9.4K] MessageDecoderTest.java
│ │ └── [2.3K] MessageTest.java
│ ├── [2.6K] MessageBatchTest.java
│ ├── [2.9K] MessageEncodeDecodeTest.java
│ ├── [3.6K] MixAllTest.java
│ ├── [1.7K] MQVersionTest.java
│ ├── [4.0K] protocol
│ │ ├── [4.0K] body
│ │ │ ├── [3.3K] BrokerStatsDataTest.java
│ │ │ ├── [2.0K] CheckClientRequestBodyTest.java
│ │ │ ├── [2.1K] ConsumeMessageDirectlyResultTest.java
│ │ │ ├── [3.6K] ConsumerConnectionTest.java
│ │ │ ├── [4.2K] ConsumerRunningInfoTest.java
│ │ │ ├── [2.7K] ConsumeStatsListTest.java
│ │ │ ├── [1.7K] KVTableTest.java
│ │ │ ├── [2.8K] QueryConsumeQueueResponseBodyTest.java
│ │ │ ├── [1.8K] QueryCorrectionOffsetBodyTest.java
│ │ │ ├── [1.8K] ResetOffsetBodyTest.java
│ │ │ └── [2.5K] SubscriptionGroupWrapperTest.java
│ │ ├── [3.9K] ClusterInfoTest.java
│ │ ├── [1.7K] ConsumeStatusTest.java
│ │ ├── [1.9K] GroupListTest.java
│ │ ├── [4.0K] heartbeat
│ │ │ └── [4.0K] SubscriptionDataTest.java
│ │ ├── [4.8K] NamespaceUtilTest.java
│ │ ├── [7.2K] QueryConsumeTimeSpanBodyTest.java
│ │ ├── [4.0K] route
│ │ │ └── [4.3K] TopicRouteDataTest.java
│ │ └── [4.0K] topic
│ │ └── [2.6K] OffsetMovedEventTest.java
│ ├── [2.3K] RegisterBrokerBodyTest.java
│ ├── [1.2K] RemotingUtilTest.java
│ ├── [4.6K] ServiceThreadTest.java
│ ├── [4.0K] stats
│ │ └── [3.4K] StatsItemSetTest.java
│ ├── [5.6K] UtilAllTest.java
│ └── [4.0K] utils
│ └── [5.1K] IOTinyUtilsTest.java
├── [1.9K] CONTRIBUTING.md
├── [4.0K] dev
│ └── [ 17K] merge_rocketmq_pr.py
├── [4.0K] distribution
│ ├── [4.0K] benchmark
│ │ ├── [ 862] consumer.sh
│ │ ├── [ 909] producer.sh
│ │ ├── [2.6K] runclass.sh
│ │ └── [ 890] tproducer.sh
│ ├── [4.0K] bin
│ │ ├── [1.6K] cachedog.sh
│ │ ├── [ 845] cleancache.sh
│ │ ├── [1.1K] cleancache.v1.sh
│ │ ├── [4.0K] dledger
│ │ │ └── [2.8K] fast-try.sh
│ │ ├── [1.4K] mqadmin
│ │ ├── [1.0K] mqadmin.cmd
│ │ ├── [1.4K] mqbroker
│ │ ├── [1.1K] mqbroker.cmd
│ │ ├── [1.3K] mqbroker.numanode0
│ │ ├── [1.3K] mqbroker.numanode1
│ │ ├── [1.3K] mqbroker.numanode2
│ │ ├── [1.3K] mqbroker.numanode3
│ │ ├── [1.4K] mqnamesrv
│ │ ├── [1.1K] mqnamesrv.cmd
│ │ ├── [1.5K] mqshutdown
│ │ ├── [1.4K] mqshutdown.cmd
│ │ ├── [2.2K] os.sh
│ │ ├── [1.1K] play.cmd
│ │ ├── [1008] play.sh
│ │ ├── [ 772] README.md
│ │ ├── [2.2K] runbroker.cmd
│ │ ├── [3.6K] runbroker.sh
│ │ ├── [1.8K] runserver.cmd
│ │ ├── [3.3K] runserver.sh
│ │ ├── [1.1K] setcache.sh
│ │ ├── [1.4K] startfsrv.sh
│ │ ├── [1.6K] tools.cmd
│ │ └── [1.9K] tools.sh
│ ├── [4.0K] conf
│ │ ├── [4.0K] 2m-2s-async
│ │ │ ├── [ 929] broker-a.properties
│ │ │ ├── [ 922] broker-a-s.properties
│ │ │ ├── [ 929] broker-b.properties
│ │ │ └── [ 922] broker-b-s.properties
│ │ ├── [4.0K] 2m-2s-sync
│ │ │ ├── [ 928] broker-a.properties
│ │ │ ├── [ 922] broker-a-s.properties
│ │ │ ├── [ 928] broker-b.properties
│ │ │ └── [ 922] broker-b-s.properties
│ │ ├── [4.0K] 2m-noslave
│ │ │ ├── [ 929] broker-a.properties
│ │ │ ├── [ 929] broker-b.properties
│ │ │ └── [ 937] broker-trace.properties
│ │ ├── [ 949] broker.conf
│ │ ├── [4.0K] dledger
│ │ │ ├── [1.1K] broker-n0.conf
│ │ │ ├── [1.1K] broker-n1.conf
│ │ │ └── [1.1K] broker-n2.conf
│ │ ├── [ 15K] logback_broker.xml
│ │ ├── [3.7K] logback_namesrv.xml
│ │ ├── [3.7K] logback_tools.xml
│ │ ├── [1.3K] plain_acl.yml
│ │ └── [ 834] tools.yml
│ ├── [ 17K] LICENSE-BIN
│ ├── [1.3K] NOTICE-BIN
│ ├── [4.6K] pom.xml
│ ├── [2.1K] release-client.xml
│ └── [2.7K] release.xml
├── [4.0K] docs
│ ├── [4.0K] cn
│ │ ├── [4.0K] acl
│ │ │ └── [8.3K] user_guide.md
│ │ ├── [4.9K] architecture.md
│ │ ├── [ 28K] best_practice.md
│ │ ├── [4.0K] client
│ │ │ └── [4.0K] java
│ │ │ └── [ 42K] API_Reference_DefaultMQProducer.md
│ │ ├── [4.3K] concept.md
│ │ ├── [ 27K] design.md
│ │ ├── [4.0K] dledger
│ │ │ ├── [3.5K] deploy_guide.md
│ │ │ └── [1.6K] quick_start.md
│ │ ├── [9.3K] features.md
│ │ ├── [4.0K] image
│ │ │ ├── [369K] rocketmq_architecture_1.png
│ │ │ ├── [ 18K] rocketmq_architecture_2.png
│ │ │ ├── [ 60K] 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
│ │ │ └── [4.8K] user_guide.md
│ │ ├── [ 68K] operation.md
│ │ ├── [ 0] README
│ │ ├── [1.8K] README.md
│ │ └── [ 37K] RocketMQ_Example.md
│ └── [4.0K] en
│ ├── [4.0K] acl
│ │ └── [4.5K] Operations_ACL.md
│ ├── [6.2K] architecture.md
│ ├── [2.4K] best_practice.md
│ ├── [ 65K] CLITools.md
│ ├── [5.1K] Concept.md
│ ├── [ 12K] Configuration_Client.md
│ ├── [3.0K] Configuration_System.md
│ ├── [7.5K] Deployment.md
│ ├── [2.1K] Design_Filter.md
│ ├── [7.3K] Design_LoadBlancing.md
│ ├── [7.8K] design.md
│ ├── [2.8K] Design_Query.md
│ ├── [6.5K] Design_Remoting.md
│ ├── [6.8K] Design_Store.md
│ ├── [6.8K] Design_Trancation.md
│ ├── [3.1K] Example_Batch.md
│ ├── [3.3K] Example_Delay.md
│ ├── [2.7K] Example_Filter.md
│ ├── [4.9K] Example_OpenMessaging.md
│ ├── [7.6K] Example_Orderly.md
│ ├── [5.4K] Example_Simple.md
│ ├── [5.9K] Example_Transaction.md
│ ├── [5.4K] FAQ.md
│ ├── [ 11K] Feature.md
│ ├── [4.0K] image
│ │ ├── [ 45K] rocketmq_architecture_1.png
│ │ ├── [ 18K] rocketmq_architecture_2.png
│ │ └── [ 60K] rocketmq_architecture_3.png
│ ├── [4.0K] images
│ │ ├── [6.6K] rocketmq_design_7.png
│ │ ├── [ 26K] rocketmq_design_message_query.png
│ │ ├── [109K] rocketmq_storage_arch.png
│ │ └── [ 22K] rocketmq_storage_flush.png
│ ├── [ 0] index.md
│ ├── [2.9K] Operations_Broker.md
│ ├── [6.9K] Operations_Consumer.md
│ ├── [5.1K] Operations_Producer.md
│ ├── [5.1K] Operations_Trace.md
│ └── [4.5K] Troubleshoopting.md
├── [4.0K] example
│ ├── [2.4K] 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
│ │ │ ├── [1.8K] SimpleBatchProducer.java
│ │ │ └── [3.5K] SplitBatchProducer.java
│ │ ├── [4.0K] benchmark
│ │ │ ├── [9.3K] Consumer.java
│ │ │ ├── [ 12K] Producer.java
│ │ │ └── [ 11K] TransactionProducer.java
│ │ ├── [4.0K] broadcast
│ │ │ └── [2.3K] PushConsumer.java
│ │ ├── [4.0K] filter
│ │ │ ├── [2.2K] SqlFilterConsumer.java
│ │ │ ├── [1.8K] SqlFilterProducer.java
│ │ │ ├── [2.1K] TagFilterConsumer.java
│ │ │ └── [1.7K] TagFilterProducer.java
│ │ ├── [4.0K] namespace
│ │ │ ├── [1.7K] ProducerWithNamespace.java
│ │ │ ├── [3.3K] PullConsumerWithNamespace.java
│ │ │ └── [1.8K] PushConsumerWithNamespace.java
│ │ ├── [4.0K] openmessaging
│ │ │ ├── [3.2K] SimpleProducer.java
│ │ │ ├── [2.9K] SimplePullConsumer.java
│ │ │ └── [2.2K] SimplePushConsumer.java
│ │ ├── [4.0K] operation
│ │ │ ├── [4.4K] Consumer.java
│ │ │ └── [4.1K] Producer.java
│ │ ├── [4.0K] ordermessage
│ │ │ ├── [2.9K] Consumer.java
│ │ │ └── [2.7K] Producer.java
│ │ ├── [4.0K] quickstart
│ │ │ ├── [3.1K] Consumer.java
│ │ │ └── [2.8K] Producer.java
│ │ ├── [4.0K] rpc
│ │ │ ├── [2.5K] AsyncRequestProducer.java
│ │ │ ├── [1.9K] RequestProducer.java
│ │ │ └── [3.9K] ResponseConsumer.java
│ │ ├── [4.0K] simple
│ │ │ ├── [6.5K] AclClient.java
│ │ │ ├── [2.8K] AsyncProducer.java
│ │ │ ├── [1.1K] CachedQueue.java
│ │ │ ├── [2.1K] LitePullConsumerAssign.java
│ │ │ ├── [1.6K] LitePullConsumerSubscribe.java
│ │ │ ├── [1.9K] Producer.java
│ │ │ ├── [2.9K] PullConsumer.java
│ │ │ ├── [1.9K] PullConsumerTest.java
│ │ │ ├── [2.9K] PullScheduleService.java
│ │ │ ├── [2.2K] PushConsumer.java
│ │ │ ├── [2.1K] RandomAsyncCommit.java
│ │ │ └── [2.3K] TestProducer.java
│ │ ├── [4.0K] tracemessage
│ │ │ ├── [1.9K] TraceProducer.java
│ │ │ └── [2.3K] TracePushConsumer.java
│ │ └── [4.0K] transaction
│ │ ├── [2.3K] TransactionListenerImpl.java
│ │ └── [3.0K] TransactionProducer.java
│ └── [4.0K] resources
│ └── [1.4K] MessageFilterImpl.java
├── [4.0K] filter
│ ├── [1.8K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] filter
│ │ ├── [4.0K] constant
│ │ │ └── [ 930] UnaryType.java
│ │ ├── [4.0K] expression
│ │ │ ├── [2.3K] BinaryExpression.java
│ │ │ ├── [1.3K] BooleanExpression.java
│ │ │ ├── [ 16K] ComparisonExpression.java
│ │ │ ├── [4.7K] 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.3K] UnaryExpression.java
│ │ │ └── [1.7K] UnaryInExpression.java
│ │ ├── [2.0K] FilterFactory.java
│ │ ├── [1.2K] FilterSpi.java
│ │ ├── [4.0K] parser
│ │ │ ├── [7.3K] ParseException.java
│ │ │ ├── [2.9K] SelectorParserConstants.java
│ │ │ ├── [ 39K] SelectorParser.java
│ │ │ ├── [ 13K] SelectorParser.jj
│ │ │ ├── [ 32K] SelectorParserTokenManager.java
│ │ │ ├── [ 14K] SimpleCharStream.java
│ │ │ ├── [5.1K] Token.java
│ │ │ └── [5.7K] TokenMgrError.java
│ │ ├── [1.5K] SqlFilter.java
│ │ └── [4.0K] util
│ │ ├── [7.3K] BitsArray.java
│ │ ├── [2.3K] BloomFilterData.java
│ │ └── [8.6K] BloomFilter.java
│ └── [4.0K] test
│ └── [4.0K] java
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] filter
│ ├── [3.3K] BitsArrayTest.java
│ ├── [5.8K] BloomFilterTest.java
│ ├── [ 16K] ExpressionTest.java
│ ├── [2.7K] FilterSpiTest.java
│ └── [4.3K] ParserTest.java
├── [ 11K] LICENSE
├── [4.0K] logappender
│ ├── [3.2K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] logappender
│ │ ├── [4.0K] common
│ │ │ └── [3.4K] ProducerInstance.java
│ │ ├── [4.0K] log4j
│ │ │ └── [5.4K] RocketmqLog4jAppender.java
│ │ ├── [4.0K] log4j2
│ │ │ └── [7.6K] RocketmqLog4j2Appender.java
│ │ └── [4.0K] logback
│ │ └── [5.2K] RocketmqLogbackAppender.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] logappender
│ │ ├── [2.7K] AbstractTestCase.java
│ │ ├── [1.6K] log4j2Test.java
│ │ ├── [1.1K] Log4jPropertiesTest.java
│ │ ├── [1.4K] Log4jTest.java
│ │ ├── [1.1K] Log4jXmlTest.java
│ │ └── [1.9K] LogbackTest.java
│ └── [4.0K] resources
│ ├── [1.6K] log4j2-example.xml
│ ├── [1.8K] log4j-example.properties
│ ├── [2.2K] log4j-example.xml
│ └── [3.1K] logback-example.xml
├── [4.0K] logging
│ ├── [1.8K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] logging
│ │ ├── [4.0K] inner
│ │ │ ├── [6.3K] Appender.java
│ │ │ ├── [1.2K] Layout.java
│ │ │ ├── [4.3K] Level.java
│ │ │ ├── [ 13K] Logger.java
│ │ │ ├── [ 39K] LoggingBuilder.java
│ │ │ ├── [3.6K] LoggingEvent.java
│ │ │ └── [2.5K] SysLogger.java
│ │ ├── [ 16K] InnerLoggerFactory.java
│ │ ├── [2.9K] InternalLoggerFactory.java
│ │ ├── [1.7K] InternalLogger.java
│ │ ├── [1.2K] package-info.java
│ │ └── [3.9K] Slf4jLoggerFactory.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] logging
│ │ ├── [2.4K] BasicLoggerTest.java
│ │ ├── [4.0K] inner
│ │ │ ├── [6.5K] AppenderTest.java
│ │ │ ├── [2.1K] LayoutTest.java
│ │ │ ├── [1.2K] LevelTest.java
│ │ │ ├── [2.0K] LoggerRepositoryTest.java
│ │ │ ├── [4.3K] LoggerTest.java
│ │ │ ├── [4.1K] LoggingBuilderTest.java
│ │ │ └── [1.6K] MessageFormatterTest.java
│ │ ├── [3.5K] InnerLoggerFactoryTest.java
│ │ ├── [2.7K] InternalLoggerTest.java
│ │ └── [3.3K] Slf4jLoggerFactoryTest.java
│ └── [4.0K] resources
│ └── [1.8K] logback_test.xml
├── [4.0K] namesrv
│ ├── [2.2K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] namesrv
│ │ ├── [4.0K] kvconfig
│ │ │ ├── [7.8K] KVConfigManager.java
│ │ │ └── [1.3K] KVConfigSerializeWrapper.java
│ │ ├── [7.6K] NamesrvController.java
│ │ ├── [6.7K] NamesrvStartup.java
│ │ ├── [4.0K] processor
│ │ │ ├── [4.0K] ClusterTestRequestProcessor.java
│ │ │ └── [ 26K] DefaultRequestProcessor.java
│ │ └── [4.0K] routeinfo
│ │ ├── [2.1K] BrokerHousekeepingService.java
│ │ └── [ 34K] RouteInfoManager.java
│ └── [4.0K] test
│ └── [4.0K] java
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] namesrv
│ ├── [4.0K] kvconfig
│ │ ├── [2.2K] KVConfigManagerTest.java
│ │ └── [2.5K] KVConfigSerializeWrapperTest.java
│ ├── [1.8K] NameServerInstanceTest.java
│ ├── [4.0K] processor
│ │ ├── [5.1K] ClusterTestRequestProcessorTest.java
│ │ └── [ 12K] DefaultRequestProcessorTest.java
│ └── [4.0K] routeinfo
│ ├── [1.9K] BrokerHousekeepingServiceTest.java
│ └── [4.4K] RouteInfoManagerTest.java
├── [ 169] NOTICE
├── [4.0K] openmessaging
│ ├── [1.6K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] io
│ │ └── [4.0K] openmessaging
│ │ └── [4.0K] rocketmq
│ │ ├── [4.0K] config
│ │ │ └── [5.6K] ClientConfig.java
│ │ ├── [4.0K] consumer
│ │ │ ├── [9.1K] LocalMessageCache.java
│ │ │ ├── [7.4K] PullConsumerImpl.java
│ │ │ └── [8.0K] PushConsumerImpl.java
│ │ ├── [4.0K] domain
│ │ │ ├── [3.1K] BytesMessageImpl.java
│ │ │ ├── [1.9K] ConsumeRequest.java
│ │ │ ├── [1.5K] NonStandardKeys.java
│ │ │ ├── [1002] RocketMQConstants.java
│ │ │ └── [1.3K] SendResultImpl.java
│ │ ├── [3.2K] MessagingAccessPointImpl.java
│ │ ├── [4.0K] producer
│ │ │ ├── [6.6K] AbstractOMSProducer.java
│ │ │ └── [5.6K] ProducerImpl.java
│ │ ├── [4.0K] promise
│ │ │ ├── [6.3K] DefaultPromise.java
│ │ │ └── [1.3K] FutureState.java
│ │ └── [4.0K] utils
│ │ ├── [7.8K] 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
├── [ 24K] pom.xml
├── [4.1K] README.md
├── [4.0K] remoting
│ ├── [2.1K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] remoting
│ │ ├── [4.0K] annotation
│ │ │ ├── [1.2K] CFNotNull.java
│ │ │ └── [1.2K] CFNullable.java
│ │ ├── [1.2K] ChannelEventListener.java
│ │ ├── [1011] CommandCustomHeader.java
│ │ ├── [4.0K] common
│ │ │ ├── [1.3K] Pair.java
│ │ │ ├── [6.9K] RemotingHelper.java
│ │ │ ├── [7.4K] RemotingUtil.java
│ │ │ ├── [1.4K] SemaphoreReleaseOnlyOnce.java
│ │ │ ├── [2.6K] ServiceThread.java
│ │ │ └── [1.8K] TlsMode.java
│ │ ├── [4.0K] exception
│ │ │ ├── [1.2K] RemotingCommandException.java
│ │ │ ├── [1.2K] RemotingConnectException.java
│ │ │ ├── [1.1K] RemotingException.java
│ │ │ ├── [1.2K] RemotingSendRequestException.java
│ │ │ ├── [1.4K] RemotingTimeoutException.java
│ │ │ └── [1.1K] RemotingTooMuchRequestException.java
│ │ ├── [1001] InvokeCallback.java
│ │ ├── [4.0K] netty
│ │ │ ├── [2.8K] FileRegionEncoder.java
│ │ │ ├── [4.7K] NettyClientConfig.java
│ │ │ ├── [2.4K] NettyDecoder.java
│ │ │ ├── [2.2K] NettyEncoder.java
│ │ │ ├── [1.5K] NettyEvent.java
│ │ │ ├── [ 926] NettyEventType.java
│ │ │ ├── [9.4K] NettyLogger.java
│ │ │ ├── [ 24K] NettyRemotingAbstract.java
│ │ │ ├── [ 29K] NettyRemotingClient.java
│ │ │ ├── [ 20K] NettyRemotingServer.java
│ │ │ ├── [1.2K] NettyRequestProcessor.java
│ │ │ ├── [4.4K] NettyServerConfig.java
│ │ │ ├── [2.3K] NettySystemConfig.java
│ │ │ ├── [3.0K] RequestTask.java
│ │ │ ├── [4.3K] ResponseFuture.java
│ │ │ ├── [ 11K] TlsHelper.java
│ │ │ └── [5.7K] TlsSystemConfig.java
│ │ ├── [4.0K] protocol
│ │ │ ├── [1.5K] LanguageCode.java
│ │ │ ├── [ 18K] RemotingCommand.java
│ │ │ ├── [ 929] RemotingCommandType.java
│ │ │ ├── [2.0K] RemotingSerializable.java
│ │ │ ├── [1.1K] RemotingSysResponseCode.java
│ │ │ ├── [6.9K] RocketMQSerializable.java
│ │ │ └── [1.3K] SerializeType.java
│ │ ├── [2.5K] RemotingClient.java
│ │ ├── [2.4K] RemotingServer.java
│ │ ├── [ 963] RemotingService.java
│ │ └── [1.1K] RPCHook.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] remoting
│ │ ├── [4.0K] netty
│ │ │ ├── [3.0K] FileRegionEncoderTest.java
│ │ │ ├── [4.5K] NettyRemotingAbstractTest.java
│ │ │ └── [1.6K] NettyRemotingClientTest.java
│ │ ├── [4.0K] protocol
│ │ │ ├── [9.8K] RemotingCommandTest.java
│ │ │ ├── [4.9K] RemotingSerializableTest.java
│ │ │ └── [7.0K] RocketMQSerializableTest.java
│ │ ├── [6.0K] RemotingServerTest.java
│ │ └── [ 14K] TlsTest.java
│ └── [4.0K] resources
│ └── [4.0K] certs
│ ├── [ 993] badClient.key
│ ├── [1.1K] badClient.pem
│ ├── [ 916] badServer.key
│ ├── [1.0K] badServer.pem
│ ├── [1.3K] ca.pem
│ ├── [ 993] client.key
│ ├── [1.1K] client.pem
│ ├── [1.8K] privkey.pem
│ ├── [ 916] server.key
│ └── [1.1K] server.pem
├── [4.0K] srvutil
│ ├── [1.8K] pom.xml
│ └── [4.0K] src
│ └── [4.0K] main
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] srvutil
│ │ ├── [3.9K] FileWatchService.java
│ │ ├── [2.9K] ServerUtil.java
│ │ └── [2.6K] ShutdownHookThread.java
│ └── [4.0K] test
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] srvutil
│ └── [5.6K] FileWatchServiceTest.java
├── [4.0K] store
│ ├── [2.5K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] store
│ │ ├── [ 12K] AllocateMappedFileService.java
│ │ ├── [1.6K] AppendMessageCallback.java
│ │ ├── [3.7K] AppendMessageResult.java
│ │ ├── [1.0K] AppendMessageStatus.java
│ │ ├── [ 968] CommitLogDispatcher.java
│ │ ├── [ 69K] CommitLog.java
│ │ ├── [4.0K] config
│ │ │ ├── [ 918] BrokerRole.java
│ │ │ ├── [ 907] FlushDiskType.java
│ │ │ ├── [ 22K] MessageStoreConfig.java
│ │ │ └── [2.1K] StorePathConfigHelper.java
│ │ ├── [ 19K] ConsumeQueueExt.java
│ │ ├── [ 23K] ConsumeQueue.java
│ │ ├── [1.8K] DefaultMessageFilter.java
│ │ ├── [ 76K] DefaultMessageStore.java
│ │ ├── [4.6K] DispatchRequest.java
│ │ ├── [4.0K] dledger
│ │ │ └── [ 31K] DLedgerCommitLog.java
│ │ ├── [3.9K] GetMessageResult.java
│ │ ├── [1.1K] GetMessageStatus.java
│ │ ├── [4.0K] ha
│ │ │ ├── [ 16K] HAConnection.java
│ │ │ ├── [ 23K] HAService.java
│ │ │ └── [3.3K] WaitNotifyObject.java
│ │ ├── [4.0K] index
│ │ │ ├── [ 10K] IndexFile.java
│ │ │ ├── [4.3K] IndexHeader.java
│ │ │ ├── [ 13K] IndexService.java
│ │ │ └── [1.6K] QueryOffsetResult.java
│ │ ├── [ 21K] MappedFile.java
│ │ ├── [ 21K] MappedFileQueue.java
│ │ ├── [1.0K] MessageArrivingListener.java
│ │ ├── [1.8K] MessageExtBrokerInner.java
│ │ ├── [1.8K] MessageFilter.java
│ │ ├── [ 11K] MessageStore.java
│ │ ├── [ 954] PutMessageLock.java
│ │ ├── [1.2K] PutMessageReentrantLock.java
│ │ ├── [1.9K] PutMessageResult.java
│ │ ├── [1.4K] PutMessageSpinLock.java
│ │ ├── [1.1K] PutMessageStatus.java
│ │ ├── [2.3K] QueryMessageResult.java
│ │ ├── [2.4K] ReferenceResource.java
│ │ ├── [3.7K] RunningFlags.java
│ │ ├── [4.0K] schedule
│ │ │ ├── [1.4K] DelayOffsetSerializeWrapper.java
│ │ │ └── [ 17K] ScheduleMessageService.java
│ │ ├── [1.9K] SelectMappedBufferResult.java
│ │ ├── [4.0K] stats
│ │ │ ├── [3.5K] BrokerStats.java
│ │ │ └── [ 11K] BrokerStatsManager.java
│ │ ├── [4.5K] StoreCheckpoint.java
│ │ ├── [ 20K] StoreStatsService.java
│ │ ├── [1.5K] StoreUtil.java
│ │ ├── [3.3K] TransientStorePool.java
│ │ └── [4.0K] util
│ │ └── [1.7K] LibC.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] store
│ │ ├── [ 11K] AppendCallbackTest.java
│ │ ├── [ 10K] BatchPutMessageTest.java
│ │ ├── [7.4K] ConsumeQueueExtTest.java
│ │ ├── [ 10K] ConsumeQueueTest.java
│ │ ├── [ 18K] DefaultMessageStoreCleanFilesTest.java
│ │ ├── [2.9K] DefaultMessageStoreShutDownTest.java
│ │ ├── [ 26K] DefaultMessageStoreTest.java
│ │ ├── [4.0K] dledger
│ │ │ ├── [ 12K] DLedgerCommitlogTest.java
│ │ │ ├── [6.9K] MessageStoreTestBase.java
│ │ │ └── [ 10K] MixCommitlogTest.java
│ │ ├── [4.0K] ha
│ │ │ └── [1.5K] WaitNotifyObjectTest.java
│ │ ├── [7.4K] HATest.java
│ │ ├── [4.0K] index
│ │ │ └── [2.7K] IndexFileTest.java
│ │ ├── [9.8K] MappedFileQueueTest.java
│ │ ├── [2.2K] MappedFileTest.java
│ │ ├── [4.0K] schedule
│ │ │ └── [7.9K] ScheduleMessageServiceTest.java
│ │ ├── [2.1K] StoreCheckpointTest.java
│ │ ├── [3.9K] StoreStatsServiceTest.java
│ │ ├── [4.1K] StoreTestBase.java
│ │ └── [3.6K] StoreTestUtil.java
│ └── [4.0K] resources
│ └── [1.3K] logback-test.xml
├── [4.0K] style
│ ├── [4.0K] copyright
│ │ ├── [1.7K] Apache.xml
│ │ └── [2.7K] profiles_settings.xml
│ ├── [5.9K] rmq_checkstyle.xml
│ └── [6.9K] rmq_codeStyle.xml
├── [4.0K] test
│ ├── [2.4K] pom.xml
│ └── [4.0K] src
│ ├── [4.0K] main
│ │ └── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] test
│ │ ├── [4.0K] client
│ │ │ ├── [4.0K] mq
│ │ │ │ └── [2.9K] MQAsyncProducer.java
│ │ │ └── [4.0K] rmq
│ │ │ ├── [7.5K] RMQAsyncSendProducer.java
│ │ │ ├── [1.5K] RMQBroadCastConsumer.java
│ │ │ ├── [3.1K] RMQNormalConsumer.java
│ │ │ ├── [6.0K] RMQNormalProducer.java
│ │ │ └── [1.6K] RMQSqlConsumer.java
│ │ ├── [4.0K] clientinterface
│ │ │ ├── [3.0K] AbstractMQConsumer.java
│ │ │ ├── [4.4K] AbstractMQProducer.java
│ │ │ ├── [3.9K] MQCollector.java
│ │ │ ├── [ 985] MQConsumer.java
│ │ │ └── [1.0K] MQProducer.java
│ │ ├── [4.0K] factory
│ │ │ ├── [3.1K] ConsumerFactory.java
│ │ │ ├── [2.2K] MessageFactory.java
│ │ │ ├── [4.4K] MQMessageFactory.java
│ │ │ ├── [1.5K] ProducerFactory.java
│ │ │ ├── [1.3K] SendCallBackFactory.java
│ │ │ └── [3.2K] TagMessage.java
│ │ ├── [4.0K] listener
│ │ │ ├── [4.3K] AbstractListener.java
│ │ │ └── [4.0K] rmq
│ │ │ ├── [4.0K] concurrent
│ │ │ │ ├── [2.5K] RMQDelayListner.java
│ │ │ │ └── [2.9K] RMQNormalListener.java
│ │ │ └── [4.0K] order
│ │ │ └── [3.0K] RMQOrderListener.java
│ │ ├── [4.0K] message
│ │ │ └── [2.1K] MessageQueueMsg.java
│ │ ├── [4.0K] sendresult
│ │ │ └── [1.8K] ResultWrapper.java
│ │ └── [4.0K] util
│ │ ├── [ 909] Condition.java
│ │ ├── [4.0K] data
│ │ │ └── [4.0K] collect
│ │ │ ├── [1.3K] DataCollector.java
│ │ │ ├── [4.1K] DataCollectorManager.java
│ │ │ ├── [ 894] DataFilter.java
│ │ │ └── [4.0K] impl
│ │ │ ├── [2.5K] ListDataCollectorImpl.java
│ │ │ └── [3.1K] MapDataCollectorImpl.java
│ │ ├── [5.7K] DuplicateMessageInfo.java
│ │ ├── [3.4K] FileUtil.java
│ │ ├── [6.2K] MQAdmin.java
│ │ ├── [1.1K] MQRandomUtils.java
│ │ ├── [3.3K] MQWait.java
│ │ ├── [4.0K] parallel
│ │ │ ├── [2.0K] ParallelTaskExecutor.java
│ │ │ ├── [1.3K] ParallelTask.java
│ │ │ └── [1.0K] Task4Test.java
│ │ ├── [8.5K] RandomUtil.java
│ │ ├── [2.6K] RandomUtils.java
│ │ ├── [3.7K] TestUtil.java
│ │ ├── [1.5K] TestUtils.java
│ │ └── [4.7K] VerifyUtils.java
│ └── [4.0K] test
│ ├── [4.0K] java
│ │ └── [4.0K] org
│ │ └── [4.0K] apache
│ │ └── [4.0K] rocketmq
│ │ └── [4.0K] test
│ │ ├── [4.0K] base
│ │ │ ├── [6.3K] BaseConf.java
│ │ │ ├── [4.0K] dledger
│ │ │ │ └── [5.6K] DLedgerProduceAndConsumeIT.java
│ │ │ └── [8.1K] IntegrationTestBase.java
│ │ ├── [4.0K] client
│ │ │ ├── [4.0K] consumer
│ │ │ │ ├── [4.0K] balance
│ │ │ │ │ ├── [4.6K] NormalMsgDynamicBalanceIT.java
│ │ │ │ │ └── [4.7K] NormalMsgStaticBalanceIT.java
│ │ │ │ ├── [4.0K] broadcast
│ │ │ │ │ ├── [2.3K] BaseBroadCastIT.java
│ │ │ │ │ ├── [4.0K] normal
│ │ │ │ │ │ ├── [2.9K] BroadCastNormalMsgNotRecvIT.java
│ │ │ │ │ │ ├── [3.6K] BroadCastNormalMsgRecvCrashIT.java
│ │ │ │ │ │ ├── [2.8K] BroadCastNormalMsgRecvFailIT.java
│ │ │ │ │ │ ├── [3.6K] BroadCastNormalMsgRecvStartLaterIT.java
│ │ │ │ │ │ ├── [3.1K] BroadCastNormalMsgTwoDiffGroupRecvIT.java
│ │ │ │ │ │ └── [3.1K] NormalMsgTwoSameGroupConsumerIT.java
│ │ │ │ │ ├── [4.0K] order
│ │ │ │ │ │ └── [3.1K] OrderMsgBroadCastIT.java
│ │ │ │ │ └── [4.0K] tag
│ │ │ │ │ ├── [3.1K] BroadCastTwoConsumerFilterIT.java
│ │ │ │ │ ├── [3.0K] BroadCastTwoConsumerSubDiffTagIT.java
│ │ │ │ │ └── [3.0K] BroadCastTwoConsumerSubTagIT.java
│ │ │ │ ├── [4.0K] cluster
│ │ │ │ │ ├── [4.1K] DynamicAddAndCrashIT.java
│ │ │ │ │ ├── [3.9K] DynamicAddConsumerIT.java
│ │ │ │ │ └── [3.9K] DynamicCrashConsumerIT.java
│ │ │ │ ├── [4.0K] filter
│ │ │ │ │ └── [5.6K] SqlFilterIT.java
│ │ │ │ ├── [4.0K] tag
│ │ │ │ │ ├── [6.2K] MulTagSubIT.java
│ │ │ │ │ ├── [8.0K] TagMessageWith1ConsumerIT.java
│ │ │ │ │ ├── [8.9K] TagMessageWithMulConsumerIT.java
│ │ │ │ │ └── [4.7K] TagMessageWithSameGroupConsumerIT.java
│ │ │ │ └── [4.0K] topic
│ │ │ │ ├── [4.4K] MulConsumerMulTopicIT.java
│ │ │ │ └── [4.2K] OneConsumerMulTopicIT.java
│ │ │ └── [4.0K] producer
│ │ │ ├── [4.0K] async
│ │ │ │ ├── [5.4K] AsyncSendExceptionIT.java
│ │ │ │ ├── [3.4K] AsyncSendWithMessageQueueIT.java
│ │ │ │ ├── [4.2K] AsyncSendWithMessageQueueSelectorIT.java
│ │ │ │ └── [2.5K] AsyncSendWithOnlySendCallBackIT.java
│ │ │ ├── [4.0K] batch
│ │ │ │ └── [5.0K] BatchSendIT.java
│ │ │ ├── [4.0K] exception
│ │ │ │ ├── [4.0K] msg
│ │ │ │ │ ├── [2.5K] ChinaPropIT.java
│ │ │ │ │ ├── [4.8K] MessageExceptionIT.java
│ │ │ │ │ └── [3.5K] MessageUserPropIT.java
│ │ │ │ └── [4.0K] producer
│ │ │ │ └── [2.5K] ProducerGroupAndInstanceNameValidityIT.java
│ │ │ ├── [4.0K] oneway
│ │ │ │ ├── [3.2K] OneWaySendExceptionIT.java
│ │ │ │ ├── [2.5K] OneWaySendIT.java
│ │ │ │ ├── [3.1K] OneWaySendWithMQIT.java
│ │ │ │ └── [4.1K] OneWaySendWithSelectorIT.java
│ │ │ ├── [4.0K] order
│ │ │ │ ├── [4.7K] OrderMsgDynamicRebalanceIT.java
│ │ │ │ ├── [4.2K] OrderMsgIT.java
│ │ │ │ ├── [6.0K] OrderMsgRebalanceIT.java
│ │ │ │ └── [6.5K] OrderMsgWithTagIT.java
│ │ │ └── [4.0K] querymsg
│ │ │ ├── [2.6K] QueryMsgByIdExceptionIT.java
│ │ │ ├── [2.9K] QueryMsgByIdIT.java
│ │ │ └── [3.7K] QueryMsgByKeyIT.java
│ │ ├── [4.0K] delay
│ │ │ ├── [1.1K] DelayConf.java
│ │ │ └── [5.1K] NormalMsgDelayIT.java
│ │ ├── [4.0K] smoke
│ │ │ └── [2.4K] NormalMessageSendAndRecvIT.java
│ │ └── [4.0K] tls
│ │ ├── [2.0K] TLS_IT.java
│ │ ├── [2.0K] TLS_Mix2_IT.java
│ │ └── [2.0K] TLS_Mix_IT.java
│ └── [4.0K] resources
│ ├── [1.9K] log4j.xml
│ └── [1.3K] logback-test.xml
└── [4.0K] tools
├── [2.7K] pom.xml
└── [4.0K] src
├── [4.0K] main
│ └── [4.0K] java
│ └── [4.0K] org
│ └── [4.0K] apache
│ └── [4.0K] rocketmq
│ └── [4.0K] tools
│ ├── [4.0K] admin
│ │ ├── [4.0K] api
│ │ │ ├── [1.7K] MessageTrack.java
│ │ │ └── [ 975] TrackType.java
│ │ ├── [ 48K] DefaultMQAdminExtImpl.java
│ │ ├── [ 24K] DefaultMQAdminExt.java
│ │ └── [ 15K] MQAdminExt.java
│ ├── [4.0K] command
│ │ ├── [4.0K] acl
│ │ │ ├── [5.2K] ClusterAclConfigVersionListSubCommand.java
│ │ │ ├── [4.0K] DeleteAccessConfigSubCommand.java
│ │ │ ├── [5.1K] GetAccessConfigSubCommand.java
│ │ │ ├── [7.1K] UpdateAccessConfigSubCommand.java
│ │ │ └── [4.0K] UpdateGlobalWhiteAddrSubCommand.java
│ │ ├── [4.0K] broker
│ │ │ ├── [6.7K] BrokerConsumeStatsSubCommad.java
│ │ │ ├── [4.5K] BrokerStatusSubCommand.java
│ │ │ ├── [2.9K] CleanExpiredCQSubCommand.java
│ │ │ ├── [2.9K] CleanUnusedTopicCommand.java
│ │ │ ├── [4.9K] GetBrokerConfigCommand.java
│ │ │ ├── [3.7K] SendMsgStatusCommand.java
│ │ │ └── [4.1K] UpdateBrokerConfigSubCommand.java
│ │ ├── [4.0K] cluster
│ │ │ ├── [ 13K] ClusterListSubCommand.java
│ │ │ └── [7.8K] CLusterSendMsgRTCommand.java
│ │ ├── [6.5K] CommandUtil.java
│ │ ├── [4.0K] connection
│ │ │ ├── [3.9K] ConsumerConnectionSubCommand.java
│ │ │ └── [3.1K] ProducerConnectionSubCommand.java
│ │ ├── [4.0K] consumer
│ │ │ ├── [ 12K] ConsumerProgressSubCommand.java
│ │ │ ├── [6.2K] ConsumerStatusSubCommand.java
│ │ │ ├── [6.1K] ConsumerSubCommand.java
│ │ │ ├── [4.3K] DeleteSubscriptionGroupCommand.java
│ │ │ ├── [2.2K] StartMonitoringSubCommand.java
│ │ │ └── [7.4K] UpdateSubGroupSubCommand.java
│ │ ├── [4.0K] message
│ │ │ ├── [5.0K] CheckMsgSendRTCommand.java
│ │ │ ├── [ 11K] ConsumeMessageCommand.java
│ │ │ ├── [2.4K] DecodeMessageIdCommond.java
│ │ │ ├── [9.4K] PrintMessageByQueueCommand.java
│ │ │ ├── [6.6K] PrintMessageSubCommand.java
│ │ │ ├── [ 10K] QueryMsgByIdSubCommand.java
│ │ │ ├── [3.2K] QueryMsgByKeySubCommand.java
│ │ │ ├── [4.1K] QueryMsgByOffsetSubCommand.java
│ │ │ ├── [7.5K] QueryMsgByUniqueKeySubCommand.java
│ │ │ └── [5.4K] SendMessageCommand.java
│ │ ├── [ 12K] MQAdminStartup.java
│ │ ├── [4.0K] namesrv
│ │ │ ├── [2.6K] DeleteKvConfigCommand.java
│ │ │ ├── [3.0K] GetNamesrvConfigCommand.java
│ │ │ ├── [2.9K] UpdateKvConfigCommand.java
│ │ │ ├── [3.3K] UpdateNamesrvConfigCommand.java
│ │ │ └── [3.2K] WipeWritePermSubCommand.java
│ │ ├── [4.0K] offset
│ │ │ ├── [4.2K] CloneGroupOffsetCommand.java
│ │ │ ├── [4.0K] GetConsumerStatusCommand.java
│ │ │ ├── [5.3K] ResetOffsetByTimeCommand.java
│ │ │ └── [5.4K] ResetOffsetByTimeOldCommand.java
│ │ ├── [4.0K] queue
│ │ │ └── [6.2K] QueryConsumeQueueCommand.java
│ │ ├── [4.0K] stats
│ │ │ └── [7.7K] StatsAllSubCommand.java
│ │ ├── [1.2K] SubCommandException.java
│ │ ├── [1.2K] SubCommand.java
│ │ └── [4.0K] topic
│ │ ├── [3.7K] AllocateMQSubCommand.java
│ │ ├── [3.9K] DeleteTopicSubCommand.java
│ │ ├── [1.3K] RebalanceResult.java
│ │ ├── [2.5K] TopicClusterSubCommand.java
│ │ ├── [5.5K] TopicListSubCommand.java
│ │ ├── [2.5K] TopicRouteSubCommand.java
│ │ ├── [3.7K] TopicStatusSubCommand.java
│ │ ├── [4.1K] UpdateOrderConfCommand.java
│ │ ├── [7.1K] UpdateTopicPermSubCommand.java
│ │ └── [7.5K] UpdateTopicSubCommand.java
│ └── [4.0K] monitor
│ ├── [3.3K] DefaultMonitorListener.java
│ ├── [1.6K] DeleteMsgsEvent.java
│ ├── [1.7K] FailedMsgs.java
│ ├── [1.4K] MonitorConfig.java
│ ├── [1.3K] MonitorListener.java
│ ├── [ 13K] MonitorService.java
│ └── [2.3K] UndoneMsgs.java
└── [4.0K] test
└── [4.0K] java
└── [4.0K] org
└── [4.0K] apache
└── [4.0K] rocketmq
└── [4.0K] tools
├── [4.0K] admin
│ └── [ 22K] DefaultMQAdminExtTest.java
├── [4.0K] command
│ ├── [4.0K] acl
│ │ ├── [1.7K] ClusterAclConfigVersionListSubCommandTest.java
│ │ ├── [1.7K] DeleteAccessConfigSubCommandTest.java
│ │ ├── [1.6K] GetAccessConfigSubCommandTest.java
│ │ ├── [3.8K] UpdateAccessConfigSubCommandTest.java
│ │ └── [1.8K] UpdateGlobalWhiteAddrSubCommandTest.java
│ ├── [4.0K] broker
│ │ ├── [4.7K] BrokerConsumeStatsSubCommadTest.java
│ │ ├── [4.2K] BrokerStatusSubCommandTest.java
│ │ ├── [4.1K] CleanExpiredCQSubCommandTest.java
│ │ ├── [4.1K] CleanUnusedTopicCommandTest.java
│ │ ├── [4.4K] GetBrokerConfigCommandTest.java
│ │ ├── [3.7K] SendMsgStatusCommandTest.java
│ │ └── [3.9K] UpdateBrokerConfigSubCommandTest.java
│ ├── [5.4K] CommandUtilTest.java
│ ├── [4.0K] connection
│ │ ├── [5.1K] ConsumerConnectionSubCommandTest.java
│ │ └── [4.6K] ProducerConnectionSubCommandTest.java
│ ├── [4.0K] consumer
│ │ ├── [5.4K] ConsumerProgressSubCommandTest.java
│ │ └── [6.8K] ConsumerStatusSubCommandTest.java
│ ├── [4.0K] message
│ │ ├── [7.9K] ConsumeMessageCommandTest.java
│ │ ├── [ 12K] QueryMsgByUniqueKeySubCommandTest.java
│ │ └── [4.1K] SendMessageCommandTest.java
│ ├── [4.0K] namesrv
│ │ ├── [4.3K] GetNamesrvConfigCommandTest.java
│ │ ├── [3.4K] UpdateKvConfigCommandTest.java
│ │ └── [4.4K] WipeWritePermSubCommandTest.java
│ ├── [4.0K] offset
│ │ ├── [4.1K] GetConsumerStatusCommandTest.java
│ │ ├── [5.2K] ResetOffsetByTimeCommandTest.java
│ │ └── [1.9K] ResetOffsetByTimeOldCommandTest.java
│ └── [4.0K] topic
│ ├── [1.7K] AllocateMQSubCommandTest.java
│ ├── [1.7K] DeleteTopicSubCommandTest.java
│ ├── [1.6K] TopicClusterSubCommandTest.java
│ ├── [1.6K] TopicRouteSubCommandTest.java
│ ├── [1.6K] TopicStatusSubCommandTest.java
│ ├── [1.8K] UpdateOrderConfCommandTest.java
│ ├── [1.9K] UpdateTopicPermSubCommandTest.java
│ └── [2.3K] UpdateTopicSubCommandTest.java
└── [4.0K] monitor
├── [3.4K] DefaultMonitorListenerTest.java
└── [9.2K] MonitorServiceTest.java
465 directories, 1155 files
备注
1. 建议优先通过来源进行访问。
2. 如果因为来源失效或无法访问，请发送邮件到 f.jinxu#gmail.com 索取本地快照（把 # 换成 @）。
3. 神龙已为您对 POC 代码进行快照，为了长期维护，请考虑为本地 POC 付费/捐赠，感谢您的支持。