Path	Lines of Code
cpp/bazel/rocketmq_deps.bzl	172
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	43
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	60
cpp/include/rocketmq/Executor.h	6
cpp/include/rocketmq/ExpressionType.h	10
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	42
cpp/include/rocketmq/PushConsumer.h	58
cpp/include/rocketmq/RocketMQ.h	6
cpp/include/rocketmq/SendCallback.h	8
cpp/include/rocketmq/SendReceipt.h	12
cpp/include/rocketmq/SimpleConsumer.h	68
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	366
cpp/proto/apache/rocketmq/v2/service.proto	378
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	25
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	62
cpp/source/base/MessageExt.cpp	13
cpp/source/base/MetadataConstants.cpp	29
cpp/source/base/MixAll.cpp	246
cpp/source/base/Protocol.cpp	115
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	53
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/base/mocks/include/HttpClientMock.h	16
cpp/source/base/mocks/include/MessageListenerMock.h	13
cpp/source/client/ClientManagerImpl.cpp	1184
cpp/source/client/LogInterceptor.cpp	70
cpp/source/client/LogInterceptorFactory.cpp	8
cpp/source/client/ReceiveMessageStreamReader.cpp	128
cpp/source/client/RpcClientImpl.cpp	119
cpp/source/client/SessionImpl.cpp	23
cpp/source/client/Signature.cpp	48
cpp/source/client/TelemetryBidiReactor.cpp	284
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	60
cpp/source/client/include/ClientManagerImpl.h	125
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	50
cpp/source/client/include/RpcClientImpl.h	58
cpp/source/client/include/SendMessageContext.h	52
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	57
cpp/source/client/include/TlsHelper.h	10
cpp/source/client/include/TopicAssignmentInfo.h	27
cpp/source/client/include/TopicRouteData.h	34
cpp/source/client/mocks/include/ClientManagerMock.h	59
cpp/source/client/mocks/include/ClientMock.h	25
cpp/source/client/mocks/include/RpcClientMock.h	40
cpp/source/concurrent/CountdownLatch.cpp	32
cpp/source/concurrent/include/CountdownLatch.h	23
cpp/source/log/LoggerImpl.cpp	101
cpp/source/log/include/LoggerImpl.h	67
cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp	86
cpp/source/rocketmq/ClientImpl.cpp	505
cpp/source/rocketmq/ConsumeMessageServiceImpl.cpp	109
cpp/source/rocketmq/ConsumeTask.cpp	174
cpp/source/rocketmq/MessageGroupQueueSelector.cpp	14
cpp/source/rocketmq/NamingScheme.cpp	55
cpp/source/rocketmq/ProcessQueueImpl.cpp	170
cpp/source/rocketmq/Producer.cpp	72
cpp/source/rocketmq/ProducerImpl.cpp	477
cpp/source/rocketmq/PushConsumer.cpp	30
cpp/source/rocketmq/PushConsumerImpl.cpp	513
cpp/source/rocketmq/SendContext.cpp	81
cpp/source/rocketmq/SimpleConsumer.cpp	102
cpp/source/rocketmq/SimpleConsumerImpl.cpp	316
cpp/source/rocketmq/StaticNameServerResolver.cpp	17
cpp/source/rocketmq/TopicPublishInfo.cpp	93
cpp/source/rocketmq/TransactionImpl.cpp	33
cpp/source/rocketmq/include/AsyncReceiveMessageCallback.h	19
cpp/source/rocketmq/include/ClientImpl.h	127
cpp/source/rocketmq/include/ClientResourceBundle.h	17
cpp/source/rocketmq/include/ConsumeMessageService.h	28
cpp/source/rocketmq/include/ConsumeMessageServiceImpl.h	43
cpp/source/rocketmq/include/ConsumeTask.h	38
cpp/source/rocketmq/include/Consumer.h	18
cpp/source/rocketmq/include/MessageGroupQueueSelector.h	13
cpp/source/rocketmq/include/NameServerResolver.h	13
cpp/source/rocketmq/include/NamingScheme.h	23
cpp/source/rocketmq/include/ProcessQueue.h	30
cpp/source/rocketmq/include/ProcessQueueImpl.h	65
cpp/source/rocketmq/include/ProducerImpl.h	96
cpp/source/rocketmq/include/PublishInfoCallback.h	7
cpp/source/rocketmq/include/PushConsumerImpl.h	127
cpp/source/rocketmq/include/SendContext.h	41
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/rocketmq/mocks/include/ConsumeMessageServiceMock.h	14
cpp/source/rocketmq/mocks/include/ConsumerMock.h	13
cpp/source/rocketmq/mocks/include/NameServerResolverMock.h	11
cpp/source/rocketmq/mocks/include/ProcessQueueMock.h	26
cpp/source/rocketmq/mocks/include/PushConsumerMock.h	19
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	91
cpp/source/stats/OpencensusExporter.cpp	149
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	30
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/Broker.cs	25
csharp/rocketmq-client-csharp/Client.cs	411
csharp/rocketmq-client-csharp/ClientConfig.cs	50
csharp/rocketmq-client-csharp/ClientLoggerInterceptor.cs	83
csharp/rocketmq-client-csharp/ClientManager.cs	141
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/Consumer.cs	83
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/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	63
csharp/rocketmq-client-csharp/ExpressionType.cs	8
csharp/rocketmq-client-csharp/FilterExpression.cs	13
csharp/rocketmq-client-csharp/IClientManager.cs	31
csharp/rocketmq-client-csharp/IRetryPolicy.cs	13
csharp/rocketmq-client-csharp/IRpcClient.cs	29
csharp/rocketmq-client-csharp/ISendReceipt.cs	7
csharp/rocketmq-client-csharp/ISessionCredentialsProvider.cs	10
csharp/rocketmq-client-csharp/ITransaction.cs	8
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	145
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	65
csharp/rocketmq-client-csharp/Permission.cs	71
csharp/rocketmq-client-csharp/Preconditions.cs	14
csharp/rocketmq-client-csharp/Producer.cs	335
csharp/rocketmq-client-csharp/PublishingLoadBalancer.cs	73
csharp/rocketmq-client-csharp/PublishingMessage.cs	82
csharp/rocketmq-client-csharp/PublishingSettings.cs	58
csharp/rocketmq-client-csharp/ReceiveMessageResult.cs	14
csharp/rocketmq-client-csharp/Resource.cs	31
csharp/rocketmq-client-csharp/RpcClient.cs	148
csharp/rocketmq-client-csharp/RpcInvocation.cs	17
csharp/rocketmq-client-csharp/SendReceipt.cs	38
csharp/rocketmq-client-csharp/Session.cs	105
csharp/rocketmq-client-csharp/SessionCredentials.cs	25
csharp/rocketmq-client-csharp/Settings.cs	36
csharp/rocketmq-client-csharp/Signature.cs	52
csharp/rocketmq-client-csharp/SimpleConsumer.cs	279
csharp/rocketmq-client-csharp/SimpleSubscriptionSettings.cs	75
csharp/rocketmq-client-csharp/State.cs	12
csharp/rocketmq-client-csharp/StaticSessionCredentialsProvider.cs	11
csharp/rocketmq-client-csharp/StatusChecker.cs	86
csharp/rocketmq-client-csharp/SubscriptionLoadBalancer.cs	37
csharp/rocketmq-client-csharp/TopicRouteData.cs	45
csharp/rocketmq-client-csharp/Transaction.cs	100
csharp/rocketmq-client-csharp/TransactionResolution.cs	9
csharp/rocketmq-client-csharp/UserAgent.cs	27
csharp/rocketmq-client-csharp/Utilities.cs	112
golang/client.go	574
golang/client_manager.go	265
golang/client_manager_mock.go	138
golang/client_mock.go	105
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	109
golang/log.go	78
golang/message.go	300
golang/message_id.go	25
golang/message_id_codec.go	84
golang/metadata/metadata.go	22
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	240
golang/pkg/zaplog/ctxzap/ctxzap.go	34
golang/pkg/zaplog/logger.go	37
golang/pkg/zaplog/options.go	47
golang/producer.go	393
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	79
golang/rpc_client.go	137
golang/rpc_client_mock.go	150
golang/rpc_client_options.go	56
golang/simple_consumer.go	382
golang/simple_consumer_options.go	138
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	31
java/client-apis/src/main/java/org/apache/rocketmq/client/apis/ClientConfigurationBuilder.java	34
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	14
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/SendReceipt.java	5
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/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	83
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	579
java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManager.java	57
java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java	395
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	41
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	48
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java	227
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	435
java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushSubscriptionSettings.java	117
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	87
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	445
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	73
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/SendReceiptImpl.java	74
java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/TransactionImpl.java	89
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	81
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	238
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	57
java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClientImpl.java	183
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	82
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
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/protocol/apache/rocketmq/v2/admin.proto	37
php/protocol/apache/rocketmq/v2/definition.proto	366
php/protocol/apache/rocketmq/v2/service.proto	378
python/pyproject.toml	44
python/rocketmq/client.py	300
python/rocketmq/client_config.py	22
python/rocketmq/client_id_encoder.py	27
python/rocketmq/client_manager.py	119
python/rocketmq/definition.py	146
python/rocketmq/exponential_backoff_retry_policy.py	38
python/rocketmq/foo.py	1
python/rocketmq/log.py	18
python/rocketmq/message.py	90
python/rocketmq/message_id.py	4
python/rocketmq/message_id_codec.py	56
python/rocketmq/producer.py	369
python/rocketmq/protocol/__init__.py	1
python/rocketmq/protocol/admin_pb2.pyi	22
python/rocketmq/protocol/admin_pb2_grpc.py	42
python/rocketmq/protocol/definition_pb2_grpc.py	1
python/rocketmq/protocol/service_pb2.pyi	249
python/rocketmq/protocol/service_pb2_grpc.py	342
python/rocketmq/publish_settings.py	59
python/rocketmq/publishing_message.py	55
python/rocketmq/rpc_client.py	237
python/rocketmq/send_receipt.py	21
python/rocketmq/session.py	49
python/rocketmq/session_credentials.py	16
python/rocketmq/settings.py	49
python/rocketmq/signature.py	66
python/rocketmq/status_checker.py	137
python/rocketmq/utils.py	22
rust/Cargo.toml	70
rust/build.rs	68
rust/src/client.rs	579
rust/src/conf.rs	219
rust/src/error.rs	168
rust/src/lib.rs	33
rust/src/log.rs	50
rust/src/model/common.rs	52
rust/src/model/message.rs	77
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	498
rust/src/session.rs	109
rust/src/simple_consumer.rs	248
rust/src/util.rs	53
style/markdown/config.yml	50