• Home
  • Features
  • Pricing
  • Docs
  • Announcements
  • Sign In

apache / rocketmq / 7472
48%
develop: 49%

Build:
Build:
LAST BUILD BRANCH: 4.9.x
DEFAULT BRANCH: develop
Ran 13 Jul 2022 03:31PM UTC
Jobs 2
Files 970
Run time 2min
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

pending completion
7472

push

travis-ci-com

RongtongJin
Use ${dledger.version} instead of fixed version in pom file

29067 of 60515 relevant lines covered (48.03%)

0.96 hits per line

Uncovered Existing Lines

Lines Coverage ∆ File
1
100.0
broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
1
100.0
broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageUtil.java
1
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByMachineRoom.java
1
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/store/LocalFileOffsetStore.java
1
100.0
common/src/main/java/org/apache/rocketmq/common/CountDownLatch2.java
1
100.0
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyDecoder.java
1
100.0
store/src/main/java/org/apache/rocketmq/store/logfile/DefaultMappedFile.java
1
100.0
store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
1
100.0
tools/src/main/java/org/apache/rocketmq/tools/command/SubCommand.java
2
100.0
acl/src/main/java/org/apache/rocketmq/acl/common/AclClientRPCHook.java
2
100.0
acl/src/main/java/org/apache/rocketmq/acl/common/AclSigner.java
2
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
2
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueByConfig.java
2
100.0
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyEncoder.java
2
100.0
store/src/main/java/org/apache/rocketmq/store/FlushDiskWatcher.java
2
100.0
store/src/main/java/org/apache/rocketmq/store/ha/HAService.java
3
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
3
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueConsistentHash.java
3
100.0
client/src/main/java/org/apache/rocketmq/client/producer/RequestFutureHolder.java
3
100.0
logging/src/main/java/org/apache/rocketmq/logging/inner/LoggingBuilder.java
3
100.0
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingSerializable.java
3
100.0
store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java
3
100.0
store/src/main/java/org/apache/rocketmq/store/index/IndexHeader.java
4
100.0
acl/src/main/java/org/apache/rocketmq/acl/plain/PlainAccessValidator.java
4
100.0
common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java
4
100.0
filter/src/main/java/org/apache/rocketmq/filter/util/BitsArray.java
4
100.0
tools/src/main/java/org/apache/rocketmq/tools/command/message/PrintMessageSubCommand.java
6
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMachineRoomNearby.java
6
100.0
common/src/main/java/org/apache/rocketmq/common/message/Message.java
6
100.0
controller/src/main/java/org/apache/rocketmq/controller/impl/manager/ReplicasInfoManager.java
6
100.0
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RocketMQSerializable.java
7
100.0
broker/src/main/java/org/apache/rocketmq/broker/processor/EndTransactionProcessor.java
7
100.0
common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoRequestHeader.java
7
100.0
common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateGlobalWhiteAddrsConfigRequestHeader.java
7
100.0
logging/src/main/java/org/apache/rocketmq/logging/inner/Level.java
8
100.0
namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
9
100.0
acl/src/main/java/org/apache/rocketmq/acl/common/SessionCredentials.java
10
100.0
tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerStatusSubCommand.java
11
100.0
store/src/main/java/org/apache/rocketmq/store/ha/autoswitch/EpochFileCache.java
11
100.0
tools/src/main/java/org/apache/rocketmq/tools/command/message/SendMessageCommand.java
12
100.0
tools/src/main/java/org/apache/rocketmq/tools/command/acl/DeleteAccessConfigSubCommand.java
13
100.0
broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingCleanService.java
13
100.0
namesrv/src/main/java/org/apache/rocketmq/namesrv/kvconfig/KVConfigManager.java
14
100.0
tools/src/main/java/org/apache/rocketmq/tools/command/acl/UpdateGlobalWhiteAddrSubCommand.java
15
100.0
filter/src/main/java/org/apache/rocketmq/filter/util/BloomFilter.java
15
100.0
store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java
16
100.0
tools/src/main/java/org/apache/rocketmq/tools/command/acl/GetAccessConfigSubCommand.java
17
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
18
100.0
client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java
18
100.0
common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java
18
100.0
tools/src/main/java/org/apache/rocketmq/tools/command/message/QueryMsgTraceByIdSubCommand.java
20
100.0
common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java
22
100.0
store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
23
100.0
broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
23
100.0
store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java
25
100.0
common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java
28
100.0
broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java
30
100.0
common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java
31
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/DefaultLitePullConsumer.java
32
100.0
common/src/main/java/org/apache/rocketmq/common/utils/ServiceProvider.java
37
100.0
broker/src/main/java/org/apache/rocketmq/broker/plugin/AbstractPluginMessageStore.java
40
100.0
acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionManager.java
40
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
43
100.0
client/src/main/java/org/apache/rocketmq/client/ClientConfig.java
44
100.0
namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
47
100.0
tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
49
100.0
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
51
100.0
broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
51
100.0
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
53
100.0
client/src/main/java/org/apache/rocketmq/client/impl/ClientRemotingProcessor.java
53
100.0
common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
53
100.0
common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
55
100.0
common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeaderV2.java
56
100.0
store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
64
100.0
remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java
65
100.0
common/src/main/java/org/apache/rocketmq/common/MixAll.java
71
100.0
common/src/main/java/org/apache/rocketmq/common/UtilAll.java
72
100.0
broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
79
100.0
client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
82
100.0
tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
83
100.0
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java
83
100.0
store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
128
100.0
remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
158
100.0
store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
193
100.0
store/src/main/java/org/apache/rocketmq/store/CommitLog.java
205
100.0
client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
226
100.0
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
284
100.0
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
336
100.0
tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
532
100.0
client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
538
100.0
broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
Jobs
ID Job ID Ran Files Coverage
1 7472.1 13 Jul 2022 03:32PM UTC 0
47.79
Travis Job 7472.1
2 7472.2 13 Jul 2022 03:31PM UTC 0
47.92
Travis Job 7472.2
Source Files on build 7472
  • Tree
  • List 970
  • Changed 154
  • Source Changed 121
  • Coverage Changed 133
Coverage ∆ File Lines Relevant Covered Missed Hits/Line
  • Back to Repo
  • Build #7472
  • 67a52621 on github
  • Prev Build on 5.0.0-beta-dledger-controller (#7438)
  • Next Build on 5.0.0-beta-dledger-controller (#7480)
STATUS · Troubleshooting · Open an Issue · Sales · Support · CAREERS · ENTERPRISE · START FREE · SCHEDULE DEMO
ANNOUNCEMENTS · TWITTER · TOS & SLA · Supported CI Services · What's a CI service? · Automated Testing

© 2025 Coveralls, Inc