apache / rocketmq / 7470
48%
develop: 49%

LAST BUILD BRANCH: 4.9.x
DEFAULT BRANCH: develop
Ran
Jobs 2
Files 1027
Run time 8min
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
7470

Pull #4225

travis-ci-com

zhouxiang 
[ISSUE #3949] Refine README
Pull Request #4225: [ISSUE #3949] Support gRPC protocol

5518 of 5518 new or added lines in 154 files covered. (100.0%)

29666 of 62385 relevant lines covered (47.55%)

0.95 hits per line

New Missed Lines in Diff

Lines Coverage ∆ File
1
84.62
 -10.84% acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessValidator.java
1
69.37
 5.41% 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
91.67
 acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionChecker.java
2
92.68
 -0.25% broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
2
49.55
 -1.25% 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
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
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
0.0
 common/src/main/java/org/apache/rocketmq/common/rpchook/StreamTypeRPCHook.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
75.86
 42.86% broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.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
77.27
 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
6
66.87
 0.66% client/src/main/java/org/apache/rocketmq/client/ClientConfig.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
71.43
 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/AddressableMessageQueue.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
65.0
 proxy/src/main/java/org/apache/rocketmq/proxy/processor/TransactionProcessor.java
8
31.01
 0.23% 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
86.21
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcValidator.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
0.0
 0.0% 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
0.0
 0.0% 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
76.47
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity.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
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
88.71
 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.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
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
42
66.13
 proxy/src/main/java/org/apache/rocketmq/proxy/processor/ReceiptHandleProcessor.java
43
78.71
 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
56
70.68
 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
58.64
 -21.36% acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessResource.java
70
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
180
44.1
 proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java

Uncovered Existing Lines

Lines Coverage ∆ File
1
53.1
 -0.24% broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java
1
72.6
 -1.37% client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceLitePullImpl.java
1
47.22
 -1.39% remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java
1
71.28
 -0.51% store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAClient.java
1
55.52
 -0.28% store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
2
51.99
 -0.25% client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
2
87.13
 -0.99% client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
3
49.55
 -1.25% broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
6
34.48
 -20.69% broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopRequest.java
9
76.67
 -1.54% client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
12
53.39
 -1.66% client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
Jobs
ID Job ID Ran Files Coverage
1 7470.1 1027
47.53
 Travis Job 7470.1
2 7470.2 1027
47.63
 Travis Job 7470.2
Source Files on build 7470