Path	Lines of Code
cpp/bazel/rocketmq_deps.bzl	164
cpp/cmake/FindProtobufWithTargets.cmake	174
cpp/cmake/FindgRPC.cmake	315
cpp/cmake/OpenCensusHelpers.cmake	85
cpp/include/rocketmq/AdminServer.h	17
cpp/include/rocketmq/BackoffPolicy.h	42
cpp/include/rocketmq/Configuration.h	48
cpp/include/rocketmq/ConfigurationDefaults.h	9
cpp/include/rocketmq/ConsumeResult.h	9
cpp/include/rocketmq/Credentials.h	51
cpp/include/rocketmq/CredentialsProvider.h	58
cpp/include/rocketmq/ErrorCategory.h	17
cpp/include/rocketmq/ErrorCode.h	61
cpp/include/rocketmq/Executor.h	6
cpp/include/rocketmq/ExpressionType.h	10
cpp/include/rocketmq/FifoProducer.h	35
cpp/include/rocketmq/FilterExpression.h	19
cpp/include/rocketmq/Logger.h	32
cpp/include/rocketmq/MQClientException.h	66
cpp/include/rocketmq/Message.h	113
cpp/include/rocketmq/MessageListener.h	7
cpp/include/rocketmq/Producer.h	41
cpp/include/rocketmq/PushConsumer.h	58
cpp/include/rocketmq/RecallReceipt.h	8
cpp/include/rocketmq/RocketMQ.h	6
cpp/include/rocketmq/SendCallback.h	8
cpp/include/rocketmq/SendReceipt.h	13
cpp/include/rocketmq/SimpleConsumer.h	67
cpp/include/rocketmq/State.h	13
cpp/include/rocketmq/Tracing.h	11
cpp/include/rocketmq/Transaction.h	16
cpp/include/rocketmq/TransactionChecker.h	7
cpp/include/rocketmq/TransactionState.h	9
cpp/proto/apache/rocketmq/v2/admin.proto	37
cpp/proto/apache/rocketmq/v2/definition.proto	462
cpp/proto/apache/rocketmq/v2/service.proto	362
cpp/source/admin/AdminClient.cpp	77
cpp/source/admin/AdminFacade.cpp	6
cpp/source/admin/AdminServerImpl.cpp	86
cpp/source/admin/AdminServiceImpl.cpp	42
cpp/source/admin/include/AdminClient.h	20
cpp/source/admin/include/AdminServerImpl.h	36
cpp/source/admin/include/AdminServiceImpl.h	16
cpp/source/admin/include/ServerCall.h	52
cpp/source/base/Configuration.cpp	29
cpp/source/base/ConfigurationDefaults.cpp	5
cpp/source/base/CredentialsProvider.cpp	88
cpp/source/base/ErrorCategory.cpp	138
cpp/source/base/ErrorCode.cpp	7
cpp/source/base/FilterExpression.cpp	19
cpp/source/base/Message.cpp	61
cpp/source/base/MessageExt.cpp	13
cpp/source/base/MetadataConstants.cpp	29
cpp/source/base/MixAll.cpp	246
cpp/source/base/Protocol.cpp	116
cpp/source/base/ThreadPoolImpl.cpp	76
cpp/source/base/UniqueIdGenerator.cpp	62
cpp/source/base/UtilAll.cpp	157
cpp/source/base/include/InvocationContext.h	66
cpp/source/base/include/MessageExt.h	10
cpp/source/base/include/MetadataConstants.h	24
cpp/source/base/include/MixAll.h	106
cpp/source/base/include/Protocol.h	55
cpp/source/base/include/RetryPolicy.h	50
cpp/source/base/include/SubscriptionEntry.h	12
cpp/source/base/include/ThreadPool.h	12
cpp/source/base/include/ThreadPoolImpl.h	30
cpp/source/base/include/UniqueIdGenerator.h	33
cpp/source/base/include/UtilAll.h	14
cpp/source/client/ClientManagerImpl.cpp	1295
cpp/source/client/LogInterceptor.cpp	70
cpp/source/client/LogInterceptorFactory.cpp	8
cpp/source/client/ReceiveMessageStreamReader.cpp	128
cpp/source/client/RpcClientImpl.cpp	123
cpp/source/client/SessionImpl.cpp	24
cpp/source/client/Signature.cpp	49
cpp/source/client/TelemetryBidiReactor.cpp	294
cpp/source/client/TlsHelper.cpp	19
cpp/source/client/TopicAssignmentInfo.cpp	33
cpp/source/client/include/Client.h	26
cpp/source/client/include/ClientConfig.h	42
cpp/source/client/include/ClientManager.h	62
cpp/source/client/include/ClientManagerImpl.h	124
cpp/source/client/include/ConsumeMessageType.h	10
cpp/source/client/include/InsecureCertificateVerifier.h	15
cpp/source/client/include/InterceptorContinuation.h	21
cpp/source/client/include/LogInterceptor.h	12
cpp/source/client/include/LogInterceptorFactory.h	9
cpp/source/client/include/Metadata.h	6
cpp/source/client/include/OpenSSLCompatible.h	289
cpp/source/client/include/ReceiveMessageCallback.h	7
cpp/source/client/include/ReceiveMessageContext.h	13
cpp/source/client/include/ReceiveMessageResult.h	19
cpp/source/client/include/ReceiveMessageStreamReader.h	38
cpp/source/client/include/RpcClient.h	52
cpp/source/client/include/RpcClientImpl.h	60
cpp/source/client/include/SendMessageContext.h	52
cpp/source/client/include/SendResult.h	12
cpp/source/client/include/SendResultCallback.h	6
cpp/source/client/include/Session.h	10
cpp/source/client/include/SessionImpl.h	19
cpp/source/client/include/Signature.h	9
cpp/source/client/include/TelemetryBidiReactor.h	53
cpp/source/client/include/TlsHelper.h	10
cpp/source/client/include/TopicAssignmentInfo.h	27
cpp/source/client/include/TopicRouteData.h	34
cpp/source/concurrent/CountdownLatch.cpp	32
cpp/source/concurrent/include/CountdownLatch.h	23
cpp/source/log/LoggerImpl.cpp	100
cpp/source/log/include/LoggerImpl.h	67
cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp	95
cpp/source/rocketmq/ClientImpl.cpp	501
cpp/source/rocketmq/ConsumeMessageServiceImpl.cpp	115
cpp/source/rocketmq/ConsumeTask.cpp	174
cpp/source/rocketmq/FifoContext.cpp	11
cpp/source/rocketmq/FifoProducer.cpp	44
cpp/source/rocketmq/FifoProducerImpl.cpp	15
cpp/source/rocketmq/FifoProducerPartition.cpp	73
cpp/source/rocketmq/MessageGroupQueueSelector.cpp	14
cpp/source/rocketmq/NamingScheme.cpp	67
cpp/source/rocketmq/ProcessQueueImpl.cpp	182
cpp/source/rocketmq/Producer.cpp	72
cpp/source/rocketmq/ProducerImpl.cpp	567
cpp/source/rocketmq/PushConsumer.cpp	31
cpp/source/rocketmq/PushConsumerImpl.cpp	533
cpp/source/rocketmq/SendContext.cpp	84
cpp/source/rocketmq/SimpleConsumer.cpp	101
cpp/source/rocketmq/SimpleConsumerImpl.cpp	338
cpp/source/rocketmq/StaticNameServerResolver.cpp	21
cpp/source/rocketmq/TopicPublishInfo.cpp	97
cpp/source/rocketmq/TransactionImpl.cpp	33
cpp/source/rocketmq/include/AsyncReceiveMessageCallback.h	19
cpp/source/rocketmq/include/ClientImpl.h	130
cpp/source/rocketmq/include/ClientResourceBundle.h	17
cpp/source/rocketmq/include/ConsumeMessageService.h	28
cpp/source/rocketmq/include/ConsumeMessageServiceImpl.h	48
cpp/source/rocketmq/include/ConsumeTask.h	38
cpp/source/rocketmq/include/Consumer.h	18
cpp/source/rocketmq/include/FifoContext.h	12
cpp/source/rocketmq/include/FifoProducerImpl.h	29
cpp/source/rocketmq/include/FifoProducerPartition.h	29
cpp/source/rocketmq/include/MessageGroupQueueSelector.h	13
cpp/source/rocketmq/include/NameServerResolver.h	13
cpp/source/rocketmq/include/NamingScheme.h	24
cpp/source/rocketmq/include/ProcessQueue.h	30
cpp/source/rocketmq/include/ProcessQueueImpl.h	65
cpp/source/rocketmq/include/ProducerImpl.h	94
cpp/source/rocketmq/include/PublishInfoCallback.h	7
cpp/source/rocketmq/include/PushConsumerImpl.h	128
cpp/source/rocketmq/include/SendContext.h	38
cpp/source/rocketmq/include/SimpleConsumerImpl.h	53
cpp/source/rocketmq/include/StaticNameServerResolver.h	18
cpp/source/rocketmq/include/TopicPublishInfo.h	29
cpp/source/rocketmq/include/TransactionImpl.h	33
cpp/source/scheduler/SchedulerImpl.cpp	155
cpp/source/scheduler/include/Scheduler.h	20
cpp/source/scheduler/include/SchedulerImpl.h	48
cpp/source/stats/ConsumeStats.cpp	58
cpp/source/stats/MetricBidiReactor.cpp	100
cpp/source/stats/OpencensusExporter.cpp	157
cpp/source/stats/OpencensusHandler.cpp	10
cpp/source/stats/PublishStats.cpp	16
cpp/source/stats/StdoutHandler.cpp	58
cpp/source/stats/Tag.cpp	19
cpp/source/stats/include/ConsumeStats.h	30
cpp/source/stats/include/MetricBidiReactor.h	35
cpp/source/stats/include/OpencensusExporter.h	27
cpp/source/stats/include/OpencensusHandler.h	10
cpp/source/stats/include/PublishStats.h	16
cpp/source/stats/include/StdoutHandler.h	47
cpp/source/stats/include/Tag.h	12
cpp/source/trace/TracingUtility.cpp	61
cpp/source/trace/include/TracingUtility.h	11
cpp/tools/fix_copyright.py	45
csharp/rocketmq-client-csharp/Address.cs	56
csharp/rocketmq-client-csharp/AddressListEqualityComparer.cs	29
csharp/rocketmq-client-csharp/AddressScheme.cs	26
csharp/rocketmq-client-csharp/Assignment.cs	28
csharp/rocketmq-client-csharp/Assignments.cs	40
csharp/rocketmq-client-csharp/Broker.cs	25
csharp/rocketmq-client-csharp/Client.cs	423
csharp/rocketmq-client-csharp/ClientConfig.cs	58
csharp/rocketmq-client-csharp/ClientLoggerInterceptor.cs	83
csharp/rocketmq-client-csharp/ClientManager.cs	158
csharp/rocketmq-client-csharp/ClientMeter.cs	47
csharp/rocketmq-client-csharp/ClientMeterManager.cs	90
csharp/rocketmq-client-csharp/ClientType.cs	23
csharp/rocketmq-client-csharp/ConsumeResult.cs	8
csharp/rocketmq-client-csharp/ConsumeService.cs	56
csharp/rocketmq-client-csharp/ConsumeTask.cs	32
csharp/rocketmq-client-csharp/Consumer.cs	107
csharp/rocketmq-client-csharp/CustomizedBackoffRetryPolicy.cs	74
csharp/rocketmq-client-csharp/Endpoints.cs	151
csharp/rocketmq-client-csharp/Error/BadRequestException.cs	13
csharp/rocketmq-client-csharp/Error/ClientException.cs	23
csharp/rocketmq-client-csharp/Error/ForbiddenException.cs	13
csharp/rocketmq-client-csharp/Error/InternalErrorException.cs	16
csharp/rocketmq-client-csharp/Error/NotFoundException.cs	16
csharp/rocketmq-client-csharp/Error/PayloadEmptyException.cs	13
csharp/rocketmq-client-csharp/Error/PayloadTooLargeException.cs	13
csharp/rocketmq-client-csharp/Error/PaymentRequiredException.cs	13
csharp/rocketmq-client-csharp/Error/ProxyTimeoutException.cs	13
csharp/rocketmq-client-csharp/Error/RequestHeaderFieldsTooLargeException.cs	13
csharp/rocketmq-client-csharp/Error/TooManyRequestsException.cs	13
csharp/rocketmq-client-csharp/Error/UnauthorizedException.cs	13
csharp/rocketmq-client-csharp/Error/UnsupportedException.cs	13
csharp/rocketmq-client-csharp/ExponentialBackoffRetryPolicy.cs	79
csharp/rocketmq-client-csharp/ExpressionType.cs	8
csharp/rocketmq-client-csharp/FifoConsumeService.cs	43
csharp/rocketmq-client-csharp/FilterExpression.cs	13
csharp/rocketmq-client-csharp/IClientManager.cs	35
csharp/rocketmq-client-csharp/IMessageListener.cs	7
csharp/rocketmq-client-csharp/IRecallReceipt.cs	7
csharp/rocketmq-client-csharp/IRetryPolicy.cs	13
csharp/rocketmq-client-csharp/IRpcClient.cs	30
csharp/rocketmq-client-csharp/ISendReceipt.cs	8
csharp/rocketmq-client-csharp/ISessionCredentialsProvider.cs	10
csharp/rocketmq-client-csharp/ITransaction.cs	9
csharp/rocketmq-client-csharp/ITransactionChecker.cs	7
csharp/rocketmq-client-csharp/Message.cs	121
csharp/rocketmq-client-csharp/MessageIdGenerator.cs	63
csharp/rocketmq-client-csharp/MessageQueue.cs	41
csharp/rocketmq-client-csharp/MessageType.cs	43
csharp/rocketmq-client-csharp/MessageView.cs	159
csharp/rocketmq-client-csharp/MetadataConstants.cs	43
csharp/rocketmq-client-csharp/Metric.cs	14
csharp/rocketmq-client-csharp/MetricConstant.cs	41
csharp/rocketmq-client-csharp/MetricHttpDelegatingHandler.cs	26
csharp/rocketmq-client-csharp/MqEncoding.cs	21
csharp/rocketmq-client-csharp/MqLogManager.cs	73
csharp/rocketmq-client-csharp/Permission.cs	71
csharp/rocketmq-client-csharp/Preconditions.cs	14
csharp/rocketmq-client-csharp/ProcessQueue.cs	617
csharp/rocketmq-client-csharp/Producer.cs	357
csharp/rocketmq-client-csharp/PublishingLoadBalancer.cs	73
csharp/rocketmq-client-csharp/PublishingMessage.cs	83
csharp/rocketmq-client-csharp/PublishingSettings.cs	59
csharp/rocketmq-client-csharp/PushConsumer.cs	553
csharp/rocketmq-client-csharp/PushSubscriptionSettings.cs	108
csharp/rocketmq-client-csharp/RecallReceipt.cs	15
csharp/rocketmq-client-csharp/ReceiveMessageResult.cs	14
csharp/rocketmq-client-csharp/Resource.cs	65
csharp/rocketmq-client-csharp/RpcClient.cs	155
csharp/rocketmq-client-csharp/RpcInvocation.cs	17
csharp/rocketmq-client-csharp/SendReceipt.cs	42
csharp/rocketmq-client-csharp/Session.cs	104
csharp/rocketmq-client-csharp/SessionCredentials.cs	25
csharp/rocketmq-client-csharp/Settings.cs	39
csharp/rocketmq-client-csharp/Signature.cs	53
csharp/rocketmq-client-csharp/SimpleConsumer.cs	284
csharp/rocketmq-client-csharp/SimpleSubscriptionSettings.cs	77
csharp/rocketmq-client-csharp/StandardConsumeService.cs	42
csharp/rocketmq-client-csharp/State.cs	12
csharp/rocketmq-client-csharp/StaticSessionCredentialsProvider.cs	11
csharp/rocketmq-client-csharp/StatusChecker.cs	88
csharp/rocketmq-client-csharp/SubscriptionLoadBalancer.cs	37
csharp/rocketmq-client-csharp/TopicRouteData.cs	76
csharp/rocketmq-client-csharp/Transaction.cs	101
csharp/rocketmq-client-csharp/TransactionResolution.cs	9
csharp/rocketmq-client-csharp/UserAgent.cs	27
csharp/rocketmq-client-csharp/Utilities.cs	130
golang/client.go	614
golang/client_manager.go	265
golang/client_options.go	58
golang/config.go	8
golang/conn.go	99
golang/conn_options.go	83
golang/consumer.go	9
golang/credentials/credentials.go	6
golang/error.go	35
golang/example/consumer/simple_consumer/main.go	64
golang/example/producer/async/main.go	55
golang/example/producer/delay/main.go	55
golang/example/producer/fifo/main.go	55
golang/example/producer/normal/main.go	54
golang/example/producer/transaction/main.go	65
golang/loadBalancer.go	123
golang/log.go	78
golang/message.go	300
golang/message_id.go	25
golang/message_id_codec.go	84
golang/metadata/metadata.go	23
golang/metric.go	177
golang/pkg/grpc/middleware/zaplog/zaplog.go	34
golang/pkg/net/net.go	31
golang/pkg/os/host.go	12
golang/pkg/ticker/ticker.go	20
golang/pkg/utils/utils.go	303
golang/pkg/zaplog/ctxzap/ctxzap.go	34
golang/pkg/zaplog/logger.go	37
golang/pkg/zaplog/options.go	47
golang/producer.go	396
golang/producer_options.go	128
golang/protocol/v2/admin.pb.go	241
golang/protocol/v2/admin_grpc.pb.go	70
golang/protocol/v2/definition.pb.go	2602
golang/protocol/v2/service.pb.go	2424
golang/protocol/v2/service_grpc.pb.go	456
golang/publishing_message.go	82
golang/rpc_client.go	137
golang/rpc_client_options.go	56
golang/simple_consumer.go	387
golang/simple_consumer_options.go	144
golang/trace.go	49
golang/transaction.go	89
golang/user_agent.go	23
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/ClientConfiguration.java	36
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/ClientConfigurationBuilder.java	39
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/ClientException.java	17
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/ClientServiceProvider.java	21
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/SessionCredentials.java	27
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/SessionCredentialsProvider.java	4
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/StaticSessionCredentialsProvider.java	14
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/ConsumeResult.java	5
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/FilterExpression.java	40
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/FilterExpressionType.java	5
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/MessageListener.java	5
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/PushConsumer.java	13
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/PushConsumerBuilder.java	14
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/SimpleConsumer.java	23
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/SimpleConsumerBuilder.java	13
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/message/Message.java	15
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/message/MessageBuilder.java	11
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/message/MessageId.java	5
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/message/MessageView.java	18
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/producer/Producer.java	16
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/producer/ProducerBuilder.java	11
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/producer/RecallReceipt.java	5
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/producer/SendReceipt.java	6
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/producer/Transaction.java	6
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/producer/TransactionChecker.java	5
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/producer/TransactionResolution.java	6
java/client-shade/src/main/resources/rocketmq.logback.xml	38
java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncProducerExample.java	40
java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java	78
java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerDelayMessageExample.java	36
java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerFifoMessageExample.java	34
java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerNormalMessageExample.java	33
java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerSingleton.java	55
java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerTransactionMessageExample.java	43
java/client/src/main/java/org/apache/rocketmq/client/java/example/PushConsumerExample.java	46
java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java	60
java/client/src/main/java/org/apache/rocketmq/client/java/exception/BadRequestException.java	7
java/client/src/main/java/org/apache/rocketmq/client/java/exception/ForbiddenException.java	7
java/client/src/main/java/org/apache/rocketmq/client/java/exception/InternalErrorException.java	13
java/client/src/main/java/org/apache/rocketmq/client/java/exception/NotFoundException.java	13
java/client/src/main/java/org/apache/rocketmq/client/java/exception/PayloadEmptyException.java	7
java/client/src/main/java/org/apache/rocketmq/client/java/exception/PayloadTooLargeException.java	7
java/client/src/main/java/org/apache/rocketmq/client/java/exception/PaymentRequiredException.java	7
java/client/src/main/java/org/apache/rocketmq/client/java/exception/ProxyTimeoutException.java	7
java/client/src/main/java/org/apache/rocketmq/client/java/exception/RequestHeaderFieldsTooLargeException.java	7
java/client/src/main/java/org/apache/rocketmq/client/java/exception/StatusChecker.java	85
java/client/src/main/java/org/apache/rocketmq/client/java/exception/TooManyRequestsException.java	7
java/client/src/main/java/org/apache/rocketmq/client/java/exception/UnauthorizedException.java	7
java/client/src/main/java/org/apache/rocketmq/client/java/exception/UnsupportedException.java	7
java/client/src/main/java/org/apache/rocketmq/client/java/hook/Attribute.java	13
java/client/src/main/java/org/apache/rocketmq/client/java/hook/AttributeKey.java	27
java/client/src/main/java/org/apache/rocketmq/client/java/hook/CompositedMessageInterceptor.java	53
java/client/src/main/java/org/apache/rocketmq/client/java/hook/MessageHookPoints.java	11
java/client/src/main/java/org/apache/rocketmq/client/java/hook/MessageHookPointsStatus.java	6
java/client/src/main/java/org/apache/rocketmq/client/java/hook/MessageInterceptor.java	9
java/client/src/main/java/org/apache/rocketmq/client/java/hook/MessageInterceptorContext.java	7
java/client/src/main/java/org/apache/rocketmq/client/java/hook/MessageInterceptorContextImpl.java	53
java/client/src/main/java/org/apache/rocketmq/client/java/impl/Client.java	13
java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java	582
java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManager.java	61
java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java	411
java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientServiceProviderImpl.java	28
java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientSessionImpl.java	161
java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientType.java	18
java/client/src/main/java/org/apache/rocketmq/client/java/impl/Settings.java	44
java/client/src/main/java/org/apache/rocketmq/client/java/impl/UserAgent.java	25
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/Assignment.java	34
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/Assignments.java	33
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumeService.java	63
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumeTask.java	49
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java	235
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/FifoConsumeService.java	45
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueue.java	19
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueGaugeObserver.java	68
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java	560
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerBuilderImpl.java	76
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerImpl.java	444
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushSubscriptionSettings.java	120
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ReceiveMessageResult.java	23
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/SimpleConsumerBuilderImpl.java	54
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/SimpleConsumerImpl.java	241
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/SimpleSubscriptionSettings.java	89
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/StandardConsumeService.java	46
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/SubscriptionLoadBalancer.java	38
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ClientSessionHandler.java	27
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerBuilderImpl.java	52
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java	486
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/PublishingLoadBalancer.java	95
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/PublishingSettings.java	78
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/RecallReceiptImpl.java	21
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/SendReceiptImpl.java	83
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/TransactionImpl.java	102
java/client/src/main/java/org/apache/rocketmq/client/java/logging/CustomConsoleAppender.java	18
java/client/src/main/java/org/apache/rocketmq/client/java/logging/ProcessIdConverter.java	20
java/client/src/main/java/org/apache/rocketmq/client/java/message/GeneralMessage.java	23
java/client/src/main/java/org/apache/rocketmq/client/java/message/GeneralMessageImpl.java	129
java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageBuilderImpl.java	82
java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageIdCodec.java	76
java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageIdImpl.java	37
java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageImpl.java	89
java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageType.java	36
java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageViewImpl.java	241
java/client/src/main/java/org/apache/rocketmq/client/java/message/PublishingMessageImpl.java	74
java/client/src/main/java/org/apache/rocketmq/client/java/message/protocol/Encoding.java	26
java/client/src/main/java/org/apache/rocketmq/client/java/message/protocol/Resource.java	54
java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeter.java	83
java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterManager.java	139
java/client/src/main/java/org/apache/rocketmq/client/java/metrics/EmptyGaugeObserver.java	16
java/client/src/main/java/org/apache/rocketmq/client/java/metrics/GaugeEnum.java	12
java/client/src/main/java/org/apache/rocketmq/client/java/metrics/GaugeObserver.java	9
java/client/src/main/java/org/apache/rocketmq/client/java/metrics/HistogramEnum.java	25
java/client/src/main/java/org/apache/rocketmq/client/java/metrics/InvocationStatus.java	12
java/client/src/main/java/org/apache/rocketmq/client/java/metrics/MessageMeterInterceptor.java	170
java/client/src/main/java/org/apache/rocketmq/client/java/metrics/Metric.java	24
java/client/src/main/java/org/apache/rocketmq/client/java/metrics/MetricLabels.java	11
java/client/src/main/java/org/apache/rocketmq/client/java/misc/ClientId.java	28
java/client/src/main/java/org/apache/rocketmq/client/java/misc/ExcludeFromJacocoGeneratedReport.java	9
java/client/src/main/java/org/apache/rocketmq/client/java/misc/ExecutorServices.java	11
java/client/src/main/java/org/apache/rocketmq/client/java/misc/MetadataUtils.java	29
java/client/src/main/java/org/apache/rocketmq/client/java/misc/RequestIdGenerator.java	11
java/client/src/main/java/org/apache/rocketmq/client/java/misc/ThreadFactoryImpl.java	26
java/client/src/main/java/org/apache/rocketmq/client/java/misc/Utilities.java	285
java/client/src/main/java/org/apache/rocketmq/client/java/retry/CustomizedBackoffRetryPolicy.java	72
java/client/src/main/java/org/apache/rocketmq/client/java/retry/ExponentialBackoffRetryPolicy.java	90
java/client/src/main/java/org/apache/rocketmq/client/java/retry/RetryPolicy.java	8
java/client/src/main/java/org/apache/rocketmq/client/java/route/Address.java	49
java/client/src/main/java/org/apache/rocketmq/client/java/route/AddressScheme.java	36
java/client/src/main/java/org/apache/rocketmq/client/java/route/Broker.java	51
java/client/src/main/java/org/apache/rocketmq/client/java/route/Endpoints.java	162
java/client/src/main/java/org/apache/rocketmq/client/java/route/MessageQueueImpl.java	75
java/client/src/main/java/org/apache/rocketmq/client/java/route/Permission.java	58
java/client/src/main/java/org/apache/rocketmq/client/java/route/TopicRouteData.java	71
java/client/src/main/java/org/apache/rocketmq/client/java/rpc/AuthInterceptor.java	40
java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Context.java	17
java/client/src/main/java/org/apache/rocketmq/client/java/rpc/IpNameResolverFactory.java	54
java/client/src/main/java/org/apache/rocketmq/client/java/rpc/LoggingInterceptor.java	56
java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClient.java	61
java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClientImpl.java	192
java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcFuture.java	53
java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java	84
java/client/src/main/java/org/apache/rocketmq/client/java/rpc/TLSHelper.java	21
java/client/src/main/resources/logback.xml	38
java/style/copyright/Apache.xml	6
java/style/intellij-codestyle.xml	49
java/style/spotbugs-suppressions.xml	46
nodejs/proto/apache/rocketmq/v2/admin.proto	37
nodejs/proto/apache/rocketmq/v2/definition.proto	456
nodejs/proto/apache/rocketmq/v2/service.proto	338
nodejs/src/client/BaseClient.ts	278
nodejs/src/client/ClientId.ts	8
nodejs/src/client/Logger.ts	16
nodejs/src/client/RpcClient.ts	200
nodejs/src/client/RpcClientManager.ts	134
nodejs/src/client/SessionCredentials.ts	5
nodejs/src/client/Settings.ts	24
nodejs/src/client/TelemetrySession.ts	91
nodejs/src/client/UserAgent.ts	23
nodejs/src/client/index.ts	10
nodejs/src/consumer/Consumer.ts	83
nodejs/src/consumer/FilterExpression.ts	19
nodejs/src/consumer/SimpleConsumer.ts	96
nodejs/src/consumer/SimpleSubscriptionSettings.ts	40
nodejs/src/consumer/SubscriptionLoadBalancer.ts	26
nodejs/src/consumer/index.ts	5
nodejs/src/exception/BadRequestException.ts	7
nodejs/src/exception/ClientException.ts	10
nodejs/src/exception/ForbiddenException.ts	7
nodejs/src/exception/InternalErrorException.ts	7
nodejs/src/exception/NotFoundException.ts	7
nodejs/src/exception/PayloadTooLargeException.ts	7
nodejs/src/exception/PaymentRequiredException.ts	7
nodejs/src/exception/ProxyTimeoutException.ts	7
nodejs/src/exception/RequestHeaderFieldsTooLargeException.ts	7
nodejs/src/exception/StatusChecker.ts	76
nodejs/src/exception/TooManyRequestsException.ts	7
nodejs/src/exception/UnauthorizedException.ts	7
nodejs/src/exception/UnsupportedException.ts	7
nodejs/src/exception/index.ts	13
nodejs/src/index.ts	6
nodejs/src/message/Message.ts	32
nodejs/src/message/MessageId.ts	70
nodejs/src/message/MessageView.ts	72
nodejs/src/message/PublishingMessage.ts	73
nodejs/src/message/index.ts	4
nodejs/src/producer/Producer.ts	235
nodejs/src/producer/PublishingLoadBalancer.ts	61
nodejs/src/producer/PublishingSettings.ts	49
nodejs/src/producer/SendReceipt.ts	37
nodejs/src/producer/Transaction.ts	47
nodejs/src/producer/TransactionChecker.ts	5
nodejs/src/producer/index.ts	5
nodejs/src/retry/ExponentialBackoffRetryPolicy.ts	51
nodejs/src/retry/RetryPolicy.ts	7
nodejs/src/retry/index.ts	2
nodejs/src/route/Broker.ts	19
nodejs/src/route/Endpoints.ts	43
nodejs/src/route/MessageQueue.ts	29
nodejs/src/route/TopicRouteData.ts	18
nodejs/src/route/index.ts	4
nodejs/src/util/index.ts	52
php/Consumer.php	27
php/Producer.php	43
php/grpc/Apache/Rocketmq/V2/AdminClient.php	14
php/grpc/Apache/Rocketmq/V2/MessagingServiceClient.php	82
php/grpc/GPBMetadata/Apache/Rocketmq/V2/Admin.php	31
php/grpc/GPBMetadata/Apache/Rocketmq/V2/Definition.php	207
php/grpc/GPBMetadata/Apache/Rocketmq/V2/Service.php	178
php/protocol/apache/rocketmq/v2/admin.proto	37
php/protocol/apache/rocketmq/v2/definition.proto	366
php/protocol/apache/rocketmq/v2/service.proto	378
python/example/async_producer_example.py	33
python/example/async_simple_consumer_example.py	42
python/example/delay_producer_example.py	26
python/example/fifo_producer_example.py	25
python/example/normal_producer_example.py	26
python/example/simple_consumer_example.py	27
python/example/transaction_producer_example.py	37
python/rocketmq/__init__.py	17
python/rocketmq/grpc_protocol/__init__.py	46
python/rocketmq/grpc_protocol/admin_pb2.py	20
python/rocketmq/grpc_protocol/admin_pb2_grpc.py	42
python/rocketmq/grpc_protocol/definition_pb2_grpc.py	1
python/rocketmq/grpc_protocol/proto/admin.proto	37
python/rocketmq/grpc_protocol/proto/definition.proto	460
python/rocketmq/grpc_protocol/proto/service.proto	346
python/rocketmq/grpc_protocol/service_pb2_grpc.py	462
python/rocketmq/v5/__init__.py	1
python/rocketmq/v5/client/__init__.py	7
python/rocketmq/v5/client/balancer/__init__.py	4
python/rocketmq/v5/client/balancer/queue_selector.py	68
python/rocketmq/v5/client/client.py	456
python/rocketmq/v5/client/client_configuration.py	82
python/rocketmq/v5/client/connection/__init__.py	7
python/rocketmq/v5/client/connection/rpc_channel.py	196
python/rocketmq/v5/client/connection/rpc_client.py	259
python/rocketmq/v5/client/metrics/__init__.py	4
python/rocketmq/v5/client/metrics/client_metrics.py	131
python/rocketmq/v5/consumer/__init__.py	4
python/rocketmq/v5/consumer/simple_consumer.py	382
python/rocketmq/v5/exception/__init__.py	24
python/rocketmq/v5/exception/client_exception.py	48
python/rocketmq/v5/log/__init__.py	4
python/rocketmq/v5/log/log_config.py	31
python/rocketmq/v5/model/__init__.py	18
python/rocketmq/v5/model/callback_result.py	77
python/rocketmq/v5/model/filter_expression.py	16
python/rocketmq/v5/model/message.py	203
python/rocketmq/v5/model/metrics.py	40
python/rocketmq/v5/model/send_receipt.py	20
python/rocketmq/v5/model/topic_route.py	95
python/rocketmq/v5/producer/__init__.py	6
python/rocketmq/v5/producer/producer.py	457
python/rocketmq/v5/util/__init__.py	16
python/rocketmq/v5/util/atomic.py	40
python/rocketmq/v5/util/client_id.py	28
python/rocketmq/v5/util/concurrent_map.py	36
python/rocketmq/v5/util/message_id_codec.py	60
python/rocketmq/v5/util/messaging_result_checker.py	83
python/rocketmq/v5/util/misc.py	79
python/rocketmq/v5/util/signature.py	44
python/setup.py	15
rust/Cargo.toml	74
rust/build.rs	68
rust/src/client.rs	1155
rust/src/conf.rs	306
rust/src/error.rs	172
rust/src/lib.rs	36
rust/src/log.rs	50
rust/src/model/common.rs	54
rust/src/model/message.rs	98
rust/src/model/message_id.rs	132
rust/src/model/mod.rs	20
rust/src/model/transaction.rs	38
rust/src/pb/apache.rocketmq.v2.rs	1885
rust/src/producer.rs	171
rust/src/push_consumer.rs	1857
rust/src/session.rs	112
rust/src/simple_consumer.rs	185
rust/src/util.rs	361