7548
49%

Ran 20 Jul 2022 04:13AM UTC

Jobs 2

Files 1042

Run time 22min

Badge

Embed ▾

pending completion

Build # 7548

Build Type

push

travis-ci-com

Committed by GitHub

Commit Message

Merge pull request #4225 from drpmma/feature/grpc-develop-v2

[ISSUE #3949] Support gRPC protocol

Run Details

5544 of 5544 new or added lines in 150 files covered. (100.0%)

30315 of 63012 relevant lines covered (48.11%)

0.96 hits per line

New Missed Lines in Diff

Lines	Coverage	File
1	100.0	acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessValidator.java
1	100.0	acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionChecker.java
1	100.0	broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
1	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java
1	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/FilterUtils.java
1	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ProxyUtils.java
1	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigurationManager.java
1	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/config/MetricCollectorMode.java
1	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/InterceptorConstants.java
1	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator/DefaultTopicMessageTypeValidator.java
1	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java
1	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/DoNothingClientRemotingProcessor.java
1	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueView.java
2	100.0	broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
2	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
2	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/FutureUtils.java
2	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/AbstractMessingActivity.java
2	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationContext.java
2	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteWrapper.java
2	100.0	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java
3	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java
3	100.0	common/src/main/java/org/apache/rocketmq/common/subscription/CustomizedRetryPolicy.java
3	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyException.java
3	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/ContextInterceptor.java
3	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/ForwardMessageToDLQActivity.java
3	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/transaction/EndTransactionActivity.java
3	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/route/LocalTopicRouteService.java
3	100.0	test/src/main/java/org/apache/rocketmq/test/util/MQAdminTestUtils.java
4	100.0	broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
4	100.0	broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
4	100.0	client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
4	100.0	client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java
4	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java
4	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java
4	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyContext.java
4	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/processor/AbstractProcessor.java
4	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ClusterProxyRelayService.java
4	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/RelayData.java
4	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteService.java
4	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/AbstractTransactionService.java
4	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/EndTransactionRequestData.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerRunningInfoRequestHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerStatusRequestHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/subscription/ExponentialRetryPolicy.java
5	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/config/Configuration.java
5	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcProxyException.java
5	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/processor/MessagingProcessor.java
5	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManagerFactory.java
5	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/route/AddressableMessageQueue.java
6	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/CloneGroupOffsetRequestHeader.java
6	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java
6	100.0	common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolQueueSizeMonitor.java
6	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/PopMessageResultFilterImpl.java
6	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyRelayResult.java
6	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ClusterTopicRouteService.java
6	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteHelper.java
7	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/AckMessageRequestHeader.java
7	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/CheckTransactionStateRequestHeader.java
7	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/AbstractCacheLoader.java
7	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/Address.java
7	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcValidator.java
7	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/processor/TransactionProcessor.java
8	100.0	client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
8	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/ChangeInvisibleTimeRequestHeader.java
8	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ExceptionUtils.java
8	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseWriter.java
8	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java
8	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/LocalMetadataService.java
8	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/LocalTransactionService.java
9	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/ConsumeMessageDirectlyResultRequestHeader.java
9	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/ConsumerSendMsgBackRequestHeader.java
9	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/EndTransactionRequestHeader.java
10	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateAccessConfigRequestHeader.java
10	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/processor/ProducerProcessor.java
11	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/ReceiptHandleGroup.java
11	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseBuilder.java
11	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageResponseStreamWriter.java
11	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/ClusterMetadataService.java
12	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java
12	100.0	common/src/main/java/org/apache/rocketmq/common/utils/BinaryUtil.java
12	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/ProxyMode.java
12	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/AckMessageActivity.java
13	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/PopMessageRequestHeader.java
13	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java
13	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationChannel.java
13	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionDataManager.java
14	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
14	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/AbstractProxyRelayService.java
15	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java
15	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/ChannelManager.java
16	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/AbstractStartAndShutdown.java
16	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/HeaderInterceptor.java
16	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/RequestMapping.java
16	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyChannel.java
17	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java
17	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity.java
17	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/processor/ClientProcessor.java
17	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/ProxyClientRemotingProcessor.java
19	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionData.java
21	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ProxyTopicRouteData.java
25	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/common/MessageReceiptHandle.java
25	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java
26	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannel.java
28	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/LocalServiceManager.java
28	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/ClusterTransactionService.java
29	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/DefaultGrpcMessingActivity.java
30	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManager.java
32	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java
34	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/AuthenticationInterceptor.java
35	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueSelector.java
37	100.0	common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolWrapper.java
39	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIFactory.java
40	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannelHandlerContext.java
43	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/processor/ReceiptHandleProcessor.java
43	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalMessageService.java
45	100.0	acl/src/main/java/org/apache/rocketmq/acl/common/AuthorizationHeader.java
47	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java
48	100.0	common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolMonitor.java
49	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/GlobalExceptionInterceptor.java
49	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java
50	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/message/ClusterMessageService.java
55	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java
59	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java
65	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java
67	100.0	acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessResource.java
72	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java
77	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java
80	100.0	common/src/main/java/org/apache/rocketmq/common/consumer/ReceiptHandle.java
85	100.0	acl/src/main/java/org/apache/rocketmq/acl/common/AuthenticationHeader.java
123	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
143	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/processor/ConsumerProcessor.java
165	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java
188	100.0	proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java

Uncovered Existing Lines

Lines	Coverage	File
1	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceLitePullImpl.java
2	100.0	acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessValidator.java
2	100.0	client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
2	100.0	client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
2	100.0	store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
3	100.0	common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java

Jobs

ID	Job ID	Ran	Files	Coverage
1	7548.1	20 Jul 2022 04:13AM UTC	0	48.11	Travis Job 7548.1
2	7548.2	20 Jul 2022 04:28AM UTC	0	48.1	Travis Job 7548.2

apache / rocketmq / 7548
49%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Uncovered Existing Lines

Jobs

Source Files on build 7548

apache / rocketmq / 7548 49%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Uncovered Existing Lines

Jobs

Source Files on build 7548

apache / rocketmq / 7548
49%

README BADGES
x