path	# lines of code
filter/src/main/java/org/apache/rocketmq/filter/expression/UnaryExpression.java	192
filter/src/main/java/org/apache/rocketmq/filter/expression/EmptyEvaluationContext.java	12
filter/src/main/java/org/apache/rocketmq/filter/expression/UnaryInExpression.java	29
filter/src/main/java/org/apache/rocketmq/filter/expression/PropertyExpression.java	29
filter/src/main/java/org/apache/rocketmq/filter/expression/Expression.java	4
filter/src/main/java/org/apache/rocketmq/filter/expression/MQFilterException.java	21
filter/src/main/java/org/apache/rocketmq/filter/expression/ComparisonExpression.java	494
filter/src/main/java/org/apache/rocketmq/filter/expression/LogicExpression.java	53
filter/src/main/java/org/apache/rocketmq/filter/expression/ConstantExpression.java	72
filter/src/main/java/org/apache/rocketmq/filter/expression/EvaluationContext.java	6
filter/src/main/java/org/apache/rocketmq/filter/expression/BinaryExpression.java	34
filter/src/main/java/org/apache/rocketmq/filter/expression/BooleanExpression.java	4
filter/src/main/java/org/apache/rocketmq/filter/expression/BooleanConstantExpression.java	13
filter/src/main/java/org/apache/rocketmq/filter/expression/NowExpression.java	13
filter/src/main/java/org/apache/rocketmq/filter/SqlFilter.java	15
filter/src/main/java/org/apache/rocketmq/filter/FilterSpi.java	7
filter/src/main/java/org/apache/rocketmq/filter/util/BitsArray.java	186
filter/src/main/java/org/apache/rocketmq/filter/util/BloomFilter.java	156
filter/src/main/java/org/apache/rocketmq/filter/util/BloomFilterData.java	50
filter/src/main/java/org/apache/rocketmq/filter/constant/UnaryType.java	8
filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParser.java	429
filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParserConstants.java	62
filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParserTokenManager.java	973
filter/src/main/java/org/apache/rocketmq/filter/parser/ParseException.java	95
filter/src/main/java/org/apache/rocketmq/filter/parser/TokenMgrError.java	37
filter/src/main/java/org/apache/rocketmq/filter/parser/Token.java	36
filter/src/main/java/org/apache/rocketmq/filter/parser/SimpleCharStream.java	304
filter/src/main/java/org/apache/rocketmq/filter/FilterFactory.java	22
distribution/release-client.xml	46
distribution/release.xml	92
tools/src/main/java/org/apache/rocketmq/tools/monitor/DeleteMsgsEvent.java	23
tools/src/main/java/org/apache/rocketmq/tools/monitor/UndoneMsgs.java	44
tools/src/main/java/org/apache/rocketmq/tools/monitor/MonitorService.java	261
tools/src/main/java/org/apache/rocketmq/tools/monitor/MonitorConfig.java	19
tools/src/main/java/org/apache/rocketmq/tools/monitor/FailedMsgs.java	29
tools/src/main/java/org/apache/rocketmq/tools/monitor/MonitorListener.java	11
tools/src/main/java/org/apache/rocketmq/tools/monitor/DefaultMonitorListener.java	59
tools/src/main/java/org/apache/rocketmq/tools/admin/api/TrackType.java	10
tools/src/main/java/org/apache/rocketmq/tools/admin/api/MessageTrack.java	29
tools/src/main/java/org/apache/rocketmq/tools/admin/api/BrokerOperatorResult.java	25
tools/src/main/java/org/apache/rocketmq/tools/admin/common/AdminToolsResultCodeEnum.java	18
tools/src/main/java/org/apache/rocketmq/tools/admin/common/AdminToolResult.java	46
tools/src/main/java/org/apache/rocketmq/tools/admin/common/AdminToolHandler.java	4
tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminUtils.java	291
tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminExt.java	322
tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java	820
tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java	1791
tools/src/main/java/org/apache/rocketmq/tools/command/connection/ProducerConnectionSubCommand.java	59
tools/src/main/java/org/apache/rocketmq/tools/command/connection/ConsumerConnectionSubCommand.java	74
tools/src/main/java/org/apache/rocketmq/tools/command/ha/GetSyncStateSetSubCommand.java	103
tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java	111
tools/src/main/java/org/apache/rocketmq/tools/command/SubCommand.java	13
tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java	280
tools/src/main/java/org/apache/rocketmq/tools/command/metadata/RocksDBConfigToJsonCommand.java	271
tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java	158
tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java	248
tools/src/main/java/org/apache/rocketmq/tools/command/broker/SendMsgStatusCommand.java	66
tools/src/main/java/org/apache/rocketmq/tools/command/broker/CleanUnusedTopicCommand.java	51
tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java	128
tools/src/main/java/org/apache/rocketmq/tools/command/broker/CleanExpiredCQSubCommand.java	51
tools/src/main/java/org/apache/rocketmq/tools/command/broker/ResetMasterFlushOffsetSubCommand.java	45
tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java	82
tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java	101
tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetColdDataFlowCtrInfoSubCommand.java	94
tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerStatusSubCommand.java	82
tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateColdDataFlowCtrGroupConfigSubCommand.java	74
tools/src/main/java/org/apache/rocketmq/tools/command/broker/CommitLogSetReadAheadSubCommand.java	79
tools/src/main/java/org/apache/rocketmq/tools/command/broker/DeleteExpiredCommitLogSubCommand.java	57
tools/src/main/java/org/apache/rocketmq/tools/command/broker/RemoveColdDataFlowCtrGroupConfigSubCommand.java	67
tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerEpochSubCommand.java	94
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java	161
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/SetConsumeModeSubCommand.java	92
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerSubCommand.java	106
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java	309
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/DeleteSubscriptionGroupCommand.java	83
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java	118
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/StartMonitoringSubCommand.java	33
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupListSubCommand.java	85
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java	121
tools/src/main/java/org/apache/rocketmq/tools/command/offset/SkipAccumulationSubCommand.java	102
tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeOldCommand.java	105
tools/src/main/java/org/apache/rocketmq/tools/command/offset/GetConsumerStatusCommand.java	76
tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java	132
tools/src/main/java/org/apache/rocketmq/tools/command/offset/CloneGroupOffsetCommand.java	75
tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java	104
tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java	147
tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicRouteSubCommand.java	81
tools/src/main/java/org/apache/rocketmq/tools/command/topic/RemappingStaticTopicSubCommand.java	155
tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicStatusSubCommand.java	91
tools/src/main/java/org/apache/rocketmq/tools/command/topic/RebalanceResult.java	14
tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicListSubCommand.java	84
tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateOrderConfCommand.java	74
tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java	70
tools/src/main/java/org/apache/rocketmq/tools/command/topic/AllocateMQSubCommand.java	66
tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicClusterSubCommand.java	44
tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateStaticTopicSubCommand.java	155
tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicPermSubCommand.java	135
tools/src/main/java/org/apache/rocketmq/tools/command/CommandUtil.java	143
tools/src/main/java/org/apache/rocketmq/tools/command/controller/GetControllerMetaDataSubCommand.java	52
tools/src/main/java/org/apache/rocketmq/tools/command/controller/CleanControllerBrokerMetaSubCommand.java	75
tools/src/main/java/org/apache/rocketmq/tools/command/controller/ReElectMasterSubCommand.java	64
tools/src/main/java/org/apache/rocketmq/tools/command/controller/GetControllerConfigSubCommand.java	58
tools/src/main/java/org/apache/rocketmq/tools/command/controller/UpdateControllerConfigSubCommand.java	62
tools/src/main/java/org/apache/rocketmq/tools/command/container/RemoveBrokerSubCommand.java	58
tools/src/main/java/org/apache/rocketmq/tools/command/container/AddBrokerSubCommand.java	45
tools/src/main/java/org/apache/rocketmq/tools/command/SubCommandException.java	13
tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/WipeWritePermSubCommand.java	58
tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/GetNamesrvConfigCommand.java	55
tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/DeleteKvConfigCommand.java	44
tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateKvConfigCommand.java	51
tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/AddWritePermSubCommand.java	58
tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/UpdateNamesrvConfigCommand.java	59
tools/src/main/java/org/apache/rocketmq/tools/command/queue/CheckRocksdbCqWriteProgressCommand.java	74
tools/src/main/java/org/apache/rocketmq/tools/command/queue/QueryConsumeQueueCommand.java	112
tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportConfigsCommand.java	101
tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataCommand.java	134
tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataInRocksDBCommand.java	108
tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetricsCommand.java	207
tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportPopRecordCommand.java	82
tools/src/main/java/org/apache/rocketmq/tools/command/producer/ProducerSubCommand.java	60
tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByIdSubCommand.java	265
tools/src/main/java/org/apache/rocketmq/tools/command/message/DumpCompactionLogCommand.java	82
tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageByQueueCommand.java	199
tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByKeySubCommand.java	87
tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByOffsetSubCommand.java	83
tools/src/main/java/org/apache/rocketmq/tools/command/message/DecodeMessageIdCommond.java	42
tools/src/main/java/org/apache/rocketmq/tools/command/message/SendMessageCommand.java	129
tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java	152
tools/src/main/java/org/apache/rocketmq/tools/command/message/CheckMsgSendRTCommand.java	104
tools/src/main/java/org/apache/rocketmq/tools/command/message/ConsumeMessageCommand.java	243
tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgTraceByIdSubCommand.java	155
tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommand.java	169
tools/src/main/java/org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java	159
tools/src/main/java/org/apache/rocketmq/tools/command/auth/DeleteAclSubCommand.java	78
tools/src/main/java/org/apache/rocketmq/tools/command/auth/ListAclSubCommand.java	100
tools/src/main/java/org/apache/rocketmq/tools/command/auth/UpdateAclSubCommand.java	105
tools/src/main/java/org/apache/rocketmq/tools/command/auth/CreateUserSubCommand.java	76
tools/src/main/java/org/apache/rocketmq/tools/command/auth/CopyAclsSubCommand.java	79
tools/src/main/java/org/apache/rocketmq/tools/command/auth/UpdateUserSubCommand.java	80
tools/src/main/java/org/apache/rocketmq/tools/command/auth/ListUserSubCommand.java	85
tools/src/main/java/org/apache/rocketmq/tools/command/auth/CopyUsersSubCommand.java	79
tools/src/main/java/org/apache/rocketmq/tools/command/auth/CreateAclSubCommand.java	105
tools/src/main/java/org/apache/rocketmq/tools/command/auth/DeleteUserSubCommand.java	68
tools/src/main/java/org/apache/rocketmq/tools/command/auth/GetUserSubCommand.java	86
tools/src/main/java/org/apache/rocketmq/tools/command/auth/GetAclSubCommand.java	98
tools/src/main/resources/rmq.tools.logback.xml	65
openmessaging/src/main/java/io/openmessaging/rocketmq/MessagingAccessPointImpl.java	69
openmessaging/src/main/java/io/openmessaging/rocketmq/utils/BeanUtils.java	126
openmessaging/src/main/java/io/openmessaging/rocketmq/utils/OMSUtil.java	124
openmessaging/src/main/java/io/openmessaging/rocketmq/config/ClientConfig.java	138
openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/LocalMessageCache.java	176
openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/PullConsumerImpl.java	145
openmessaging/src/main/java/io/openmessaging/rocketmq/consumer/PushConsumerImpl.java	162
openmessaging/src/main/java/io/openmessaging/rocketmq/domain/BytesMessageImpl.java	80
openmessaging/src/main/java/io/openmessaging/rocketmq/domain/RocketMQConstants.java	4
openmessaging/src/main/java/io/openmessaging/rocketmq/domain/NonStandardKeys.java	13
openmessaging/src/main/java/io/openmessaging/rocketmq/domain/SendResultImpl.java	18
openmessaging/src/main/java/io/openmessaging/rocketmq/domain/ConsumeRequest.java	31
openmessaging/src/main/java/io/openmessaging/rocketmq/promise/FutureState.java	19
openmessaging/src/main/java/io/openmessaging/rocketmq/promise/DefaultPromise.java	178
openmessaging/src/main/java/io/openmessaging/rocketmq/producer/AbstractOMSProducer.java	111
openmessaging/src/main/java/io/openmessaging/rocketmq/producer/ProducerImpl.java	112
common/src/main/java/org/apache/rocketmq/common/metrics/NopLongUpDownCounter.java	12
common/src/main/java/org/apache/rocketmq/common/metrics/NopLongCounter.java	12
common/src/main/java/org/apache/rocketmq/common/metrics/NopObservableLongGauge.java	4
common/src/main/java/org/apache/rocketmq/common/metrics/NopLongHistogram.java	12
common/src/main/java/org/apache/rocketmq/common/metrics/NopObservableDoubleGauge.java	4
common/src/main/java/org/apache/rocketmq/common/metrics/MetricsExporterType.java	29
common/src/main/java/org/apache/rocketmq/common/compression/Compressor.java	6
common/src/main/java/org/apache/rocketmq/common/compression/ZstdCompressor.java	63
common/src/main/java/org/apache/rocketmq/common/compression/ZlibCompressor.java	73
common/src/main/java/org/apache/rocketmq/common/compression/CompressorFactory.java	14
common/src/main/java/org/apache/rocketmq/common/compression/CompressionType.java	51
common/src/main/java/org/apache/rocketmq/common/compression/Lz4Compressor.java	63
common/src/main/java/org/apache/rocketmq/common/filter/MessageFilter.java	5
common/src/main/java/org/apache/rocketmq/common/filter/ExpressionType.java	11
common/src/main/java/org/apache/rocketmq/common/filter/FilterContext.java	10
common/src/main/java/org/apache/rocketmq/common/filter/impl/PolishExpr.java	126
common/src/main/java/org/apache/rocketmq/common/filter/impl/Operand.java	6
common/src/main/java/org/apache/rocketmq/common/filter/impl/Type.java	8
common/src/main/java/org/apache/rocketmq/common/filter/impl/Operator.java	43
common/src/main/java/org/apache/rocketmq/common/filter/impl/Op.java	13
common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java	33
common/src/main/java/org/apache/rocketmq/common/chain/Handler.java	4
common/src/main/java/org/apache/rocketmq/common/chain/HandlerChain.java	28
common/src/main/java/org/apache/rocketmq/common/TopicAttributes.java	43
common/src/main/java/org/apache/rocketmq/common/AbortProcessException.java	31
common/src/main/java/org/apache/rocketmq/common/SubscriptionGroupAttributes.java	10
common/src/main/java/org/apache/rocketmq/common/TopicConfig.java	207
common/src/main/java/org/apache/rocketmq/common/ThreadFactoryImpl.java	39
common/src/main/java/org/apache/rocketmq/common/state/StateEventListener.java	4
common/src/main/java/org/apache/rocketmq/common/utils/CleanupPolicyUtils.java	27
common/src/main/java/org/apache/rocketmq/common/utils/MessageUtils.java	68
common/src/main/java/org/apache/rocketmq/common/utils/CorrelationIdUtil.java	7
common/src/main/java/org/apache/rocketmq/common/utils/Serializer.java	6
common/src/main/java/org/apache/rocketmq/common/utils/Start.java	4
common/src/main/java/org/apache/rocketmq/common/utils/ExceptionUtils.java	24
common/src/main/java/org/apache/rocketmq/common/utils/ChannelUtil.java	14
common/src/main/java/org/apache/rocketmq/common/utils/BinaryUtil.java	36
common/src/main/java/org/apache/rocketmq/common/utils/PositiveAtomicCounter.java	16
common/src/main/java/org/apache/rocketmq/common/utils/DataConverter.java	21
common/src/main/java/org/apache/rocketmq/common/utils/FutureUtils.java	24
common/src/main/java/org/apache/rocketmq/common/utils/AsyncShutdownHelper.java	52
common/src/main/java/org/apache/rocketmq/common/utils/QueueTypeUtils.java	27
common/src/main/java/org/apache/rocketmq/common/utils/CheckpointFile.java	92
common/src/main/java/org/apache/rocketmq/common/utils/NameServerAddressUtils.java	29
common/src/main/java/org/apache/rocketmq/common/utils/StartAndShutdown.java	4
common/src/main/java/org/apache/rocketmq/common/utils/ThreadUtils.java	139
common/src/main/java/org/apache/rocketmq/common/utils/IPAddressUtils.java	77
common/src/main/java/org/apache/rocketmq/common/utils/IOTinyUtils.java	123
common/src/main/java/org/apache/rocketmq/common/utils/ServiceProvider.java	139
common/src/main/java/org/apache/rocketmq/common/utils/HttpTinyClient.java	99
common/src/main/java/org/apache/rocketmq/common/utils/Shutdown.java	4
common/src/main/java/org/apache/rocketmq/common/utils/FastJsonSerializer.java	37
common/src/main/java/org/apache/rocketmq/common/utils/ConcurrentHashMapUtils.java	33
common/src/main/java/org/apache/rocketmq/common/utils/AbstractStartAndShutdown.java	51
common/src/main/java/org/apache/rocketmq/common/utils/NetworkUtil.java	171
common/src/main/java/org/apache/rocketmq/common/logging/DefaultJoranConfiguratorExt.java	137
common/src/main/java/org/apache/rocketmq/common/logging/JoranConfiguratorExt.java	49
common/src/main/java/org/apache/rocketmq/common/hook/FilterCheckHook.java	6
common/src/main/java/org/apache/rocketmq/common/coldctr/AccAndTimeStamp.java	36
common/src/main/java/org/apache/rocketmq/common/BoundaryType.java	18
common/src/main/java/org/apache/rocketmq/common/annotation/ImportantField.java	11
common/src/main/java/org/apache/rocketmq/common/Pair.java	25
common/src/main/java/org/apache/rocketmq/common/config/ConfigHelper.java	104
common/src/main/java/org/apache/rocketmq/common/config/ConfigManagerVersion.java	13
common/src/main/java/org/apache/rocketmq/common/config/ConfigRocksDBStorage.java	106
common/src/main/java/org/apache/rocketmq/common/config/AbstractRocksDBStorage.java	495
common/src/main/java/org/apache/rocketmq/common/ServiceState.java	7
common/src/main/java/org/apache/rocketmq/common/consumer/ReceiptHandle.java	184
common/src/main/java/org/apache/rocketmq/common/consumer/ConsumeFromWhere.java	12
common/src/main/java/org/apache/rocketmq/common/running/RunningStats.java	8
common/src/main/java/org/apache/rocketmq/common/AbstractBrokerRunnable.java	22
common/src/main/java/org/apache/rocketmq/common/LockCallback.java	7
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolQueueSizeMonitor.java	20
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolMonitor.java	101
common/src/main/java/org/apache/rocketmq/common/thread/FutureTaskExtThreadPoolExecutor.java	21
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolStatusMonitor.java	7
common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolWrapper.java	86
common/src/main/java/org/apache/rocketmq/common/MixAll.java	473
common/src/main/java/org/apache/rocketmq/common/TopicFilterType.java	5
common/src/main/java/org/apache/rocketmq/common/CheckRocksdbCqWriteResult.java	30
common/src/main/java/org/apache/rocketmq/common/topic/TopicValidator.java	106
common/src/main/java/org/apache/rocketmq/common/constant/PermName.java	45
common/src/main/java/org/apache/rocketmq/common/constant/ConsumeInitMode.java	5
common/src/main/java/org/apache/rocketmq/common/constant/GrpcConstants.java	36
common/src/main/java/org/apache/rocketmq/common/constant/CommonConstants.java	11
common/src/main/java/org/apache/rocketmq/common/constant/DBMsgConstants.java	4
common/src/main/java/org/apache/rocketmq/common/constant/FIleReadaheadMode.java	4
common/src/main/java/org/apache/rocketmq/common/constant/HAProxyConstants.java	10
common/src/main/java/org/apache/rocketmq/common/constant/LoggerName.java	40
common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java	1424
common/src/main/java/org/apache/rocketmq/common/action/RocketMQAction.java	10
common/src/main/java/org/apache/rocketmq/common/action/Action.java	36
common/src/main/java/org/apache/rocketmq/common/MQVersion.java	633
common/src/main/java/org/apache/rocketmq/common/future/FutureTaskExt.java	17
common/src/main/java/org/apache/rocketmq/common/resource/ResourceType.java	32
common/src/main/java/org/apache/rocketmq/common/resource/RocketMQResource.java	8
common/src/main/java/org/apache/rocketmq/common/resource/ResourcePattern.java	20
common/src/main/java/org/apache/rocketmq/common/ConfigManager.java	66
common/src/main/java/org/apache/rocketmq/common/SystemClock.java	6
common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvUtil.java	4
common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java	159
common/src/main/java/org/apache/rocketmq/common/namesrv/TopAddressing.java	5
common/src/main/java/org/apache/rocketmq/common/namesrv/NameServerUpdateCallback.java	4
common/src/main/java/org/apache/rocketmq/common/namesrv/DefaultTopAddressing.java	128
common/src/main/java/org/apache/rocketmq/common/consistenthash/Node.java	4
common/src/main/java/org/apache/rocketmq/common/consistenthash/ConsistentHashRouter.java	84
common/src/main/java/org/apache/rocketmq/common/consistenthash/VirtualNode.java	19
common/src/main/java/org/apache/rocketmq/common/consistenthash/HashFunction.java	4
common/src/main/java/org/apache/rocketmq/common/UtilAll.java	638
common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java	57
common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java	33
common/src/main/java/org/apache/rocketmq/common/sysflag/SubscriptionSysFlag.java	22
common/src/main/java/org/apache/rocketmq/common/sysflag/TopicSysFlag.java	33
common/src/main/java/org/apache/rocketmq/common/fastjson/GenericMapSuperclassDeserializer.java	36
common/src/main/java/org/apache/rocketmq/common/queue/ConcurrentTreeMap.java	46
common/src/main/java/org/apache/rocketmq/common/queue/RoundQueue.java	22
common/src/main/java/org/apache/rocketmq/common/attribute/AttributeUtil.java	99
common/src/main/java/org/apache/rocketmq/common/attribute/BooleanAttribute.java	19
common/src/main/java/org/apache/rocketmq/common/attribute/CleanupPolicy.java	5
common/src/main/java/org/apache/rocketmq/common/attribute/EnumAttribute.java	20
common/src/main/java/org/apache/rocketmq/common/attribute/CQType.java	6
common/src/main/java/org/apache/rocketmq/common/attribute/LongRangeAttribute.java	23
common/src/main/java/org/apache/rocketmq/common/attribute/TopicMessageType.java	41
common/src/main/java/org/apache/rocketmq/common/attribute/AttributeParser.java	57
common/src/main/java/org/apache/rocketmq/common/attribute/Attribute.java	22
common/src/main/java/org/apache/rocketmq/common/UnlockCallback.java	5
common/src/main/java/org/apache/rocketmq/common/PopAckConstants.java	21
common/src/main/java/org/apache/rocketmq/common/LifecycleAwareServiceThread.java	27
common/src/main/java/org/apache/rocketmq/common/KeyBuilder.java	56
common/src/main/java/org/apache/rocketmq/common/ObjectCreator.java	4
common/src/main/java/org/apache/rocketmq/common/help/FAQUrl.java	40
common/src/main/java/org/apache/rocketmq/common/BrokerIdentity.java	104
common/src/main/java/org/apache/rocketmq/common/producer/RecallMessageHandle.java	59
common/src/main/java/org/apache/rocketmq/common/ServiceThread.java	96
common/src/main/java/org/apache/rocketmq/common/BrokerConfigSingleton.java	18
common/src/main/java/org/apache/rocketmq/common/CountDownLatch2.java	59
common/src/main/java/org/apache/rocketmq/common/ControllerConfig.java	218
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemScheduledPrinter.java	52
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsBrief.java	133
common/src/main/java/org/apache/rocketmq/common/statistics/FutureHolder.java	32
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemPrinter.java	25
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsManager.java	97
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsBriefInterceptor.java	47
common/src/main/java/org/apache/rocketmq/common/statistics/Interceptor.java	5
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItem.java	108
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemScheduledIncrementPrinter.java	209
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsKindMeta.java	24
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemFormatter.java	15
common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemStateGetter.java	4
common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java	217
common/src/main/java/org/apache/rocketmq/common/message/MessageRequestMode.java	12
common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java	121
common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java	565
common/src/main/java/org/apache/rocketmq/common/message/MessageAccessor.java	68
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java	51
common/src/main/java/org/apache/rocketmq/common/message/MessageClientExt.java	20
common/src/main/java/org/apache/rocketmq/common/message/MessageConst.java	123
common/src/main/java/org/apache/rocketmq/common/message/MessageExtBatch.java	23
common/src/main/java/org/apache/rocketmq/common/message/MessageVersion.java	59
common/src/main/java/org/apache/rocketmq/common/message/MessageBatch.java	48
common/src/main/java/org/apache/rocketmq/common/message/MessageQueueForC.java	101
common/src/main/java/org/apache/rocketmq/common/message/Message.java	191
common/src/main/java/org/apache/rocketmq/common/message/MessageExtBrokerInner.java	71
common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java	90
common/src/main/java/org/apache/rocketmq/common/message/MessageType.java	23
common/src/main/java/org/apache/rocketmq/common/message/MessageId.java	22
common/src/main/java/org/apache/rocketmq/common/JraftConfig.java	55
common/src/main/java/org/apache/rocketmq/common/stats/Stats.java	31
common/src/main/java/org/apache/rocketmq/common/stats/StatsItem.java	206
common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java	101
common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java	225
common/src/main/java/org/apache/rocketmq/common/stats/RTStatsItem.java	13
common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItem.java	54
common/src/main/java/org/apache/rocketmq/common/stats/StatsSnapshot.java	31
bazel/GenTestRules.bzl	103
style/rmq_checkstyle.xml	88
style/spotbugs-suppressions.xml	33
style/rmq_codeStyle.xml	126
style/copyright/profiles_settings.xml	47
style/copyright/Apache.xml	6
srvutil/src/main/java/org/apache/rocketmq/srvutil/ShutdownHookThread.java	32
srvutil/src/main/java/org/apache/rocketmq/srvutil/ServerUtil.java	58
srvutil/src/main/java/org/apache/rocketmq/srvutil/FileWatchService.java	73
broker/src/main/java/org/apache/rocketmq/broker/metrics/PopMetricsConstant.java	14
broker/src/main/java/org/apache/rocketmq/broker/metrics/ProducerAttr.java	24
broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerLagCalculator.java	444
broker/src/main/java/org/apache/rocketmq/broker/metrics/ConsumerAttr.java	29
broker/src/main/java/org/apache/rocketmq/broker/metrics/PopReviveMessageType.java	5
broker/src/main/java/org/apache/rocketmq/broker/metrics/PopMetricsManager.java	187
broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsManager.java	605
broker/src/main/java/org/apache/rocketmq/broker/metrics/InvocationStatus.java	12
broker/src/main/java/org/apache/rocketmq/broker/metrics/BrokerMetricsConstant.java	43
broker/src/main/java/org/apache/rocketmq/broker/filter/ExpressionForRetryMessageFilter.java	59
broker/src/main/java/org/apache/rocketmq/broker/filter/MessageEvaluationContext.java	29
broker/src/main/java/org/apache/rocketmq/broker/filter/ConsumerFilterManager.java	354
broker/src/main/java/org/apache/rocketmq/broker/filter/ExpressionMessageFilter.java	113
broker/src/main/java/org/apache/rocketmq/broker/filter/ConsumerFilterData.java	97
broker/src/main/java/org/apache/rocketmq/broker/filter/CommitLogDispatcherCalcBitMap.java	69
broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java	321
broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java	33
broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java	219
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerKVStore.java	10
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerCache.java	242
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRecord.java	146
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerRocksdbStore.java	129
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerService.java	599
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerLockService.java	69
broker/src/main/java/org/apache/rocketmq/broker/pop/PopConsumerContext.java	125
broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java	2119
broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetricsFlushService.java	34
broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java	81
broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionMetrics.java	207
broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageCheckService.java	38
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java	310
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/GetResult.java	19
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/DefaultTransactionalMessageCheckListener.java	58
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java	616
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalOpBatchService.java	40
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/MessageQueueOpContext.java	24
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageUtil.java	63
broker/src/main/java/org/apache/rocketmq/broker/transaction/OperationResult.java	25
broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageService.java	18
broker/src/main/java/org/apache/rocketmq/broker/pagecache/QueryMessageTransfer.java	79
broker/src/main/java/org/apache/rocketmq/broker/pagecache/ManyMessageTransfer.java	79
broker/src/main/java/org/apache/rocketmq/broker/pagecache/OneMessageTransfer.java	68
broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdCtrStrategy.java	7
broker/src/main/java/org/apache/rocketmq/broker/coldctr/SimpleColdCtrStrategy.java	29
broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataPullRequestHoldService.java	71
broker/src/main/java/org/apache/rocketmq/broker/coldctr/ColdDataCgCtrService.java	195
broker/src/main/java/org/apache/rocketmq/broker/coldctr/PIDAdaptiveColdCtrStrategy.java	56
broker/src/main/java/org/apache/rocketmq/broker/BrokerPreOnlineService.java	233
broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConfigHelper.java	93
broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConsumerOffsetManagerV2.java	320
broker/src/main/java/org/apache/rocketmq/broker/config/v2/RecordPrefix.java	13
broker/src/main/java/org/apache/rocketmq/broker/config/v2/SubscriptionGroupManagerV2.java	142
broker/src/main/java/org/apache/rocketmq/broker/config/v2/TablePrefix.java	12
broker/src/main/java/org/apache/rocketmq/broker/config/v2/TableId.java	15
broker/src/main/java/org/apache/rocketmq/broker/config/v2/ConfigStorage.java	191
broker/src/main/java/org/apache/rocketmq/broker/config/v2/SerializationType.java	22
broker/src/main/java/org/apache/rocketmq/broker/config/v2/TopicConfigManagerV2.java	145
broker/src/main/java/org/apache/rocketmq/broker/config/v2/package-info.java	1
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBTopicConfigManager.java	128
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBConsumerOffsetManager.java	132
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBOffsetSerializeWrapper.java	13
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBSubscriptionGroupManager.java	208
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBLmqTopicConfigManager.java	34
broker/src/main/java/org/apache/rocketmq/broker/config/v1/RocksDBLmqSubscriptionGroupManager.java	33
broker/src/main/java/org/apache/rocketmq/broker/BrokerPathConfigHelper.java	48
broker/src/main/java/org/apache/rocketmq/broker/util/PositiveAtomicCounter.java	16
broker/src/main/java/org/apache/rocketmq/broker/util/HookUtils.java	194
broker/src/main/java/org/apache/rocketmq/broker/client/ProducerGroupEvent.java	5
broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java	282
broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java	193
broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerIdsChangeListener.java	5
broker/src/main/java/org/apache/rocketmq/broker/client/ProducerChangeListener.java	4
broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java	355
broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java	212
broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java	133
broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java	256
broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java	8
broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelAttributeHelper.java	51
broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java	65
broker/src/main/java/org/apache/rocketmq/broker/client/ClientChannelInfo.java	70
broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoLockManager.java	146
broker/src/main/java/org/apache/rocketmq/broker/offset/BroadcastOffsetStore.java	32
broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java	357
broker/src/main/java/org/apache/rocketmq/broker/offset/LmqConsumerOffsetManager.java	100
broker/src/main/java/org/apache/rocketmq/broker/offset/BroadcastOffsetManager.java	159
broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java	484
broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java	1271
broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java	624
broker/src/main/java/org/apache/rocketmq/broker/topic/TopicRouteInfoManager.java	203
broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingCleanService.java	297
broker/src/main/java/org/apache/rocketmq/broker/topic/LmqTopicConfigManager.java	34
broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java	204
broker/src/main/java/org/apache/rocketmq/broker/loadbalance/MessageRequestModeManager.java	63
broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageHook.java	6
broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageHook.java	6
broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java	174
broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java	230
broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java	128
broker/src/main/java/org/apache/rocketmq/broker/processor/PopInflightMessageCounter.java	123
broker/src/main/java/org/apache/rocketmq/broker/processor/RecallMessageProcessor.java	157
broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java	416
broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java	624
broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java	769
broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java	266
broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java	262
broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageCallback.java	6
broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java	189
broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java	307
broker/src/main/java/org/apache/rocketmq/broker/processor/DefaultPullMessageResultHandler.java	246
broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java	2976
broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java	943
broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java	237
broker/src/main/java/org/apache/rocketmq/broker/processor/PollingInfoProcessor.java	90
broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java	593
broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java	495
broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java	144
broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java	299
broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java	769
broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java	297
broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java	303
broker/src/main/java/org/apache/rocketmq/broker/controller/ReplicasManager.java	681
broker/src/main/java/org/apache/rocketmq/broker/plugin/PullMessageResultHandler.java	22
broker/src/main/java/org/apache/rocketmq/broker/plugin/BrokerAttachedPlugin.java	12
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PollingResult.java	7
broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotificationRequest.java	31
broker/src/main/java/org/apache/rocketmq/broker/longpolling/LmqPullRequestHoldService.java	43
broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotifyMessageArrivingListener.java	25
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopLongPollingService.java	356
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PollingHeader.java	39
broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java	26
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequest.java	46
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java	165
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopRequest.java	73
broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopCommandCallback.java	24
broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java	252
broker/src/main/java/org/apache/rocketmq/broker/dledger/DLedgerRoleChangeHandler.java	145
broker/src/main/java/org/apache/rocketmq/broker/ShutdownHook.java	4
broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java	335
broker/src/main/java/org/apache/rocketmq/broker/RocksDBConfigManager.java	116
broker/src/main/java/org/apache/rocketmq/broker/schedule/DelayOffsetSerializeWrapper.java	22
broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java	697
broker/src/main/java/org/apache/rocketmq/broker/auth/pipeline/AuthorizationPipeline.java	43
broker/src/main/java/org/apache/rocketmq/broker/auth/pipeline/AuthenticationPipeline.java	41
broker/src/main/java/org/apache/rocketmq/broker/auth/converter/UserConverter.java	33
broker/src/main/java/org/apache/rocketmq/broker/auth/converter/AclConverter.java	96
broker/src/main/resources/transaction.sql	4
broker/src/main/resources/rmq.broker.logback.xml	664
store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsConstant.java	30
store/src/main/java/org/apache/rocketmq/store/metrics/RocksDBStoreMetricsManager.java	114
store/src/main/java/org/apache/rocketmq/store/metrics/DefaultStoreMetricsManager.java	216
store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java	979
store/src/main/java/org/apache/rocketmq/store/PutMessageSpinLock.java	17
store/src/main/java/org/apache/rocketmq/store/pop/AckMsg.java	73
store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java	148
store/src/main/java/org/apache/rocketmq/store/pop/BatchAckMsg.java	27
store/src/main/java/org/apache/rocketmq/store/TransientStorePool.java	60
store/src/main/java/org/apache/rocketmq/store/CommitLogDispatcher.java	5
store/src/main/java/org/apache/rocketmq/store/RunningFlags.java	110
store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java	739
store/src/main/java/org/apache/rocketmq/store/PutMessageStatus.java	19
store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAClient.java	312
store/src/main/java/org/apache/rocketmq/store/ha/io/HAWriteHook.java	4
store/src/main/java/org/apache/rocketmq/store/ha/io/HAReadHook.java	4
store/src/main/java/org/apache/rocketmq/store/ha/io/AbstractHAReader.java	50
store/src/main/java/org/apache/rocketmq/store/ha/io/HAWriter.java	38
store/src/main/java/org/apache/rocketmq/store/ha/HAConnectionState.java	8
store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java	288
store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAConnection.java	363
store/src/main/java/org/apache/rocketmq/store/ha/HAConnection.java	13
store/src/main/java/org/apache/rocketmq/store/ha/HAService.java	39
store/src/main/java/org/apache/rocketmq/store/ha/WaitNotifyObject.java	85
store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java	128
store/src/main/java/org/apache/rocketmq/store/ha/HAConnectionStateNotificationService.java	105
store/src/main/java/org/apache/rocketmq/store/ha/HAConnectionStateNotificationRequest.java	25
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAClient.java	443
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAConnection.java	558
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/EpochFileCache.java	264
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/MetadataFile.java	30
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/BrokerMetadata.java	72
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/AutoSwitchHAService.java	456
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/TempBrokerMetadata.java	65
store/src/main/java/org/apache/rocketmq/store/ha/FlowMonitor.java	46
store/src/main/java/org/apache/rocketmq/store/ha/HAClient.java	16
store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java	139
store/src/main/java/org/apache/rocketmq/store/PutMessageContext.java	24
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java	2709
store/src/main/java/org/apache/rocketmq/store/AppendMessageResult.java	120
store/src/main/java/org/apache/rocketmq/store/logfile/AbstractMappedFile.java	4
store/src/main/java/org/apache/rocketmq/store/logfile/DefaultMappedFile.java	753
store/src/main/java/org/apache/rocketmq/store/logfile/MappedFile.java	67
store/src/main/java/org/apache/rocketmq/store/LmqDispatch.java	36
store/src/main/java/org/apache/rocketmq/store/MessageArrivingListener.java	6
store/src/main/java/org/apache/rocketmq/store/SelectMappedBufferResult.java	54
store/src/main/java/org/apache/rocketmq/store/QueryMessageResult.java	43
store/src/main/java/org/apache/rocketmq/store/MessageFilter.java	9
store/src/main/java/org/apache/rocketmq/store/hook/PutMessageHook.java	7
store/src/main/java/org/apache/rocketmq/store/hook/SendMessageBackHook.java	6
store/src/main/java/org/apache/rocketmq/store/config/StorePathConfigHelper.java	34
store/src/main/java/org/apache/rocketmq/store/config/FlushDiskType.java	5
store/src/main/java/org/apache/rocketmq/store/config/BrokerRole.java	6
store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java	1348
store/src/main/java/org/apache/rocketmq/store/GetMessageStatus.java	13
store/src/main/java/org/apache/rocketmq/store/util/LibC.java	27
store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java	305
store/src/main/java/org/apache/rocketmq/store/Swappable.java	5
store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java	202
store/src/main/java/org/apache/rocketmq/store/exception/StoreException.java	17
store/src/main/java/org/apache/rocketmq/store/exception/ConsumeQueueException.java	18
store/src/main/java/org/apache/rocketmq/store/PutMessageReentrantLock.java	13
store/src/main/java/org/apache/rocketmq/store/timer/Slot.java	23
store/src/main/java/org/apache/rocketmq/store/timer/TimerMessageStore.java	1673
store/src/main/java/org/apache/rocketmq/store/timer/TimerWheel.java	167
store/src/main/java/org/apache/rocketmq/store/timer/TimerLog.java	90
store/src/main/java/org/apache/rocketmq/store/timer/TimerCheckpoint.java	141
store/src/main/java/org/apache/rocketmq/store/timer/TimerRequest.java	88
store/src/main/java/org/apache/rocketmq/store/timer/TimerMetrics.java	256
store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java	536
store/src/main/java/org/apache/rocketmq/store/AppendMessageStatus.java	9
store/src/main/java/org/apache/rocketmq/store/AppendMessageCallback.java	10
store/src/main/java/org/apache/rocketmq/store/MessageStore.java	166
store/src/main/java/org/apache/rocketmq/store/StoreCheckpoint.java	107
store/src/main/java/org/apache/rocketmq/store/MessageExtEncoder.java	287
store/src/main/java/org/apache/rocketmq/store/kv/CompactionStore.java	195
store/src/main/java/org/apache/rocketmq/store/kv/CompactionLog.java	940
store/src/main/java/org/apache/rocketmq/store/kv/CompactionPositionMgr.java	57
store/src/main/java/org/apache/rocketmq/store/kv/CompactionService.java	62
store/src/main/java/org/apache/rocketmq/store/kv/CommitLogDispatcherCompaction.java	15
store/src/main/java/org/apache/rocketmq/store/kv/MessageFetcher.java	163
store/src/main/java/org/apache/rocketmq/store/lock/AdaptiveBackOffSpinLockImpl.java	143
store/src/main/java/org/apache/rocketmq/store/lock/BackOffSpinLock.java	75
store/src/main/java/org/apache/rocketmq/store/lock/BackOffReentrantLock.java	13
store/src/main/java/org/apache/rocketmq/store/lock/AdaptiveBackOffSpinLock.java	9
store/src/main/java/org/apache/rocketmq/store/PutMessageLock.java	5
store/src/main/java/org/apache/rocketmq/store/RocksDBMessageStore.java	146
store/src/main/java/org/apache/rocketmq/store/plugin/AbstractPluginMessageStore.java	531
store/src/main/java/org/apache/rocketmq/store/plugin/MessageStoreFactory.java	26
store/src/main/java/org/apache/rocketmq/store/plugin/MessageStorePluginContext.java	40
store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java	89
store/src/main/java/org/apache/rocketmq/store/ConsumeQueueExt.java	367
store/src/main/java/org/apache/rocketmq/store/DefaultMessageFilter.java	25
store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java	910
store/src/main/java/org/apache/rocketmq/store/StoreType.java	12
store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java	186
store/src/main/java/org/apache/rocketmq/store/index/QueryOffsetResult.java	22
store/src/main/java/org/apache/rocketmq/store/index/IndexService.java	321
store/src/main/java/org/apache/rocketmq/store/index/IndexHeader.java	84
store/src/main/java/org/apache/rocketmq/store/CompactionAppendMsgCallback.java	5
store/src/main/java/org/apache/rocketmq/store/FlushDiskWatcher.java	53
store/src/main/java/org/apache/rocketmq/store/FileQueueSnapshot.java	61
store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java	262
store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueInterface.java	35
store/src/main/java/org/apache/rocketmq/store/queue/RocksGroupCommitService.java	68
store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueTable.java	291
store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueOffsetTable.java	555
store/src/main/java/org/apache/rocketmq/store/queue/BatchConsumeQueue.java	949
store/src/main/java/org/apache/rocketmq/store/queue/MultiDispatchUtils.java	39
store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueueStore.java	444
store/src/main/java/org/apache/rocketmq/store/queue/offset/OffsetEntry.java	8
store/src/main/java/org/apache/rocketmq/store/queue/offset/OffsetEntryType.java	5
store/src/main/java/org/apache/rocketmq/store/queue/RocksDBConsumeQueue.java	366
store/src/main/java/org/apache/rocketmq/store/queue/OffsetInitializer.java	5
store/src/main/java/org/apache/rocketmq/store/queue/SparseConsumeQueue.java	321
store/src/main/java/org/apache/rocketmq/store/queue/QueueOffsetOperator.java	87
store/src/main/java/org/apache/rocketmq/store/queue/BatchOffsetIndex.java	31
store/src/main/java/org/apache/rocketmq/store/queue/DispatchEntry.java	24
store/src/main/java/org/apache/rocketmq/store/queue/ReferredIterator.java	6
store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStoreInterface.java	52
store/src/main/java/org/apache/rocketmq/store/queue/OffsetInitializerRocksDBImpl.java	22
store/src/main/java/org/apache/rocketmq/store/queue/CqUnit.java	75
store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java	499
store/src/main/java/org/apache/rocketmq/store/queue/FileQueueLifeCycle.java	14
store/src/main/java/org/apache/rocketmq/store/queue/AbstractConsumeQueueStore.java	88
store/src/main/java/org/apache/rocketmq/store/StoreUtil.java	52
store/src/main/java/org/apache/rocketmq/store/rocksdb/ConsumeQueueRocksDBStorage.java	85
store/src/main/java/org/apache/rocketmq/store/rocksdb/RocksDBOptionsFactory.java	186
store/src/main/java/org/apache/rocketmq/store/rocksdb/ConsumeQueueCompactionFilterFactory.java	26
store/src/main/java/org/apache/rocketmq/store/ReferenceResource.java	48
store/src/main/java/org/apache/rocketmq/store/CommitLog.java	1970
store/src/main/java/org/apache/rocketmq/store/FlushManager.java	11
store/src/main/java/org/apache/rocketmq/store/SelectMappedFileResult.java	19
store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java	698
store/src/main/java/org/apache/rocketmq/store/stats/LmqBrokerStatsManager.java	54
store/src/main/java/org/apache/rocketmq/store/stats/BrokerStats.java	56
store/src/main/java/org/apache/rocketmq/store/PutMessageResult.java	47
store/src/main/java/org/apache/rocketmq/store/TopicQueueLock.java	31
client/src/main/java/org/apache/rocketmq/acl/common/AclSigner.java	63
client/src/main/java/org/apache/rocketmq/acl/common/AclConstants.java	10
client/src/main/java/org/apache/rocketmq/acl/common/AclClientRPCHook.java	33
client/src/main/java/org/apache/rocketmq/acl/common/AclException.java	39
client/src/main/java/org/apache/rocketmq/acl/common/Permission.java	25
client/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java	122
client/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java	229
client/src/main/java/org/apache/rocketmq/acl/common/SigningAlgorithm.java	6
client/src/main/java/org/apache/rocketmq/client/utils/MessageUtil.java	34
client/src/main/java/org/apache/rocketmq/client/common/ThreadLocalIndex.java	25
client/src/main/java/org/apache/rocketmq/client/common/ClientErrorCode.java	10
client/src/main/java/org/apache/rocketmq/client/common/NameserverAccessConfig.java	20
client/src/main/java/org/apache/rocketmq/client/MqClientAdmin.java	73
client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageHook.java	5
client/src/main/java/org/apache/rocketmq/client/hook/SendMessageHook.java	6
client/src/main/java/org/apache/rocketmq/client/hook/ConsumeMessageHook.java	6
client/src/main/java/org/apache/rocketmq/client/hook/ConsumeMessageContext.java	71
client/src/main/java/org/apache/rocketmq/client/hook/SendMessageContext.java	101
client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenContext.java	84
client/src/main/java/org/apache/rocketmq/client/hook/EndTransactionContext.java	54
client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenHook.java	6
client/src/main/java/org/apache/rocketmq/client/hook/EndTransactionHook.java	5
client/src/main/java/org/apache/rocketmq/client/hook/FilterMessageContext.java	46
client/src/main/java/org/apache/rocketmq/client/rpchook/NamespaceRpcHook.java	23
client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java	3
client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java	5
client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java	12
client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java	486
client/src/main/java/org/apache/rocketmq/client/consumer/PullTaskContext.java	17
client/src/main/java/org/apache/rocketmq/client/consumer/TopicMessageQueueChangeListener.java	6
client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java	6
client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java	162
client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java	7
client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.java	43
client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java	235
client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java	19
client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java	16
client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java	206
client/src/main/java/org/apache/rocketmq/client/consumer/store/ControllableOffset.java	37
client/src/main/java/org/apache/rocketmq/client/consumer/store/ReadOffsetType.java	6
client/src/main/java/org/apache/rocketmq/client/consumer/PopStatus.java	7
client/src/main/java/org/apache/rocketmq/client/consumer/AckStatus.java	5
client/src/main/java/org/apache/rocketmq/client/consumer/NotifyResult.java	23
client/src/main/java/org/apache/rocketmq/client/consumer/PullTaskCallback.java	5
client/src/main/java/org/apache/rocketmq/client/consumer/PopResult.java	49
client/src/main/java/org/apache/rocketmq/client/consumer/MessageSelector.java	22
client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java	378
client/src/main/java/org/apache/rocketmq/client/consumer/AckResult.java	28
client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeReturnType.java	8
client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java	5
client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java	9
client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java	25
client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerConcurrently.java	7
client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListenerOrderly.java	7
client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyContext.java	25
client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java	3
client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java	57
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMachineRoomNearby.java	77
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java	25
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueConsistentHash.java	65
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java	21
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AbstractAllocateMessageQueueStrategy.java	31
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java	29
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByMachineRoom.java	48
client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java	43
client/src/main/java/org/apache/rocketmq/client/consumer/AckCallback.java	5
client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java	22
client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java	16
client/src/main/java/org/apache/rocketmq/client/consumer/PopCallback.java	5
client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java	337
client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java	38
client/src/main/java/org/apache/rocketmq/client/exception/OffsetNotFoundException.java	11
client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java	37
client/src/main/java/org/apache/rocketmq/client/exception/RequestTimeoutException.java	31
client/src/main/java/org/apache/rocketmq/client/MQAdmin.java	21
client/src/main/java/org/apache/rocketmq/client/AccessChannel.java	5
client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java	131
client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java	254
client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultTolerance.java	16
client/src/main/java/org/apache/rocketmq/client/latency/ServiceDetector.java	4
client/src/main/java/org/apache/rocketmq/client/latency/Resolver.java	4
client/src/main/java/org/apache/rocketmq/client/lock/ReadWriteCASLock.java	35
client/src/main/java/org/apache/rocketmq/client/Validators.java	92
client/src/main/java/org/apache/rocketmq/client/ClientConfig.java	414
client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java	351
client/src/main/java/org/apache/rocketmq/client/trace/TraceDispatcher.java	14
client/src/main/java/org/apache/rocketmq/client/trace/TraceDispatcherType.java	5
client/src/main/java/org/apache/rocketmq/client/trace/TraceContext.java	100
client/src/main/java/org/apache/rocketmq/client/trace/TraceConstants.java	25
client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageTraceHookImpl.java	69
client/src/main/java/org/apache/rocketmq/client/trace/hook/ConsumeMessageTraceHookImpl.java	89
client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionOpenTracingHookImpl.java	48
client/src/main/java/org/apache/rocketmq/client/trace/hook/ConsumeMessageOpenTracingHookImpl.java	69
client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageOpenTracingHookImpl.java	63
client/src/main/java/org/apache/rocketmq/client/trace/hook/DefaultRecallMessageTraceHook.java	57
client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionTraceHookImpl.java	54
client/src/main/java/org/apache/rocketmq/client/trace/TraceTransferBean.java	19
client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java	211
client/src/main/java/org/apache/rocketmq/client/trace/TraceBean.java	113
client/src/main/java/org/apache/rocketmq/client/trace/TraceView.java	131
client/src/main/java/org/apache/rocketmq/client/trace/TraceType.java	8
client/src/main/java/org/apache/rocketmq/client/MQHelper.java	53
client/src/main/java/org/apache/rocketmq/client/stat/ConsumerStatsManager.java	108
client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java	741
client/src/main/java/org/apache/rocketmq/client/producer/TransactionCheckListener.java	6
client/src/main/java/org/apache/rocketmq/client/producer/RequestFutureHolder.java	77
client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java	454
client/src/main/java/org/apache/rocketmq/client/producer/MQProducer.java	87
client/src/main/java/org/apache/rocketmq/client/producer/SendCallback.java	5
client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java	107
client/src/main/java/org/apache/rocketmq/client/producer/SendStatus.java	7
client/src/main/java/org/apache/rocketmq/client/producer/RequestCallback.java	6
client/src/main/java/org/apache/rocketmq/client/producer/MessageQueueSelector.java	7
client/src/main/java/org/apache/rocketmq/client/producer/TransactionMQProducer.java	99
client/src/main/java/org/apache/rocketmq/client/producer/TransactionSendResult.java	12
client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByMachineRoom.java	19
client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByHash.java	15
client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByRandom.java	14
client/src/main/java/org/apache/rocketmq/client/producer/TransactionListener.java	7
client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionState.java	6
client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java	86
client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIFactory.java	115
client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java	615
client/src/main/java/org/apache/rocketmq/client/impl/mqclient/DoNothingClientRemotingProcessor.java	14
client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java	65
client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java	3092
client/src/main/java/org/apache/rocketmq/client/impl/admin/MqClientAdminImpl.java	395
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java	47
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java	724
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java	388
client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java	651
client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java	235
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java	386
client/src/main/java/org/apache/rocketmq/client/impl/consumer/MQConsumerInner.java	22
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullResultExt.java	33
client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceService.java	40
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopOrderlyService.java	334
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageService.java	23
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java	122
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullRequest.java	78
client/src/main/java/org/apache/rocketmq/client/impl/consumer/MessageQueueLock.java	30
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java	319
client/src/main/java/org/apache/rocketmq/client/impl/consumer/AssignedMessageQueue.java	193
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java	1071
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopRequest.java	93
client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceLitePullImpl.java	146
client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePullImpl.java	74
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java	396
client/src/main/java/org/apache/rocketmq/client/impl/consumer/MessageRequest.java	5
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java	485
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java	1325
client/src/main/java/org/apache/rocketmq/client/impl/FindBrokerResult.java	25
client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java	404
client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java	6
client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java	1183
client/src/main/java/org/apache/rocketmq/client/impl/producer/MQProducerInner.java	18
client/src/main/java/org/apache/rocketmq/client/impl/producer/TopicPublishInfo.java	111
client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java	1578
client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java	245
client/src/main/java/org/apache/rocketmq/client/QueryResult.java	22
client/src/main/resources/rmq.client.logback.xml	38
remoting/src/main/java/org/apache/rocketmq/remoting/metrics/RemotingMetricsManager.java	72
remoting/src/main/java/org/apache/rocketmq/remoting/metrics/RemotingMetricsConstant.java	15
remoting/src/main/java/org/apache/rocketmq/remoting/RemotingServer.java	28
remoting/src/main/java/org/apache/rocketmq/remoting/ChannelEventListener.java	9
remoting/src/main/java/org/apache/rocketmq/remoting/pipeline/RequestPipeline.java	12
remoting/src/main/java/org/apache/rocketmq/remoting/common/TlsMode.java	21
remoting/src/main/java/org/apache/rocketmq/remoting/common/SemaphoreReleaseOnlyOnce.java	20
remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java	309
remoting/src/main/java/org/apache/rocketmq/remoting/common/ServiceThread.java	49
remoting/src/main/java/org/apache/rocketmq/remoting/common/HeartbeatV2Result.java	29
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyEvent.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/netty/TlsHelper.java	178
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java	146
remoting/src/main/java/org/apache/rocketmq/remoting/netty/RemotingResponseCallback.java	5
remoting/src/main/java/org/apache/rocketmq/remoting/netty/RequestTask.java	58
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java	133
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRequestProcessor.java	8
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyEventType.java	8
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyLogger.java	287
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyDecoder.java	40
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java	552
remoting/src/main/java/org/apache/rocketmq/remoting/netty/RemotingCodeDistributionHandler.java	76
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java	658
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyEncoder.java	31
remoting/src/main/java/org/apache/rocketmq/remoting/netty/AttributeKeys.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/netty/FileRegionEncoder.java	37
remoting/src/main/java/org/apache/rocketmq/remoting/netty/ResponseFuture.java	125
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java	1064
remoting/src/main/java/org/apache/rocketmq/remoting/netty/TlsSystemConfig.java	35
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettySystemConfig.java	51
remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNullable.java	11
remoting/src/main/java/org/apache/rocketmq/remoting/annotation/CFNotNull.java	11
remoting/src/main/java/org/apache/rocketmq/remoting/rpchook/DynamicalExtFieldRPCHook.java	21
remoting/src/main/java/org/apache/rocketmq/remoting/rpchook/StreamTypeRPCHook.java	15
remoting/src/main/java/org/apache/rocketmq/remoting/RPCHook.java	7
remoting/src/main/java/org/apache/rocketmq/remoting/proxy/SocksProxyConfig.java	38
remoting/src/main/java/org/apache/rocketmq/remoting/RemotingService.java	9
remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingException.java	10
remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingSendRequestException.java	10
remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingConnectException.java	10
remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingTooMuchRequestException.java	7
remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingCommandException.java	10
remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingTimeoutException.java	13
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcRequest.java	20
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/TopicQueueRequestHeader.java	5
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcClient.java	7
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcClientImpl.java	287
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcResponse.java	40
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/ClientMetadata.java	123
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RequestBuilder.java	55
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcRequestHeader.java	66
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcException.java	19
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcClientUtils.java	36
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/TopicRequestHeader.java	12
remoting/src/main/java/org/apache/rocketmq/remoting/rpc/RpcClientHook.java	5
remoting/src/main/java/org/apache/rocketmq/remoting/CommandCallback.java	4
remoting/src/main/java/org/apache/rocketmq/remoting/Configuration.java	243
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/EpochEntry.java	62
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/filter/FilterAPI.java	47
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/GroupRetryPolicyType.java	5
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/CustomizedRetryPolicy.java	53
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SimpleSubscriptionData.java	62
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/RetryPolicy.java	4
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/SubscriptionGroupConfig.java	180
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/ExponentialRetryPolicy.java	51
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/GroupForbidden.java	54
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/subscription/GroupRetryPolicy.java	51
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicQueueMappingUtils.java	588
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/LogicQueueMappingItem.java	155
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicQueueMappingInfo.java	102
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicRemappingDetailWrapper.java	64
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicQueueMappingDetail.java	97
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicConfigAndQueueMapping.java	45
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicQueueMappingContext.java	60
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/statictopic/TopicQueueMappingOne.java	58
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestType.java	19
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RocketMQSerializable.java	171
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/LanguageCode.java	40
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/ResponseCode.java	64
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingSysResponseCode.java	8
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/NamespaceUtil.java	107
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/MessageModel.java	12
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/ProducerData.java	14
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/ConsumeType.java	13
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/SubscriptionData.java	136
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/HeartbeatData.java	59
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/heartbeat/ConsumerData.java	54
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestHeaderRegistry.java	37
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestSource.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PeekMessageRequestHeader.java	49
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ConsumeMessageDirectlyResultRequestHeader.java	87
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/RecallMessageResponseHeader.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ChangeInvisibleTimeRequestHeader.java	77
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetUserRequestHeader.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PollingInfoRequestHeader.java	44
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CloneGroupOffsetRequestHeader.java	57
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ResetOffsetRequestHeader.java	63
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetTopicsByClusterRequestHeader.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageResponseHeader.java	93
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryConsumeQueueRequestHeader.java	51
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/UnregisterClientRequestHeader.java	41
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ListUsersRequestHeader.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/RecallMessageRequestHeader.java	50
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumeStatsRequestHeader.java	67
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CheckTransactionStateResponseHeader.java	49
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/DeleteTopicRequestHeader.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SearchOffsetRequestHeader.java	62
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CheckTransactionStateRequestHeader.java	71
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PullMessageResponseHeader.java	123
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QuerySubscriptionByConsumerRequestHeader.java	32
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/NotificationResponseHeader.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumeStatsInBrokerHeader.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ExportRocksDBConfigToJsonRequestHeader.java	69
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetAclRequestHeader.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/DeleteSubscriptionGroupRequestHeader.java	31
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/UpdateGroupForbiddenRequestHeader.java	40
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ViewBrokerStatsDataRequestHeader.java	30
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/AckMessageRequestHeader.java	68
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeader.java	171
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetAllProducerInfoRequestHeader.java	13
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetEarliestMsgStoretimeRequestHeader.java	36
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ExtraInfoUtil.java	261
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryCorrectionOffsetHeader.java	41
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryMessageResponseHeader.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/UnlockBatchMqRequestHeader.java	12
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CreateUserRequestHeader.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/NotifyBrokerRoleChangedRequestHeader.java	58
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/RemoveBrokerRequestHeader.java	40
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SearchOffsetResponseHeader.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ResetMasterFlushOffsetHeader.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryTopicsByConsumerRequestHeader.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryConsumeTimeSpanRequestHeader.java	33
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/HeartbeatRequestHeader.java	13
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetTopicConfigRequestHeader.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetMaxOffsetRequestHeader.java	54
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/DeleteAclRequestHeader.java	40
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetMinOffsetRequestHeader.java	44
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetMaxOffsetResponseHeader.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumerStatusRequestHeader.java	51
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/UnregisterClientResponseHeader.java	8
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ExchangeHAInfoResponseHeader.java	33
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CreateTopicRequestHeader.java	120
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ViewMessageResponseHeader.java	8
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetEarliestMsgStoretimeResponseHeader.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ChangeInvisibleTimeResponseHeader.java	33
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/UpdateConsumerOffsetRequestHeader.java	63
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryConsumerOffsetRequestHeader.java	62
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/NotifyMinBrokerIdChangeRequestHeader.java	54
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CheckRocksdbCqWriteProgressRequestHeader.java	31
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetProducerConnectionListRequestHeader.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ConsumerSendMsgBackRequestHeader.java	84
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/StatisticsMessagesRequestHeader.java	50
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/NotifyConsumerIdsChangedRequestHeader.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PopMessageRequestHeader.java	137
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/ElectMasterResponseHeader.java	53
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/AlterSyncStateSetRequestHeader.java	56
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/GetReplicaInfoResponseHeader.java	39
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/AlterSyncStateSetResponseHeader.java	23
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/register/ApplyBrokerIdResponseHeader.java	35
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/register/GetNextBrokerIdRequestHeader.java	42
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/register/RegisterBrokerToControllerResponseHeader.java	56
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/register/ApplyBrokerIdRequestHeader.java	51
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/register/RegisterBrokerToControllerRequestHeader.java	59
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/register/GetNextBrokerIdResponseHeader.java	47
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/admin/CleanControllerBrokerDataRequestHeader.java	76
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/GetReplicaInfoRequestHeader.java	31
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/ElectMasterRequestHeader.java	87
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/controller/GetMetaDataResponseHeader.java	62
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PollingInfoResponseHeader.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumerRunningInfoRequestHeader.java	50
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/InitConsumerOffsetRequestHeader.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ReplyMessageRequestHeader.java	129
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetSubscriptionGroupConfigRequestHeader.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumerConnectionListRequestHeader.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/UnRegisterBrokerRequestHeader.java	48
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/RegisterTopicRequestHeader.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/AddWritePermOfBrokerRequestHeader.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/GetRouteInfoRequestHeader.java	31
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/GetKVConfigResponseHeader.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/QueryDataVersionRequestHeader.java	48
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/AddWritePermOfBrokerResponseHeader.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/DeleteKVConfigRequestHeader.java	30
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/WipeWritePermOfBrokerResponseHeader.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/QueryDataVersionResponseHeader.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/RegisterBrokerRequestHeader.java	87
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/BrokerHeartbeatRequestHeader.java	89
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/GetKVListByNamespaceRequestHeader.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/WipeWritePermOfBrokerRequestHeader.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/PutKVConfigRequestHeader.java	38
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/GetKVConfigRequestHeader.java	30
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/DeleteTopicFromNamesrvRequestHeader.java	31
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/RegisterOrderTopicRequestHeader.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/namesrv/RegisterBrokerResponseHeader.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryTopicConsumeByWhoRequestHeader.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PopMessageResponseHeader.java	62
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetBrokerMemberGroupRequestHeader.java	32
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetTopicStatsInfoRequestHeader.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/LockBatchMqRequestHeader.java	12
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CreateAclRequestHeader.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/NotificationRequestHeader.java	88
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetBrokerConfigResponseHeader.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryMessageRequestHeader.java	56
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/UpdateConsumerOffsetResponseHeader.java	8
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumerListByGroupResponseHeader.java	8
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/DeleteUserRequestHeader.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/EndTransactionResponseHeader.java	8
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumerListByGroupRequestHeader.java	31
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/PullMessageRequestHeader.java	255
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ViewMessageRequestHeader.java	31
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/SendMessageRequestHeaderV2.java	274
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/CreateTopicListRequestHeader.java	12
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ResumeCheckHalfMessageRequestHeader.java	35
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetConsumerListByGroupResponseBody.java	12
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ListAclsRequestHeader.java	33
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetMinOffsetResponseHeader.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/GetAllTopicConfigResponseHeader.java	13
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/UpdateAclRequestHeader.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/ExchangeHAInfoRequestHeader.java	38
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/QueryConsumerOffsetResponseHeader.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/EndTransactionRequestHeader.java	103
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/AddBrokerRequestHeader.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/header/UpdateUserRequestHeader.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/admin/OffsetWrapper.java	31
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/admin/RollbackStats.java	45
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/admin/ConsumeStats.java	36
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/admin/TopicOffset.java	32
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/admin/TopicStatsTable.java	21
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java	511
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/BrokerData.java	121
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/TopicRouteData.java	175
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/MessageQueueRouteState.java	8
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/route/QueueData.java	90
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommandType.java	5
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/topic/OffsetMovedEvent.java	38
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/BrokerSyncInfo.java	37
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/Connection.java	32
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumeMessageDirectlyResult.java	45
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/TopicQueueMappingSerializeWrapper.java	21
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumeStatus.java	45
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ClusterInfo.java	53
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ResetOffsetBodyForC.java	13
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ProducerTableInfo.java	16
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ProcessQueueInfo.java	114
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/UserInfo.java	46
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumeStatsList.java	36
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/CMResult.java	9
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BatchAck.java	93
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BrokerStatsData.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BatchAckMessageRequestBody.java	19
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/SubscriptionGroupList.java	19
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/RegisterBrokerBody.java	167
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/TopicConfigSerializeWrapper.java	23
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumeQueueData.java	64
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BrokerReplicasInfo.java	148
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/TopicConfigAndMappingSerializeWrapper.java	38
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/LockBatchResponseBody.java	14
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BrokerStatsItem.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumeByWho.java	40
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/AclInfo.java	93
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/GetBrokerMemberGroupResponseBody.java	11
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/CheckClientRequestBody.java	33
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/SetMessageRequestModeRequestBody.java	35
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/MessageRequestModeSerializeWrapper.java	13
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/QueryAssignmentRequestBody.java	40
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/QueryConsumeQueueResponseBody.java	41
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/QueryCorrectionOffsetBody.java	13
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumerOffsetSerializeWrapper.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/KVTable.java	12
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/EpochEntryCache.java	58
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/HARuntimeInfo.java	130
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/QuerySubscriptionResponseBody.java	26
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/PopProcessQueueInfo.java	29
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/BrokerMemberGroup.java	68
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ProducerInfo.java	52
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/UnlockBatchRequestBody.java	45
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumerConnection.java	56
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ResetOffsetBody.java	17
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/QueryAssignmentResponseBody.java	14
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ElectMasterResponseBody.java	56
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ConsumerRunningInfo.java	273
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/CreateTopicListRequestBody.java	19
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/GetConsumerStatusBody.java	23
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/SubscriptionGroupWrapper.java	24
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/GroupList.java	12
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/LockBatchRequestBody.java	45
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/QueueTimeSpan.java	50
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/SyncStateSet.java	31
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/ProducerConnection.java	12
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/TopicList.java	20
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/RoleChangeNotifyEntry.java	50
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/body/QueryConsumeTimeSpanBody.java	13
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/FastCodesHeader.java	22
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingSerializable.java	55
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/namesrv/RegisterBrokerResult.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/ForbiddenType.java	8
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/SerializeType.java	20
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/BitSetSerializerDeserializer.java	30
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RequestCode.java	161
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/DataVersion.java	88
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/MQProtosHelper.java	25
remoting/src/main/java/org/apache/rocketmq/remoting/RemotingClient.java	53
remoting/src/main/java/org/apache/rocketmq/remoting/InvokeCallback.java	10
remoting/src/main/java/org/apache/rocketmq/remoting/CommandCustomHeader.java	5
proxy/src/main/java/org/apache/rocketmq/proxy/metrics/ProxyMetricsManager.java	215
proxy/src/main/java/org/apache/rocketmq/proxy/metrics/ProxyMetricsConstant.java	6
proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java	194
proxy/src/main/java/org/apache/rocketmq/proxy/common/Address.java	62
proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/GrpcUtils.java	23
proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ProxyUtils.java	5
proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/FilterUtils.java	14
proxy/src/main/java/org/apache/rocketmq/proxy/common/ReceiptHandleGroupKey.java	43
proxy/src/main/java/org/apache/rocketmq/proxy/common/MessageReceiptHandle.java	115
proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyException.java	15
proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java	13
proxy/src/main/java/org/apache/rocketmq/proxy/common/RenewEvent.java	38
proxy/src/main/java/org/apache/rocketmq/proxy/common/AbstractCacheLoader.java	31
proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyContext.java	97
proxy/src/main/java/org/apache/rocketmq/proxy/common/ReceiptHandleGroup.java	280
proxy/src/main/java/org/apache/rocketmq/proxy/common/RenewStrategyPolicy.java	42
proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyExceptionCode.java	9
proxy/src/main/java/org/apache/rocketmq/proxy/common/channel/ChannelHelper.java	22
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcValidator.java	94
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseWriter.java	55
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManager.java	204
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java	194
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseBuilder.java	89
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcProxyException.java	42
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/transaction/EndTransactionActivity.java	57
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessingActivity.java	46
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageResponseStreamWriter.java	131
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity.java	162
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/PopMessageResultFilterImpl.java	23
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/AckMessageActivity.java	174
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ChangeInvisibleDurationActivity.java	59
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java	438
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java	268
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/ContextStreamObserver.java	7
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java	424
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/DefaultGrpcMessingActivity.java	128
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/AbstractMessingActivity.java	36
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/ForwardMessageToDLQActivity.java	49
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java	330
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/RecallMessageActivity.java	39
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java	227
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java	95
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/pipeline/ContextInitPipeline.java	29
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/pipeline/AuthorizationPipeline.java	42
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/pipeline/AuthenticationPipeline.java	53
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/pipeline/RequestPipeline.java	13
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java	30
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/constant/AttributeKeys.java	21
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java	77
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/ProxyAndTlsProtocolNegotiator.java	233
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/HeaderInterceptor.java	66
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/ContextInterceptor.java	19
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/GlobalExceptionInterceptor.java	96
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/RequestMapping.java	38
proxy/src/main/java/org/apache/rocketmq/proxy/config/Configuration.java	68
proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigurationManager.java	38
proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java	1136
proxy/src/main/java/org/apache/rocketmq/proxy/config/MetricCollectorMode.java	21
proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigFile.java	4
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/LocalTransactionService.java	26
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionDataManager.java	130
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionData.java	85
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/ClusterTransactionService.java	248
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionService.java	17
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/EndTransactionRequestData.java	22
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/AbstractTransactionService.java	65
proxy/src/main/java/org/apache/rocketmq/proxy/service/LocalServiceManager.java	111
proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/LocalMetadataService.java	36
proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/ClusterMetadataService.java	237
proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/MetadataService.java	14
proxy/src/main/java/org/apache/rocketmq/proxy/service/receipt/ReceiptHandleManager.java	8
proxy/src/main/java/org/apache/rocketmq/proxy/service/receipt/DefaultReceiptHandleManager.java	246
proxy/src/main/java/org/apache/rocketmq/proxy/service/admin/DefaultAdminService.java	112
proxy/src/main/java/org/apache/rocketmq/proxy/service/admin/AdminService.java	10
proxy/src/main/java/org/apache/rocketmq/proxy/service/client/ProxyClientRemotingProcessor.java	56
proxy/src/main/java/org/apache/rocketmq/proxy/service/client/ClusterConsumerManager.java	45
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteService.java	187
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ProxyTopicRouteData.java	116
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ClusterTopicRouteService.java	32
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteHelper.java	26
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/LocalTopicRouteService.java	65
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueSelector.java	253
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteWrapper.java	47
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueView.java	41
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/AddressableMessageQueue.java	53
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatType.java	5
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java	145
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerData.java	130
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncer.java	203
proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManager.java	20
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/LocalProxyRelayService.java	66
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/RelayData.java	23
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyChannel.java	155
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ClusterProxyRelayService.java	26
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyRelayResult.java	29
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/AbstractProxyRelayService.java	42
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyRelayService.java	29
proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManagerFactory.java	22
proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java	166
proxy/src/main/java/org/apache/rocketmq/proxy/service/message/ClusterMessageService.java	244
proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java	17
proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalMessageService.java	467
proxy/src/main/java/org/apache/rocketmq/proxy/service/message/MessageService.java	135
proxy/src/main/java/org/apache/rocketmq/proxy/service/message/ReceiptHandleMessage.java	16
proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannel.java	137
proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannelHandlerContext.java	184
proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationContextInterface.java	6
proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationContext.java	20
proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationChannel.java	55
proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/ChannelManager.java	65
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProtocolServer.java	320
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/RemotingProxyOutClient.java	7
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/ContextInitPipeline.java	34
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/AuthorizationPipeline.java	42
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/AuthenticationPipeline.java	40
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/RequestPipeline.java	13
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/GetTopicRouteActivity.java	49
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ConsumerManagerActivity.java	142
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ClientManagerActivity.java	165
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/PullMessageActivity.java	43
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/SendMessageActivity.java	71
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AbstractRemotingActivity.java	139
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/RecallMessageActivity.java	31
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AckMessageActivity.java	18
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/PopMessageActivity.java	21
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/TransactionActivity.java	45
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ChangeInvisibleTimeActivity.java	18
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/common/RemotingConverter.java	28
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolTlsHelper.java	83
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolRemotingServer.java	58
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/HAProxyMessageForwarder.java	133
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/Http2ProxyFrontendHandler.java	51
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/Http2ProxyBackendHandler.java	43
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/http2proxy/Http2ProtocolProxyHandler.java	96
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/ProtocolNegotiationHandler.java	35
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/remoting/RemotingProtocolHandler.java	38
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/ProtocolHandler.java	7
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/ClientHousekeepingService.java	28
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelManager.java	99
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannel.java	222
proxy/src/main/java/org/apache/rocketmq/proxy/processor/ClientProcessor.java	87
proxy/src/main/java/org/apache/rocketmq/proxy/processor/PopMessageResultFilter.java	13
proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator/TopicMessageTypeValidator.java	5
proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator/DefaultTopicMessageTypeValidator.java	13
proxy/src/main/java/org/apache/rocketmq/proxy/processor/TransactionStatus.java	6
proxy/src/main/java/org/apache/rocketmq/proxy/processor/QueueSelector.java	7
proxy/src/main/java/org/apache/rocketmq/proxy/processor/AbstractProcessor.java	21
proxy/src/main/java/org/apache/rocketmq/proxy/processor/ConsumerProcessor.java	499
proxy/src/main/java/org/apache/rocketmq/proxy/processor/ReceiptHandleProcessor.java	44
proxy/src/main/java/org/apache/rocketmq/proxy/processor/BatchAckResult.java	28
proxy/src/main/java/org/apache/rocketmq/proxy/processor/TransactionProcessor.java	55
proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java	307
proxy/src/main/java/org/apache/rocketmq/proxy/processor/MessagingProcessor.java	284
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/RemoteChannel.java	80
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/RemoteChannelSerializer.java	44
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/ChannelProtocolType.java	14
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/ChannelExtendAttributeGetter.java	4
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/RemoteChannelConverter.java	4
proxy/src/main/java/org/apache/rocketmq/proxy/processor/RequestBrokerProcessor.java	17
proxy/src/main/java/org/apache/rocketmq/proxy/processor/ProducerProcessor.java	224
proxy/src/main/java/org/apache/rocketmq/proxy/ProxyMode.java	33
proxy/src/main/java/org/apache/rocketmq/proxy/auth/ProxyAuthenticationMetadataProvider.java	42
proxy/src/main/java/org/apache/rocketmq/proxy/auth/ProxyAuthorizationMetadataProvider.java	43
proxy/src/main/java/org/apache/rocketmq/proxy/CommandLineArgument.java	31
proxy/src/main/resources/rmq.proxy.logback.xml	403
dev/merge_rocketmq_pr.py	298
example/src/main/java/org/apache/rocketmq/example/filter/TagFilterProducer.java	20
example/src/main/java/org/apache/rocketmq/example/filter/SqlFilterProducer.java	22
example/src/main/java/org/apache/rocketmq/example/filter/SqlFilterConsumer.java	26
example/src/main/java/org/apache/rocketmq/example/filter/TagFilterConsumer.java	24
example/src/main/java/org/apache/rocketmq/example/quickstart/Producer.java	31
example/src/main/java/org/apache/rocketmq/example/quickstart/Consumer.java	22
example/src/main/java/org/apache/rocketmq/example/operation/Producer.java	78
example/src/main/java/org/apache/rocketmq/example/operation/Consumer.java	79
example/src/main/java/org/apache/rocketmq/example/openmessaging/SimplePushConsumer.java	28
example/src/main/java/org/apache/rocketmq/example/openmessaging/SimpleProducer.java	50
example/src/main/java/org/apache/rocketmq/example/openmessaging/SimplePullConsumer.java	48
example/src/main/java/org/apache/rocketmq/example/transaction/TransactionListenerImpl.java	35
example/src/main/java/org/apache/rocketmq/example/transaction/TransactionProducer.java	48
example/src/main/java/org/apache/rocketmq/example/batch/SplitBatchProducer.java	74
example/src/main/java/org/apache/rocketmq/example/batch/SimpleBatchProducer.java	23
example/src/main/java/org/apache/rocketmq/example/tracemessage/TraceProducer.java	33
example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingProducer.java	47
example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingPushConsumer.java	42
example/src/main/java/org/apache/rocketmq/example/tracemessage/OpenTracingTransactionProducer.java	65
example/src/main/java/org/apache/rocketmq/example/tracemessage/TracePushConsumer.java	23
example/src/main/java/org/apache/rocketmq/example/broadcast/PushConsumer.java	25
example/src/main/java/org/apache/rocketmq/example/rpc/RequestProducer.java	27
example/src/main/java/org/apache/rocketmq/example/rpc/ResponseConsumer.java	52
example/src/main/java/org/apache/rocketmq/example/rpc/AsyncRequestProducer.java	37
example/src/main/java/org/apache/rocketmq/example/ordermessage/Producer.java	37
example/src/main/java/org/apache/rocketmq/example/ordermessage/Consumer.java	35
example/src/main/java/org/apache/rocketmq/example/namespace/PullConsumerWithNamespace.java	66
example/src/main/java/org/apache/rocketmq/example/namespace/ProducerWithNamespace.java	29
example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java	21
example/src/main/java/org/apache/rocketmq/example/benchmark/Producer.java	369
example/src/main/java/org/apache/rocketmq/example/benchmark/BatchProducer.java	360
example/src/main/java/org/apache/rocketmq/example/benchmark/AclClient.java	14
example/src/main/java/org/apache/rocketmq/example/benchmark/TransactionProducer.java	399
example/src/main/java/org/apache/rocketmq/example/benchmark/timer/TimerProducer.java	249
example/src/main/java/org/apache/rocketmq/example/benchmark/timer/TimerConsumer.java	141
example/src/main/java/org/apache/rocketmq/example/benchmark/Consumer.java	235
example/src/main/java/org/apache/rocketmq/example/simple/Producer.java	26
example/src/main/java/org/apache/rocketmq/example/simple/CachedQueue.java	9
example/src/main/java/org/apache/rocketmq/example/simple/LitePullConsumerAssignWithSubExpression.java	38
example/src/main/java/org/apache/rocketmq/example/simple/PushConsumer.java	29
example/src/main/java/org/apache/rocketmq/example/simple/LitePullConsumerSubscribe.java	22
example/src/main/java/org/apache/rocketmq/example/simple/OnewayProducer.java	21
example/src/main/java/org/apache/rocketmq/example/simple/AclClient.java	128
example/src/main/java/org/apache/rocketmq/example/simple/LitePullConsumerAssign.java	32
example/src/main/java/org/apache/rocketmq/example/simple/RandomAsyncCommit.java	32
example/src/main/java/org/apache/rocketmq/example/simple/PullConsumer.java	102
example/src/main/java/org/apache/rocketmq/example/simple/PopConsumer.java	45
example/src/main/java/org/apache/rocketmq/example/simple/AsyncProducer.java	47
example/src/main/java/org/apache/rocketmq/example/simple/PullScheduleService.java	44
example/src/main/java/org/apache/rocketmq/example/lmq/LMQProducer.java	34
example/src/main/java/org/apache/rocketmq/example/lmq/LMQPushConsumer.java	56
example/src/main/java/org/apache/rocketmq/example/lmq/LMQPushPopConsumer.java	69
example/src/main/java/org/apache/rocketmq/example/lmq/LMQPullConsumer.java	45
example/src/main/java/org/apache/rocketmq/example/schedule/ScheduledMessageConsumer.java	22
example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageConsumer.java	22
example/src/main/java/org/apache/rocketmq/example/schedule/TimerMessageProducer.java	22
example/src/main/java/org/apache/rocketmq/example/schedule/ScheduledMessageProducer.java	22
controller/src/main/java/org/apache/rocketmq/controller/Controller.java	33
controller/src/main/java/org/apache/rocketmq/controller/metrics/ControllerMetricsConstant.java	83
controller/src/main/java/org/apache/rocketmq/controller/metrics/ControllerMetricsManager.java	311
controller/src/main/java/org/apache/rocketmq/controller/ControllerStartup.java	120
controller/src/main/java/org/apache/rocketmq/controller/ControllerManager.java	306
controller/src/main/java/org/apache/rocketmq/controller/BrokerHeartbeatManager.java	29
controller/src/main/java/org/apache/rocketmq/controller/elect/ElectPolicy.java	6
controller/src/main/java/org/apache/rocketmq/controller/elect/impl/DefaultElectPolicy.java	74
controller/src/main/java/org/apache/rocketmq/controller/processor/ControllerRequestProcessor.java	294
controller/src/main/java/org/apache/rocketmq/controller/helper/BrokerLifecycleListener.java	4
controller/src/main/java/org/apache/rocketmq/controller/helper/BrokerLiveInfoGetter.java	5
controller/src/main/java/org/apache/rocketmq/controller/helper/BrokerValidPredicate.java	4
controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerControllerStateMachine.java	57
controller/src/main/java/org/apache/rocketmq/controller/impl/closure/ControllerClosure.java	58
controller/src/main/java/org/apache/rocketmq/controller/impl/JRaftControllerStateMachine.java	288
controller/src/main/java/org/apache/rocketmq/controller/impl/manager/ReplicasInfoManager.java	568
controller/src/main/java/org/apache/rocketmq/controller/impl/manager/BrokerReplicaInfo.java	79
controller/src/main/java/org/apache/rocketmq/controller/impl/manager/RaftReplicasInfoManager.java	201
controller/src/main/java/org/apache/rocketmq/controller/impl/manager/SyncStateInfo.java	56
controller/src/main/java/org/apache/rocketmq/controller/impl/JRaftController.java	229
controller/src/main/java/org/apache/rocketmq/controller/impl/heartbeat/BrokerLiveInfo.java	113
controller/src/main/java/org/apache/rocketmq/controller/impl/heartbeat/RaftBrokerHeartBeatManager.java	230
controller/src/main/java/org/apache/rocketmq/controller/impl/heartbeat/BrokerIdentityInfo.java	53
controller/src/main/java/org/apache/rocketmq/controller/impl/heartbeat/DefaultBrokerHeartbeatManager.java	159
controller/src/main/java/org/apache/rocketmq/controller/impl/event/UpdateBrokerAddressEvent.java	38
controller/src/main/java/org/apache/rocketmq/controller/impl/event/ApplyBrokerIdEvent.java	45
controller/src/main/java/org/apache/rocketmq/controller/impl/event/ListEventSerializer.java	100
controller/src/main/java/org/apache/rocketmq/controller/impl/event/EventType.java	38
controller/src/main/java/org/apache/rocketmq/controller/impl/event/EventSerializer.java	55
controller/src/main/java/org/apache/rocketmq/controller/impl/event/ElectMasterEvent.java	38
controller/src/main/java/org/apache/rocketmq/controller/impl/event/CleanBrokerDataEvent.java	33
controller/src/main/java/org/apache/rocketmq/controller/impl/event/AlterSyncStateSetEvent.java	28
controller/src/main/java/org/apache/rocketmq/controller/impl/event/ControllerResult.java	57
controller/src/main/java/org/apache/rocketmq/controller/impl/event/EventMessage.java	4
controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java	479
controller/src/main/java/org/apache/rocketmq/controller/impl/task/CheckNotActiveBrokerResponse.java	14
controller/src/main/java/org/apache/rocketmq/controller/impl/task/GetBrokerLiveInfoRequest.java	36
controller/src/main/java/org/apache/rocketmq/controller/impl/task/CheckNotActiveBrokerRequest.java	20
controller/src/main/java/org/apache/rocketmq/controller/impl/task/RaftBrokerHeartBeatEventRequest.java	67
controller/src/main/java/org/apache/rocketmq/controller/impl/task/BrokerCloseChannelResponse.java	14
controller/src/main/java/org/apache/rocketmq/controller/impl/task/RaftBrokerHeartBeatEventResponse.java	14
controller/src/main/java/org/apache/rocketmq/controller/impl/task/GetSyncStateDataRequest.java	20
controller/src/main/java/org/apache/rocketmq/controller/impl/task/GetBrokerLiveInfoResponse.java	14
controller/src/main/java/org/apache/rocketmq/controller/impl/task/BrokerCloseChannelRequest.java	42
controller/src/main/java/org/apache/rocketmq/controller/BrokerHousekeepingService.java	31
controller/src/main/resources/rmq.controller.logback.xml	152
container/src/main/java/org/apache/rocketmq/container/BrokerContainer.java	384
container/src/main/java/org/apache/rocketmq/container/BrokerContainerConfig.java	70
container/src/main/java/org/apache/rocketmq/container/ContainerClientHouseKeepingService.java	72
container/src/main/java/org/apache/rocketmq/container/BrokerBootHook.java	8
container/src/main/java/org/apache/rocketmq/container/IBrokerContainer.java	28
container/src/main/java/org/apache/rocketmq/container/BrokerContainerStartup.java	343
container/src/main/java/org/apache/rocketmq/container/InnerSalveBrokerController.java	21
container/src/main/java/org/apache/rocketmq/container/InnerBrokerController.java	143
container/src/main/java/org/apache/rocketmq/container/logback/BrokerLogbackConfigurator.java	18
container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java	250
namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java	157
namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigSerializeWrapper.java	12
namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java	216
namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BatchUnregistrationService.java	44
namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java	1071
namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java	28
namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java	188
namesrv/src/main/java/org/apache/rocketmq/namesrv/route/ZoneRouteRPCHook.java	71
namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java	566
namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClusterTestRequestProcessor.java	63
namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java	75
namesrv/src/main/resources/rmq.namesrv.logback.xml	90
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metrics/TieredStoreMetricsManager.java	281
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metrics/TieredStoreMetricsConstant.java	30
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/MemoryFileSegment.java	79
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/FileSegmentFactory.java	48
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/FileSegmentProvider.java	13
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/PosixFileSegment.java	185
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/provider/FileSegment.java	271
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/FileSegmentType.java	20
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/AppendResult.java	8
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/GroupCommitContext.java	40
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/SelectBufferResult.java	32
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/common/GetMessageResultExt.java	46
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/TieredMessageStore.java	410
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatAppendFile.java	227
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatCommitLogFile.java	53
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatConsumeQueueFile.java	8
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatFileInterface.java	40
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatMessageFile.java	354
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatFileFactory.java	39
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/file/FlatFileStore.java	139
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/DefaultMetadataStore.java	290
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/MetadataStore.java	26
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/entity/FileSegmentMetadata.java	114
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/entity/QueueMetadata.java	46
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/metadata/entity/TopicMetadata.java	53
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/util/MessageStoreUtil.java	74
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/util/MessageFormatUtil.java	119
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/exception/TieredStoreException.java	36
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/exception/TieredStoreErrorCode.java	11
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/stream/FileSegmentInputStream.java	134
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/stream/CommitLogInputStream.java	151
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/stream/FileSegmentInputStreamFactory.java	25
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/MessageStoreExecutor.java	63
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreDispatcherImpl.java	324
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreFetcherImpl.java	378
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreFilter.java	5
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreTopicFilter.java	30
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreDispatcher.java	9
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/core/MessageStoreFetcher.java	15
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/MessageStoreConfig.java	290
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreFile.java	411
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexFile.java	11
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexStoreService.java	367
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexItem.java	81
tieredstore/src/main/java/org/apache/rocketmq/tieredstore/index/IndexService.java	15
auth/src/main/java/org/apache/rocketmq/auth/config/AuthConfig.java	193
auth/src/main/java/org/apache/rocketmq/auth/authorization/AuthorizationEvaluator.java	23
auth/src/main/java/org/apache/rocketmq/auth/authorization/chain/AclAuthorizationHandler.java	127
auth/src/main/java/org/apache/rocketmq/auth/authorization/chain/UserAuthorizationHandler.java	49
auth/src/main/java/org/apache/rocketmq/auth/authorization/provider/LocalAuthorizationMetadataProvider.java	167
auth/src/main/java/org/apache/rocketmq/auth/authorization/provider/AuthorizationMetadataProvider.java	16
auth/src/main/java/org/apache/rocketmq/auth/authorization/provider/DefaultAuthorizationProvider.java	76
auth/src/main/java/org/apache/rocketmq/auth/authorization/provider/AuthorizationProvider.java	16
auth/src/main/java/org/apache/rocketmq/auth/authorization/manager/AuthorizationMetadataManager.java	16
auth/src/main/java/org/apache/rocketmq/auth/authorization/manager/AuthorizationMetadataManagerImpl.java	238
auth/src/main/java/org/apache/rocketmq/auth/authorization/model/Environment.java	44
auth/src/main/java/org/apache/rocketmq/auth/authorization/model/RequestContext.java	33
auth/src/main/java/org/apache/rocketmq/auth/authorization/model/Policy.java	76
auth/src/main/java/org/apache/rocketmq/auth/authorization/model/PolicyEntry.java	83
auth/src/main/java/org/apache/rocketmq/auth/authorization/model/Resource.java	131
auth/src/main/java/org/apache/rocketmq/auth/authorization/model/Acl.java	79
auth/src/main/java/org/apache/rocketmq/auth/authorization/context/DefaultAuthorizationContext.java	58
auth/src/main/java/org/apache/rocketmq/auth/authorization/context/AuthorizationContext.java	54
auth/src/main/java/org/apache/rocketmq/auth/authorization/exception/AuthorizationException.java	13
auth/src/main/java/org/apache/rocketmq/auth/authorization/strategy/AuthorizationStrategy.java	5
auth/src/main/java/org/apache/rocketmq/auth/authorization/strategy/StatelessAuthorizationStrategy.java	13
auth/src/main/java/org/apache/rocketmq/auth/authorization/strategy/AbstractAuthorizationStrategy.java	54
auth/src/main/java/org/apache/rocketmq/auth/authorization/strategy/StatefulAuthorizationStrategy.java	51
auth/src/main/java/org/apache/rocketmq/auth/authorization/enums/Decision.java	28
auth/src/main/java/org/apache/rocketmq/auth/authorization/enums/PolicyType.java	28
auth/src/main/java/org/apache/rocketmq/auth/authorization/builder/AuthorizationContextBuilder.java	11
auth/src/main/java/org/apache/rocketmq/auth/authorization/builder/DefaultAuthorizationContextBuilder.java	465
auth/src/main/java/org/apache/rocketmq/auth/authorization/factory/AuthorizationFactory.java	127
auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessResource.java	116
auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessData.java	68
auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainPermissionManager.java	110
auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AclConfig.java	25
auth/src/main/java/org/apache/rocketmq/auth/migration/v1/AccessResource.java	3
auth/src/main/java/org/apache/rocketmq/auth/migration/v1/PlainAccessConfig.java	86
auth/src/main/java/org/apache/rocketmq/auth/migration/AuthMigrator.java	191
auth/src/main/java/org/apache/rocketmq/auth/authentication/chain/DefaultAuthenticationHandler.java	48
auth/src/main/java/org/apache/rocketmq/auth/authentication/provider/DefaultAuthenticationProvider.java	56
auth/src/main/java/org/apache/rocketmq/auth/authentication/provider/AuthenticationProvider.java	14
auth/src/main/java/org/apache/rocketmq/auth/authentication/provider/LocalAuthenticationMetadataProvider.java	135
auth/src/main/java/org/apache/rocketmq/auth/authentication/provider/AuthenticationMetadataProvider.java	15
auth/src/main/java/org/apache/rocketmq/auth/authentication/manager/AuthenticationMetadataManagerImpl.java	189
auth/src/main/java/org/apache/rocketmq/auth/authentication/manager/AuthenticationMetadataManager.java	15
auth/src/main/java/org/apache/rocketmq/auth/authentication/model/Subject.java	25
auth/src/main/java/org/apache/rocketmq/auth/authentication/model/User.java	61
auth/src/main/java/org/apache/rocketmq/auth/authentication/context/DefaultAuthenticationContext.java	24
auth/src/main/java/org/apache/rocketmq/auth/authentication/context/AuthenticationContext.java	54
auth/src/main/java/org/apache/rocketmq/auth/authentication/exception/AuthenticationException.java	13
auth/src/main/java/org/apache/rocketmq/auth/authentication/strategy/AbstractAuthenticationStrategy.java	54
auth/src/main/java/org/apache/rocketmq/auth/authentication/strategy/StatefulAuthenticationStrategy.java	50
auth/src/main/java/org/apache/rocketmq/auth/authentication/strategy/StatelessAuthenticationStrategy.java	13
auth/src/main/java/org/apache/rocketmq/auth/authentication/strategy/AuthenticationStrategy.java	5
auth/src/main/java/org/apache/rocketmq/auth/authentication/enums/UserType.java	28
auth/src/main/java/org/apache/rocketmq/auth/authentication/enums/UserStatus.java	28
auth/src/main/java/org/apache/rocketmq/auth/authentication/enums/SubjectType.java	27
auth/src/main/java/org/apache/rocketmq/auth/authentication/AuthenticationEvaluator.java	21
auth/src/main/java/org/apache/rocketmq/auth/authentication/builder/DefaultAuthenticationContextBuilder.java	105
auth/src/main/java/org/apache/rocketmq/auth/authentication/builder/AuthenticationContextBuilder.java	9
auth/src/main/java/org/apache/rocketmq/auth/authentication/factory/AuthenticationFactory.java	124