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

apache / rocketmq / 5875
49%
develop: 49%

Build:
Build:
LAST BUILD BRANCH: 4.9.x
DEFAULT BRANCH: develop
Ran 10 Jan 2022 12:51PM UTC
Jobs 1
Files 679
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
5875

push

travis-ci-com

GitHub
[ISSUE #3708] add CorrectLogicOffsetService to periodically correct min logic offset (#3722)

* [ISSUE #3708] add CorrectLogicOffsetService to periodically correct min logic offset; refactor QueueOffsetAssigner.

* Mock getDiskSpaceWarningLevelRatio and getDiskSpaceCleanForciblyRatio to get around configuration protection in unit-test.

* Fix check style.

88 of 88 new or added lines in 6 files covered. (100.0%)

22461 of 42729 relevant lines covered (52.57%)

0.53 hits per line

New Missed Lines in Diff

Lines Coverage ∆ File
1
100.0
common/src/main/java/org/apache/rocketmq/common/attribute/CQType.java
1
100.0
store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java
2
100.0
store/src/main/java/org/apache/rocketmq/store/queue/QueueOffsetAssigner.java
38
100.0
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java

Uncovered Existing Lines

Lines Coverage ∆ File
1
100.0
store/src/main/java/org/apache/rocketmq/store/MessageStore.java
1
100.0
store/src/main/java/org/apache/rocketmq/store/MultiPathMappedFileQueue.java
2
100.0
broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java
2
100.0
client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
2
100.0
client/src/main/java/org/apache/rocketmq/client/latency/LatencyFaultToleranceImpl.java
2
100.0
store/src/main/java/org/apache/rocketmq/store/config/StorePathConfigHelper.java
3
100.0
acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionManager.java
3
100.0
broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
3
100.0
common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java
3
100.0
store/src/main/java/org/apache/rocketmq/store/SelectMappedBufferResult.java
3
100.0
store/src/main/java/org/apache/rocketmq/store/StoreCheckpoint.java
4
100.0
filter/src/main/java/org/apache/rocketmq/filter/util/BitsArray.java
12
100.0
common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java
12
100.0
store/src/main/java/org/apache/rocketmq/store/AppendMessageResult.java
13
100.0
store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java
13
100.0
store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java
14
100.0
common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java
14
100.0
store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java
21
100.0
acl/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java
21
100.0
store/src/main/java/org/apache/rocketmq/store/StoreUtil.java
23
100.0
common/src/main/java/org/apache/rocketmq/common/TopicConfig.java
24
100.0
common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java
25
100.0
store/src/main/java/org/apache/rocketmq/store/schedule/ScheduleMessageService.java
28
100.0
store/src/main/java/org/apache/rocketmq/store/ConsumeQueueExt.java
37
100.0
common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
42
100.0
common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
46
100.0
store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java
47
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
56
100.0
store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
59
100.0
client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
63
100.0
common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientImpl.java
67
100.0
broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
67
100.0
client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java
70
100.0
common/src/main/java/org/apache/rocketmq/common/UtilAll.java
71
100.0
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java
76
100.0
store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
80
100.0
broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
85
100.0
client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
87
100.0
store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java
90
100.0
client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
132
100.0
broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
155
100.0
store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
161
100.0
client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
212
100.0
store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
236
100.0
store/src/main/java/org/apache/rocketmq/store/CommitLog.java
396
100.0
broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
401
100.0
client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
Jobs
ID Job ID Ran Files Coverage
1 5875.1 10 Jan 2022 12:51PM UTC 0
52.57
Travis Job 5875.1
Source Files on build 5875
  • Tree
  • List 679
  • Changed 64
  • Source Changed 53
  • Coverage Changed 57
Coverage ∆ File Lines Relevant Covered Missed Hits/Line
  • Back to Repo
  • Build #5875
  • 7be401e7 on github
  • Prev Build on 5.0.0-alpha (#5727)
  • Next Build on 5.0.0-alpha (#5891)
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