apache / rocketmq / 6113
52%
develop: 49%

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

cron

travis-ci-com

tigerweili 
Merge branch 'develop'

2122 of 2122 new or added lines in 112 files covered. (100.0%)

21922 of 42497 relevant lines covered (51.58%)

1.03 hits per line

New Missed Lines in Diff

Lines Coverage ∆ File
1
100.0
 broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
1
100.0
 broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
1
100.0
 client/src/main/java/org/apache/rocketmq/client/Validators.java
1
100.0
 common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java
1
100.0
 common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
1
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/DeleteTopicFromNamesrvRequestHeader.java
1
100.0
 namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
1
100.0
 store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java
1
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
1
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/broker/CleanUnusedTopicCommand.java
1
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/connection/ConsumerConnectionSubCommand.java
1
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java
1
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/offset/CloneGroupOffsetCommand.java
2
100.0
 acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessValidator.java
2
100.0
 broker/src/main/java/org/apache/rocketmq/broker/filter/MessageEvaluationContext.java
2
100.0
 client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
2
100.0
 client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
2
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
2
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
2
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
2
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
2
100.0
 common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java
2
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RocketMQSerializable.java
2
100.0
 tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
2
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/broker/BrokerConsumeStatsSubCommad.java
3
100.0
 broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
3
100.0
 broker/src/main/java/org/apache/rocketmq/broker/subscription/LmqSubscriptionGroupManager.java
3
100.0
 broker/src/main/java/org/apache/rocketmq/broker/topic/LmqTopicConfigManager.java
3
100.0
 broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
3
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/body/ClusterAclVersionInfo.java
3
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/GetBrokerAclConfigResponseHeader.java
3
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java
3
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
3
100.0
 test/src/main/java/org/apache/rocketmq/test/message/MessageQueueMsg.java
3
100.0
 test/src/main/java/org/apache/rocketmq/test/util/FileUtil.java
3
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportConfigsCommand.java
3
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/queue/QueryConsumeQueueCommand.java
3
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/topic/TopicListSubCommand.java
4
100.0
 client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
4
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
4
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java
4
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
4
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerRunningInfo.java
4
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java
4
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java
4
100.0
 test/src/main/java/org/apache/rocketmq/test/util/MQAdmin.java
5
100.0
 broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
5
100.0
 broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
5
100.0
 client/src/main/java/org/apache/rocketmq/client/producer/RequestFutureHolder.java
5
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java
5
100.0
 store/src/main/java/org/apache/rocketmq/store/CommitLog.java
5
100.0
 store/src/main/java/org/apache/rocketmq/store/FlushDiskWatcher.java
5
100.0
 store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
5
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java
6
100.0
 broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
6
100.0
 client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByMachineRoom.java
6
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
6
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java
6
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/stats/StatsAllSubCommand.java
7
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java
7
100.0
 store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
7
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/HAConnection.java
8
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
9
100.0
 common/src/main/java/org/apache/rocketmq/common/Configuration.java
10
100.0
 store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
12
100.0
 common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
12
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/acl/ClusterAclConfigVersionListSubCommand.java
16
100.0
 broker/src/main/java/org/apache/rocketmq/broker/offset/LmqConsumerOffsetManager.java
17
100.0
 store/src/main/java/org/apache/rocketmq/store/MultiDispatch.java
22
100.0
 broker/src/main/java/org/apache/rocketmq/broker/longpolling/LmqPullRequestHoldService.java
22
100.0
 store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
28
100.0
 store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
29
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
30
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataCommand.java
44
100.0
 acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionManager.java
52
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/offset/SkipAccumulationSubCommand.java
57
100.0
 store/src/main/java/org/apache/rocketmq/store/stats/LmqBrokerStatsManager.java
58
100.0
 broker/src/main/java/org/apache/rocketmq/broker/plugin/AbstractPluginMessageStore.java
82
100.0
 store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
