Path	Lines of Code
client/src/main/java/org/apache/rocketmq/acl/common/AclClientRPCHook.java	33
client/src/main/java/org/apache/rocketmq/acl/common/AclConstants.java	10
client/src/main/java/org/apache/rocketmq/acl/common/AclException.java	39
client/src/main/java/org/apache/rocketmq/acl/common/AclSigner.java	63
client/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java	229
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/SigningAlgorithm.java	6
client/src/main/java/org/apache/rocketmq/client/AccessChannel.java	5
client/src/main/java/org/apache/rocketmq/client/ClientConfig.java	414
client/src/main/java/org/apache/rocketmq/client/MQAdmin.java	21
client/src/main/java/org/apache/rocketmq/client/MQHelper.java	53
client/src/main/java/org/apache/rocketmq/client/MqClientAdmin.java	73
client/src/main/java/org/apache/rocketmq/client/QueryResult.java	22
client/src/main/java/org/apache/rocketmq/client/Validators.java	92
client/src/main/java/org/apache/rocketmq/client/admin/MQAdminExtInner.java	3
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/common/ThreadLocalIndex.java	25
client/src/main/java/org/apache/rocketmq/client/consumer/AckCallback.java	5
client/src/main/java/org/apache/rocketmq/client/consumer/AckResult.java	28
client/src/main/java/org/apache/rocketmq/client/consumer/AckStatus.java	5
client/src/main/java/org/apache/rocketmq/client/consumer/AllocateMessageQueueStrategy.java	12
client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java	378
client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java	337
client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java	486
client/src/main/java/org/apache/rocketmq/client/consumer/LitePullConsumer.java	43
client/src/main/java/org/apache/rocketmq/client/consumer/MQConsumer.java	16
client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumer.java	57
client/src/main/java/org/apache/rocketmq/client/consumer/MQPullConsumerScheduleService.java	162
client/src/main/java/org/apache/rocketmq/client/consumer/MQPushConsumer.java	22
client/src/main/java/org/apache/rocketmq/client/consumer/MessageQueueListener.java	6
client/src/main/java/org/apache/rocketmq/client/consumer/MessageSelector.java	22
client/src/main/java/org/apache/rocketmq/client/consumer/NotifyResult.java	23
client/src/main/java/org/apache/rocketmq/client/consumer/PopCallback.java	5
client/src/main/java/org/apache/rocketmq/client/consumer/PopResult.java	49
client/src/main/java/org/apache/rocketmq/client/consumer/PopStatus.java	7
client/src/main/java/org/apache/rocketmq/client/consumer/PullCallback.java	5
client/src/main/java/org/apache/rocketmq/client/consumer/PullResult.java	43
client/src/main/java/org/apache/rocketmq/client/consumer/PullStatus.java	7
client/src/main/java/org/apache/rocketmq/client/consumer/PullTaskCallback.java	5
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/listener/ConsumeConcurrentlyContext.java	25
client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeConcurrentlyStatus.java	5
client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyContext.java	25
client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeOrderlyStatus.java	9
client/src/main/java/org/apache/rocketmq/client/consumer/listener/ConsumeReturnType.java	8
client/src/main/java/org/apache/rocketmq/client/consumer/listener/MessageListener.java	3
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/rebalance/AbstractAllocateMessageQueueStrategy.java	31
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMachineRoomNearby.java	77
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java	29
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java	25
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java	21
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByMachineRoom.java	48
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueConsistentHash.java	65
client/src/main/java/org/apache/rocketmq/client/consumer/store/ControllableOffset.java	37
client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java	235
client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetSerializeWrapper.java	16
client/src/main/java/org/apache/rocketmq/client/consumer/store/OffsetStore.java	19
client/src/main/java/org/apache/rocketmq/client/consumer/store/ReadOffsetType.java	6
client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java	206
client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java	37
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/RequestTimeoutException.java	31
client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenContext.java	84
client/src/main/java/org/apache/rocketmq/client/hook/CheckForbiddenHook.java	6
client/src/main/java/org/apache/rocketmq/client/hook/ConsumeMessageContext.java	71
client/src/main/java/org/apache/rocketmq/client/hook/ConsumeMessageHook.java	6
client/src/main/java/org/apache/rocketmq/client/hook/EndTransactionContext.java	54
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/hook/FilterMessageHook.java	5
client/src/main/java/org/apache/rocketmq/client/hook/SendMessageContext.java	101
client/src/main/java/org/apache/rocketmq/client/hook/SendMessageHook.java	6
client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java	245
client/src/main/java/org/apache/rocketmq/client/impl/CommunicationMode.java	6
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/MQClientAPIImpl.java	3092
client/src/main/java/org/apache/rocketmq/client/impl/MQClientManager.java	65
client/src/main/java/org/apache/rocketmq/client/impl/admin/MqClientAdminImpl.java	395
client/src/main/java/org/apache/rocketmq/client/impl/consumer/AssignedMessageQueue.java	193
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java	386
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java	485
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java	396
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/DefaultLitePullConsumerImpl.java	1071
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java	724
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java	1325
client/src/main/java/org/apache/rocketmq/client/impl/consumer/MQConsumerInner.java	22
client/src/main/java/org/apache/rocketmq/client/impl/consumer/MessageQueueLock.java	30
client/src/main/java/org/apache/rocketmq/client/impl/consumer/MessageRequest.java	5
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java	47
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopRequest.java	93
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java	388
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java	319
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/PullResultExt.java	33
client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java	651
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/RebalancePushImpl.java	235
client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceService.java	40
client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java	1183
client/src/main/java/org/apache/rocketmq/client/impl/mqclient/DoNothingClientRemotingProcessor.java	14
client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIExt.java	615
client/src/main/java/org/apache/rocketmq/client/impl/mqclient/MQClientAPIFactory.java	115
client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java	1578
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/latency/LatencyFaultTolerance.java	16
client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java	254
client/src/main/java/org/apache/rocketmq/client/latency/MQFaultStrategy.java	131
client/src/main/java/org/apache/rocketmq/client/latency/Resolver.java	4
client/src/main/java/org/apache/rocketmq/client/latency/ServiceDetector.java	4
client/src/main/java/org/apache/rocketmq/client/lock/ReadWriteCASLock.java	35
client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java	741
client/src/main/java/org/apache/rocketmq/client/producer/LocalTransactionState.java	6
client/src/main/java/org/apache/rocketmq/client/producer/MQProducer.java	87
client/src/main/java/org/apache/rocketmq/client/producer/MessageQueueSelector.java	7
client/src/main/java/org/apache/rocketmq/client/producer/ProduceAccumulator.java	454
client/src/main/java/org/apache/rocketmq/client/producer/RequestCallback.java	6
client/src/main/java/org/apache/rocketmq/client/producer/RequestFutureHolder.java	77
client/src/main/java/org/apache/rocketmq/client/producer/RequestResponseFuture.java	86
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/TransactionCheckListener.java	6
client/src/main/java/org/apache/rocketmq/client/producer/TransactionListener.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/SelectMessageQueueByHash.java	15
client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByMachineRoom.java	19
client/src/main/java/org/apache/rocketmq/client/producer/selector/SelectMessageQueueByRandom.java	14
client/src/main/java/org/apache/rocketmq/client/rpchook/NamespaceRpcHook.java	23
client/src/main/java/org/apache/rocketmq/client/stat/ConsumerStatsManager.java	108
client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java	351
client/src/main/java/org/apache/rocketmq/client/trace/TraceBean.java	113
client/src/main/java/org/apache/rocketmq/client/trace/TraceConstants.java	25
client/src/main/java/org/apache/rocketmq/client/trace/TraceContext.java	100
client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java	211
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/TraceTransferBean.java	19
client/src/main/java/org/apache/rocketmq/client/trace/TraceType.java	8
client/src/main/java/org/apache/rocketmq/client/trace/TraceView.java	131
client/src/main/java/org/apache/rocketmq/client/trace/hook/ConsumeMessageOpenTracingHookImpl.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/DefaultRecallMessageTraceHook.java	57
client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionOpenTracingHookImpl.java	48
client/src/main/java/org/apache/rocketmq/client/trace/hook/EndTransactionTraceHookImpl.java	54
client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageOpenTracingHookImpl.java	63
client/src/main/java/org/apache/rocketmq/client/trace/hook/SendMessageTraceHookImpl.java	69
client/src/main/java/org/apache/rocketmq/client/utils/MessageUtil.java	34
client/src/main/resources/rmq.client.logback.xml	38