apache / rocketmq / 7548
49%

DEFAULT BRANCH: develop
Ran
Jobs 2
Files 1042
Run time 22min
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst
7548

push

travis-ci-com

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

[ISSUE #3949] Support gRPC protocol

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
78.57
 -15.87% acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessValidator.java
1
95.83
 acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionChecker.java
1
79.28
 0.9% broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
1
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java
1
83.33
 proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/FilterUtils.java
1
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ProxyUtils.java
1
90.91
 proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigurationManager.java
1
91.67
 proxy/src/main/java/org/apache/rocketmq/proxy/config/MetricCollectorMode.java
1
96.43
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/InterceptorConstants.java
1
75.0
 proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator/DefaultTopicMessageTypeValidator.java
1
87.5
 proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java
1
66.67
 proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/DoNothingClientRemotingProcessor.java
1
93.75
 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueView.java
2
81.82
 1.99% broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
2
50.09
 -0.71% broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
2
75.0
 proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/FutureUtils.java
2
87.5
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/AbstractMessingActivity.java
2
75.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationContext.java
2
90.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteWrapper.java
2
50.0
 -2.38% remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java
3
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java
3
75.0
 -6.25% common/src/main/java/org/apache/rocketmq/common/subscription/CustomizedRetryPolicy.java
3
57.14
 proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyException.java
3
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/ContextInterceptor.java
3
81.25
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/ForwardMessageToDLQActivity.java
3
88.0
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/transaction/EndTransactionActivity.java
3
92.68
 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/LocalTopicRouteService.java
3
0.0
 0.0% test/src/main/java/org/apache/rocketmq/test/util/MQAdminTestUtils.java
4
60.64
 -0.21% broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
4
94.12
 1.12% broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
4
66.87
 -0.02% client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
4
66.67
 -19.05% client/src/main/java/org/apache/rocketmq/client/exception/MQClientException.java
4
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java
4
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java
4
86.67
 proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyContext.java
4
77.78
 proxy/src/main/java/org/apache/rocketmq/proxy/processor/AbstractProcessor.java
4
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ClusterProxyRelayService.java
4
60.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/RelayData.java
4
90.48
 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteService.java
4
85.71
 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/AbstractTransactionService.java
4
60.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/EndTransactionRequestData.java
5
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerRunningInfoRequestHeader.java
5
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerStatusRequestHeader.java
5
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java
5
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java
5
34.48
 -4.65% common/src/main/java/org/apache/rocketmq/common/subscription/ExponentialRetryPolicy.java
5
78.26
 proxy/src/main/java/org/apache/rocketmq/proxy/config/Configuration.java
5
77.27
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcProxyException.java
5
16.67
 proxy/src/main/java/org/apache/rocketmq/proxy/processor/MessagingProcessor.java
5
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManagerFactory.java
5
76.19
 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/AddressableMessageQueue.java
6
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/CloneGroupOffsetRequestHeader.java
6
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java
6
0.0
 common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolQueueSizeMonitor.java
6
33.33
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/PopMessageResultFilterImpl.java
6
57.14
 proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyRelayResult.java
6
72.73
 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ClusterTopicRouteService.java
6
53.85
 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteHelper.java
7
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/AckMessageRequestHeader.java
7
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/CheckTransactionStateRequestHeader.java
7
36.36
 proxy/src/main/java/org/apache/rocketmq/proxy/common/AbstractCacheLoader.java
7
68.18
 proxy/src/main/java/org/apache/rocketmq/proxy/common/Address.java
7
87.5
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcValidator.java
7
65.0
 proxy/src/main/java/org/apache/rocketmq/proxy/processor/TransactionProcessor.java
8
30.76
 0.11% client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
8
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/ChangeInvisibleTimeRequestHeader.java
8
33.33
 proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ExceptionUtils.java
8
73.33
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseWriter.java
8
94.24
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java
8
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/LocalMetadataService.java
8
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/LocalTransactionService.java
9
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/ConsumeMessageDirectlyResultRequestHeader.java
9
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/ConsumerSendMsgBackRequestHeader.java
9
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/EndTransactionRequestHeader.java
10
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateAccessConfigRequestHeader.java
10
88.64
 proxy/src/main/java/org/apache/rocketmq/proxy/processor/ProducerProcessor.java
11
62.07
 proxy/src/main/java/org/apache/rocketmq/proxy/common/ReceiptHandleGroup.java
11
76.09
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseBuilder.java
11
85.14
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageResponseStreamWriter.java
11
82.81
 proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/ClusterMetadataService.java
12
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java
12
0.0
 common/src/main/java/org/apache/rocketmq/common/utils/BinaryUtil.java
12
33.33
 proxy/src/main/java/org/apache/rocketmq/proxy/ProxyMode.java
12
82.35
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/AckMessageActivity.java
13
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/PopMessageRequestHeader.java
13
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java
13
51.85
 proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationChannel.java
13
82.43
 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionDataManager.java
14
40.16
 -5.21% common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
14
17.65
 proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/AbstractProxyRelayService.java
15
30.0
 -3.6% common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java
15
59.46
 proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/ChannelManager.java
16
27.27
 proxy/src/main/java/org/apache/rocketmq/proxy/common/AbstractStartAndShutdown.java
16
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/HeaderInterceptor.java
16
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/RequestMapping.java
16
71.93
 proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyChannel.java
17
84.82
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java
17
76.06
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity.java
17
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/processor/ClientProcessor.java
17
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/ProxyClientRemotingProcessor.java
19
51.28
 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionData.java
21
41.67
 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ProxyTopicRouteData.java
25
46.81
 proxy/src/main/java/org/apache/rocketmq/proxy/common/MessageReceiptHandle.java
25
87.24
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java
26
40.91
 proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannel.java
28
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/LocalServiceManager.java
28
79.56
 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/ClusterTransactionService.java
29
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/DefaultGrpcMessingActivity.java
30
69.7
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManager.java
32
40.74
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java
34
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/AuthenticationInterceptor.java
35
65.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueSelector.java
37
0.0
 common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolWrapper.java
39
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIFactory.java
40
9.09
 proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannelHandlerContext.java
43
65.87
 proxy/src/main/java/org/apache/rocketmq/proxy/processor/ReceiptHandleProcessor.java
43
78.28
 proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalMessageService.java
45
0.0
 acl/src/main/java/org/apache/rocketmq/acl/common/AuthorizationHeader.java
47
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java
48
0.0
 common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolMonitor.java
49
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/GlobalExceptionInterceptor.java
49
25.76
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java
50
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/service/message/ClusterMessageService.java
55
70.74
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java
59
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java
65
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java
67
60.2
 -21.46% acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessResource.java
72
0.0
 0.0% common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java
77
0.0
 proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java
80
0.0
 common/src/main/java/org/apache/rocketmq/common/consumer/ReceiptHandle.java
85
0.0
 acl/src/main/java/org/apache/rocketmq/acl/common/AuthenticationHeader.java
123
39.11
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
143
35.59
 proxy/src/main/java/org/apache/rocketmq/proxy/processor/ConsumerProcessor.java
165
43.49
 proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java
188
48.07
 proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java

Uncovered Existing Lines

Lines Coverage ∆ File
1
72.6
 -1.37% client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceLitePullImpl.java
2
78.57
 -15.87% acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessValidator.java
2
51.55
 -0.25% client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
2
90.48
 -0.95% client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
2
62.01
 -0.08% store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
3
51.49
 2.24% common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java
Jobs
ID Job ID Ran Files Coverage
1 7548.1 1042
48.11
 Travis Job 7548.1
2 7548.2 1042
48.1
 Travis Job 7548.2
Source Files on build 7548