Path	Lines of Code
proxy/src/main/java/org/apache/rocketmq/proxy/CommandLineArgument.java	31
proxy/src/main/java/org/apache/rocketmq/proxy/ProxyMode.java	33
proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java	194
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/common/AbstractCacheLoader.java	31
proxy/src/main/java/org/apache/rocketmq/proxy/common/Address.java	62
proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java	13
proxy/src/main/java/org/apache/rocketmq/proxy/common/MessageReceiptHandle.java	115
proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyContext.java	97
proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyException.java	15
proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyExceptionCode.java	9
proxy/src/main/java/org/apache/rocketmq/proxy/common/ReceiptHandleGroup.java	280
proxy/src/main/java/org/apache/rocketmq/proxy/common/ReceiptHandleGroupKey.java	43
proxy/src/main/java/org/apache/rocketmq/proxy/common/RenewEvent.java	38
proxy/src/main/java/org/apache/rocketmq/proxy/common/RenewStrategyPolicy.java	42
proxy/src/main/java/org/apache/rocketmq/proxy/common/channel/ChannelHelper.java	22
proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/FilterUtils.java	14
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/config/ConfigFile.java	4
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/MetricCollectorMode.java	21
proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java	1136
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java	30
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/constant/AttributeKeys.java	21
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/HeaderInterceptor.java	66
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/RequestMapping.java	38
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/pipeline/AuthenticationPipeline.java	53
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/pipeline/AuthorizationPipeline.java	42
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/pipeline/ContextInitPipeline.java	29
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/pipeline/RequestPipeline.java	13
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/AbstractMessingActivity.java	36
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/ContextStreamObserver.java	7
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/DefaultGrpcMessingActivity.java	128
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java	424
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessingActivity.java	46
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java	95
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java	227
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java	438
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/GrpcProxyException.java	42
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/ResponseBuilder.java	89
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseWriter.java	55
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/consumer/PopMessageResultFilterImpl.java	23
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/ReceiveMessageResponseStreamWriter.java	131
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/RecallMessageActivity.java	39
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java	330
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java	268
proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/transaction/EndTransactionActivity.java	57
proxy/src/main/java/org/apache/rocketmq/proxy/metrics/ProxyMetricsConstant.java	6
proxy/src/main/java/org/apache/rocketmq/proxy/metrics/ProxyMetricsManager.java	215
proxy/src/main/java/org/apache/rocketmq/proxy/processor/AbstractProcessor.java	21
proxy/src/main/java/org/apache/rocketmq/proxy/processor/BatchAckResult.java	28
proxy/src/main/java/org/apache/rocketmq/proxy/processor/ClientProcessor.java	87
proxy/src/main/java/org/apache/rocketmq/proxy/processor/ConsumerProcessor.java	499
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/PopMessageResultFilter.java	13
proxy/src/main/java/org/apache/rocketmq/proxy/processor/ProducerProcessor.java	224
proxy/src/main/java/org/apache/rocketmq/proxy/processor/QueueSelector.java	7
proxy/src/main/java/org/apache/rocketmq/proxy/processor/ReceiptHandleProcessor.java	44
proxy/src/main/java/org/apache/rocketmq/proxy/processor/RequestBrokerProcessor.java	17
proxy/src/main/java/org/apache/rocketmq/proxy/processor/TransactionProcessor.java	55
proxy/src/main/java/org/apache/rocketmq/proxy/processor/TransactionStatus.java	6
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/ChannelExtendAttributeGetter.java	4
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/ChannelProtocolType.java	14
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/RemoteChannel.java	80
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/RemoteChannelConverter.java	4
proxy/src/main/java/org/apache/rocketmq/proxy/processor/channel/RemoteChannelSerializer.java	44
proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator/DefaultTopicMessageTypeValidator.java	13
proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator/TopicMessageTypeValidator.java	5
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/ClientHousekeepingService.java	28
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolRemotingServer.java	58
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/MultiProtocolTlsHelper.java	83
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/activity/AbstractRemotingActivity.java	139
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/AckMessageActivity.java	18
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ChangeInvisibleTimeActivity.java	18
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ClientManagerActivity.java	165
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/ConsumerManagerActivity.java	142
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/GetTopicRouteActivity.java	49
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/PopMessageActivity.java	21
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/PullMessageActivity.java	43
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/RecallMessageActivity.java	31
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/SendMessageActivity.java	71
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/activity/TransactionActivity.java	45
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannel.java	222
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/channel/RemotingChannelManager.java	99
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/common/RemotingConverter.java	28
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/AuthenticationPipeline.java	40
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/AuthorizationPipeline.java	42
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/ContextInitPipeline.java	34
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/pipeline/RequestPipeline.java	13
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/ProtocolHandler.java	7
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/ProtocolNegotiationHandler.java	35
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/Http2ProtocolProxyHandler.java	96
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/Http2ProxyFrontendHandler.java	51
proxy/src/main/java/org/apache/rocketmq/proxy/remoting/protocol/remoting/RemotingProtocolHandler.java	38
proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java	166
proxy/src/main/java/org/apache/rocketmq/proxy/service/LocalServiceManager.java	111
proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManager.java	20
proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManagerFactory.java	22
proxy/src/main/java/org/apache/rocketmq/proxy/service/admin/AdminService.java	10
proxy/src/main/java/org/apache/rocketmq/proxy/service/admin/DefaultAdminService.java	112
proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/ChannelManager.java	65
proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationChannel.java	55
proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationContext.java	20
proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationContextInterface.java	6
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/client/ClusterConsumerManager.java	45
proxy/src/main/java/org/apache/rocketmq/proxy/service/client/ProxyClientRemotingProcessor.java	56
proxy/src/main/java/org/apache/rocketmq/proxy/service/message/ClusterMessageService.java	244
proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalMessageService.java	467
proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java	17
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/metadata/ClusterMetadataService.java	237
proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/LocalMetadataService.java	36
proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/MetadataService.java	14
proxy/src/main/java/org/apache/rocketmq/proxy/service/receipt/DefaultReceiptHandleManager.java	246
proxy/src/main/java/org/apache/rocketmq/proxy/service/receipt/ReceiptHandleManager.java	8
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/AbstractProxyRelayService.java	42
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ClusterProxyRelayService.java	26
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/LocalProxyRelayService.java	66
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyChannel.java	155
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyRelayResult.java	29
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyRelayService.java	29
proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/RelayData.java	23
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/AddressableMessageQueue.java	53
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ClusterTopicRouteService.java	32
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/MessageQueueView.java	41
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ProxyTopicRouteData.java	116
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteHelper.java	26
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteService.java	187
proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteWrapper.java	47
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/AbstractSystemMessageSyncer.java	145
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncer.java	203
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatSyncerData.java	130
proxy/src/main/java/org/apache/rocketmq/proxy/service/sysmessage/HeartbeatType.java	5
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/AbstractTransactionService.java	65
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/ClusterTransactionService.java	248
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/EndTransactionRequestData.java	22
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/LocalTransactionService.java	26
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionData.java	85
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionDataManager.java	130
proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionService.java	17
proxy/src/main/resources/rmq.proxy.logback.xml	403