90
100.0
 test/src/main/java/org/apache/rocketmq/test/lmq/benchmark/BenchLmqStore.java
231
100.0
 test/src/main/java/org/apache/rocketmq/test/util/StatUtil.java

Uncovered Existing Lines

Lines Coverage ∆ File
1
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/body/RegisterBrokerBody.java
1
100.0
 filter/src/main/java/org/apache/rocketmq/filter/util/BloomFilter.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/producer/RequestFutureHolder.java
2
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/WaitNotifyObject.java
3
100.0
 client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
3
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RocketMQSerializable.java
3
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/connection/ConsumerConnectionSubCommand.java
4
100.0
 broker/src/main/java/org/apache/rocketmq/broker/filter/MessageEvaluationContext.java
4
100.0
 common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java
4
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/exception/RemotingConnectException.java
5
100.0
 common/src/main/java/org/apache/rocketmq/common/message/MessageClientIDSetter.java
5
100.0
 logging/src/main/java/org/apache/rocketmq/logging/inner/LoggingEvent.java
5
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/namesrv/GetNamesrvConfigCommand.java
6
100.0
 client/src/main/java/org/apache/rocketmq/client/Validators.java
8
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/body/ClusterAclVersionInfo.java
8
100.0
 test/src/main/java/org/apache/rocketmq/test/message/MessageQueueMsg.java
9
100.0
 client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByMachineRoom.java
10
100.0
 client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMachineRoomNearby.java
10
100.0
 client/src/main/java/org/apache/rocketmq/client/MQHelper.java
10
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java
11
100.0
 client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java
11
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
12
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/CommandUtil.java
13
100.0
 broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
13
100.0
 client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
13
100.0
 common/src/main/java/org/apache/rocketmq/common/protocol/header/GetBrokerAclConfigResponseHeader.java
13
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/acl/ClusterAclConfigVersionListSubCommand.java
14
100.0
 openmessaging/src/main/java/io/openmessaging/rocketmq/utils/BeanUtils.java
14
100.0
 store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
16
100.0
 acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionManager.java
18
100.0
 test/src/main/java/org/apache/rocketmq/test/util/FileUtil.java
18
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportConfigsCommand.java
20
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/consumer/GetConsumerConfigSubCommand.java
21
100.0
 broker/src/main/java/org/apache/rocketmq/broker/filter/ConsumerFilterManager.java
22
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java
23
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
23
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyServerConfig.java
24
100.0
 store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
25
100.0
 test/src/main/java/org/apache/rocketmq/test/util/MQAdmin.java
25
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/export/ExportMetadataCommand.java
29
100.0
 client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
31
100.0
 broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
32
100.0
 broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
34
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
35
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java
38
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java
40
100.0
 store/src/main/java/org/apache/rocketmq/store/ha/HAConnection.java
42
100.0
 client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
42
100.0
 client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
43
100.0
 tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
45
100.0
 client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
45
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java
46
100.0
 store/src/main/java/org/apache/rocketmq/store/MappedFile.java
50
100.0
 common/src/main/java/org/apache/rocketmq/common/MixAll.java
51
100.0
 broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
52
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/consumer/ProcessQueue.java
58
100.0
 common/src/main/java/org/apache/rocketmq/common/UtilAll.java
64
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
64
100.0
 store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
67
100.0
 common/src/main/java/org/apache/rocketmq/common/Configuration.java
75
100.0
 store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
76
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
80
100.0
 store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
86
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
87
100.0
 tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
98
100.0
 remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
104
100.0
 broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
110
100.0
 store/src/main/java/org/apache/rocketmq/store/CommitLog.java
122
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
145
100.0
 common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
171
100.0
 broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
244
100.0
 store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
253
100.0
 broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
259
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
488
100.0
 client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
Jobs
ID Job ID Ran Files Coverage
1 6113.1 0
51.52
 Travis Job 6113.1
2 6113.2 0
51.41
 Travis Job 6113.2
Source Files on build 6113