Path	Lines of Code
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