7460
49%

Ran 13 Jul 2022 08:44AM UTC

Jobs 2

Files 920

Run time 2min

Badge

Embed ▾

pending completion

Build # 7460

Build Type

push

travis-ci-com

Committed by GitHub

Commit Message

Merge pull request #4578 from apache/develop-merge-5.0.0

The code of 5.0.0-beta merge into develop branch

Run Details

18342 of 18342 new or added lines in 357 files covered. (100.0%)

27461 of 57654 relevant lines covered (47.63%)

0.95 hits per line

New Missed Lines in Diff

Lines	Coverage	File
1	100.0	broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
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/plugin/MessageStorePluginContext.java
1	100.0	broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageCheckService.java
1	100.0	broker/src/main/java/org/apache/rocketmq/broker/util/MsgUtil.java
1	100.0	client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
1	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
1	100.0	client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/TopicAttributes.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/attribute/BooleanAttribute.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/attribute/EnumAttribute.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/attribute/LongRangeAttribute.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/constant/ConsumeInitMode.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/constant/PermName.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/message/MessageRequestMode.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeRequestHeader.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetTopicStatsInfoRequestHeader.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoRequestHeader.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientHook.java
1	100.0	common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java
1	100.0	container/src/main/java/org/apache/rocketmq/container/BrokerContainerConfig.java
1	100.0	logging/src/main/java/org/apache/rocketmq/logging/inner/SysLogger.java
1	100.0	namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java
1	100.0	remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java
1	100.0	store/src/main/java/org/apache/rocketmq/store/ConsumeQueueExt.java
1	100.0	store/src/main/java/org/apache/rocketmq/store/PutMessageContext.java
1	100.0	store/src/main/java/org/apache/rocketmq/store/QueryMessageResult.java
1	100.0	store/src/main/java/org/apache/rocketmq/store/SelectMappedBufferResult.java
1	100.0	store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
1	100.0	store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java
1	100.0	store/src/main/java/org/apache/rocketmq/store/stats/BrokerStats.java
1	100.0	test/src/main/java/org/apache/rocketmq/test/listener/AbstractListener.java
1	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java
1	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java
2	100.0	broker/src/main/java/org/apache/rocketmq/broker/longpolling/LmqPullRequestHoldService.java
2	100.0	broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotifyMessageArrivingListener.java
2	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.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/impl/consumer/MessageQueueLock.java
2	100.0	common/src/main/java/org/apache/rocketmq/common/MixAll.java
2	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/CheckClientRequestBody.java
2	100.0	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java
2	100.0	store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java
2	100.0	store/src/main/java/org/apache/rocketmq/store/StoreCheckpoint.java
2	100.0	test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQNormalConsumer.java
2	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/SubCommandException.java
3	100.0	broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
3	100.0	broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
3	100.0	broker/src/main/java/org/apache/rocketmq/broker/loadbalance/MessageRequestModeManager.java
3	100.0	client/src/main/java/org/apache/rocketmq/client/consumer/AckResult.java
3	100.0	client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
3	100.0	client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.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/impl/consumer/RebalanceLitePullImpl.java
3	100.0	client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java
3	100.0	common/src/main/java/org/apache/rocketmq/common/attribute/AttributeParser.java
3	100.0	common/src/main/java/org/apache/rocketmq/common/attribute/CQType.java
3	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerOffsetSerializeWrapper.java
3	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/DeleteSubscriptionGroupRequestHeader.java
3	100.0	common/src/main/java/org/apache/rocketmq/common/rpc/TopicRequestHeader.java
3	100.0	store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java
3	100.0	store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java
3	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/CommandUtil.java
4	100.0	broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
4	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
4	100.0	client/src/main/java/org/apache/rocketmq/client/exception/OffsetNotFoundException.java
4	100.0	client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
4	100.0	common/src/main/java/org/apache/rocketmq/common/ConfigManager.java
4	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/GetBrokerMemberGroupResponseBody.java
4	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchRequestBody.java
4	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryAssignmentResponseBody.java
4	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/UnlockBatchRequestBody.java
4	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetRequestHeader.java
4	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java
4	100.0	common/src/main/java/org/apache/rocketmq/common/utils/ServiceProvider.java
4	100.0	store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java
4	100.0	test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQNormalProducer.java
4	100.0	test/src/main/java/org/apache/rocketmq/test/factory/ConsumerFactory.java
4	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java
4	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java
5	100.0	broker/src/main/java/org/apache/rocketmq/broker/plugin/MessageStoreFactory.java
5	100.0	broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
5	100.0	client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/PopAckConstants.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/attribute/Attribute.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/message/MessageExtBatch.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/GetRemoteClientConfigBody.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/AddBrokerRequestHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetSubscriptionGroupConfigRequestHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetTopicConfigRequestHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/PollingInfoResponseHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryTopicsByConsumerRequestHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/ResetMasterFlushOffsetHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterTopicRequestHeader.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/route/MessageQueueRouteState.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteDatas.java
5	100.0	common/src/main/java/org/apache/rocketmq/common/subscription/GroupRetryPolicy.java
5	100.0	remoting/src/main/java/org/apache/rocketmq/remoting/netty/ResponseFuture.java
5	100.0	store/src/main/java/org/apache/rocketmq/store/queue/CqUnit.java
5	100.0	test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQPopConsumer.java
6	100.0	broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java
6	100.0	client/src/main/java/org/apache/rocketmq/client/consumer/PopResult.java
6	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePullImpl.java
6	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/NotificationResponseHeader.java
6	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerRequestHeader.java
6	100.0	common/src/main/java/org/apache/rocketmq/common/subscription/CustomizedRetryPolicy.java
6	100.0	common/src/main/java/org/apache/rocketmq/common/utils/PositiveAtomicCounter.java
6	100.0	common/src/main/java/org/apache/rocketmq/common/utils/ThreadUtils.java
6	100.0	namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
6	100.0	store/src/main/java/org/apache/rocketmq/store/ha/WaitNotifyObject.java
7	100.0	client/src/main/java/org/apache/rocketmq/client/exception/MQRedirectException.java
7	100.0	common/src/main/java/org/apache/rocketmq/common/AbstractBrokerRunnable.java
7	100.0	common/src/main/java/org/apache/rocketmq/common/KeyBuilder.java
7	100.0	common/src/main/java/org/apache/rocketmq/common/future/FutureTaskExt.java
7	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/ClusterInfo.java
7	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/route/QueueData.java
7	100.0	common/src/main/java/org/apache/rocketmq/common/rpc/RpcRequest.java
8	100.0	acl/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java
8	100.0	broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
8	100.0	broker/src/main/java/org/apache/rocketmq/broker/mqtrace/AbortProcessException.java
8	100.0	common/src/main/java/org/apache/rocketmq/common/ThreadFactoryImpl.java
8	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/TopicQueueMappingSerializeWrapper.java
8	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java
8	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetBrokerMemberGroupRequestHeader.java
8	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/InitConsumerOffsetRequestHeader.java
8	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/QuerySubscriptionByConsumerRequestHeader.java
8	100.0	store/src/main/java/org/apache/rocketmq/store/SelectMappedFileResult.java
8	100.0	tools/src/main/java/org/apache/rocketmq/tools/admin/api/BrokerOperatorResult.java
8	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/consumer/DeleteSubscriptionGroupCommand.java
9	100.0	broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
9	100.0	broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java
9	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java
9	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/RegisterBrokerBody.java
9	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/ConsumeMessageDirectlyResultRequestHeader.java
9	100.0	common/src/main/java/org/apache/rocketmq/common/rpc/RpcException.java
9	100.0	common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemFormatter.java
9	100.0	common/src/main/java/org/apache/rocketmq/common/utils/DataConverter.java
9	100.0	store/src/main/java/org/apache/rocketmq/store/PutMessageResult.java
9	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java
9	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java
10	100.0	broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java
10	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/QuerySubscriptionResponseBody.java
10	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/TopicConfigAndMappingSerializeWrapper.java
10	100.0	common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsKindMeta.java
10	100.0	store/src/main/java/org/apache/rocketmq/store/ha/HAConnectionStateNotificationRequest.java
11	100.0	broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotificationRequest.java
11	100.0	client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
11	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/PopProcessQueueInfo.java
11	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/ChangeInvisibleTimeResponseHeader.java
11	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/ExchangeHAInfoRequestHeader.java
11	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/ExchangeHAInfoResponseHeader.java
11	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/RemoveBrokerRequestHeader.java
11	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateGroupForbiddenRequestHeader.java
11	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/BrokerHeartbeatRequestHeader.java
11	100.0	common/src/main/java/org/apache/rocketmq/common/utils/MessageUtils.java
11	100.0	common/src/main/java/org/apache/rocketmq/common/utils/QueueTypeUtils.java
11	100.0	remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java
11	100.0	store/src/main/java/org/apache/rocketmq/store/queue/QueueOffsetAssigner.java
12	100.0	common/src/main/java/org/apache/rocketmq/common/rpc/RpcRequestHeader.java
12	100.0	tools/src/main/java/org/apache/rocketmq/tools/admin/common/AdminToolsResultCodeEnum.java
12	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java
13	100.0	common/src/main/java/org/apache/rocketmq/common/message/MessageType.java
13	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/PollingInfoRequestHeader.java
13	100.0	common/src/main/java/org/apache/rocketmq/common/subscription/SubscriptionGroupConfig.java
13	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
13	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java
14	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/PeekMessageRequestHeader.java
14	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
14	100.0	common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemPrinter.java
14	100.0	common/src/main/java/org/apache/rocketmq/common/subscription/ExponentialRetryPolicy.java
15	100.0	common/src/main/java/org/apache/rocketmq/common/BrokerSyncInfo.java
15	100.0	common/src/main/java/org/apache/rocketmq/common/fastjson/GenericMapSuperclassDeserializer.java
15	100.0	common/src/main/java/org/apache/rocketmq/common/message/MessageVersion.java
15	100.0	common/src/main/java/org/apache/rocketmq/common/statictopic/TopicConfigAndQueueMapping.java
15	100.0	store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
16	100.0	broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
16	100.0	common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java
16	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryAssignmentRequestBody.java
16	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java
17	100.0	broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
17	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
17	100.0	common/src/main/java/org/apache/rocketmq/common/DataVersion.java
17	100.0	common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java
17	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/NotifyMinBrokerIdChangeRequestHeader.java
17	100.0	common/src/main/java/org/apache/rocketmq/common/statictopic/TopicRemappingDetailWrapper.java
18	100.0	broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
18	100.0	client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
18	100.0	common/src/main/java/org/apache/rocketmq/common/TopicConfig.java
18	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/AckMessageRequestHeader.java
18	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java
18	100.0	logging/src/main/java/org/apache/rocketmq/logging/Slf4jLoggerFactory.java
18	100.0	remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java
19	100.0	broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
19	100.0	broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopRequest.java
19	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java
19	100.0	common/src/main/java/org/apache/rocketmq/common/Configuration.java
19	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/NotificationRequestHeader.java
19	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/StatisticsMessagesRequestHeader.java
19	100.0	common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingInfo.java
19	100.0	common/src/main/java/org/apache/rocketmq/common/statistics/FutureHolder.java
19	100.0	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
19	100.0	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java
20	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerRunningInfo.java
20	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/ChangeInvisibleTimeRequestHeader.java
20	100.0	common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemScheduledPrinter.java
20	100.0	namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java
20	100.0	store/src/main/java/org/apache/rocketmq/store/StoreUtil.java
21	100.0	broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
21	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
21	100.0	common/src/main/java/org/apache/rocketmq/common/rpc/RpcResponse.java
21	100.0	store/src/main/java/org/apache/rocketmq/store/FileQueueSnapshot.java
21	100.0	tools/src/main/java/org/apache/rocketmq/tools/admin/common/AdminToolResult.java
21	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/broker/ResetMasterFlushOffsetSubCommand.java
21	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/container/AddBrokerSubCommand.java
22	100.0	common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientUtils.java
23	100.0	broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
23	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java
23	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/PopMessageResponseHeader.java
23	100.0	common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java
23	100.0	store/src/main/java/org/apache/rocketmq/store/index/IndexService.java
24	100.0	container/src/main/java/org/apache/rocketmq/container/logback/BrokerLogbackConfigurator.java
24	100.0	namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java
25	100.0	common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsBriefInterceptor.java
26	100.0	broker/src/main/java/org/apache/rocketmq/broker/loadbalance/AssignmentManager.java
26	100.0	common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java
27	100.0	common/src/main/java/org/apache/rocketmq/common/statictopic/LogicQueueMappingItem.java
28	100.0	common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingContext.java
28	100.0	store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
29	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/BrokerMemberGroup.java
29	100.0	common/src/main/java/org/apache/rocketmq/common/rpc/RequestBuilder.java
29	100.0	common/src/main/java/org/apache/rocketmq/common/subscription/GroupForbidden.java
31	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java
31	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java
31	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/container/RemoveBrokerSubCommand.java
32	100.0	store/src/main/java/org/apache/rocketmq/store/pop/AckMsg.java
34	100.0	store/src/main/java/org/apache/rocketmq/store/logfile/DefaultMappedFile.java
35	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java
35	100.0	tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
36	100.0	common/src/main/java/org/apache/rocketmq/common/BrokerIdentity.java
36	100.0	container/src/main/java/org/apache/rocketmq/container/ContainerClientHouseKeepingService.java
37	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java
38	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java
39	100.0	broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
39	100.0	common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingDetail.java
40	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/PopMessageRequestHeader.java
41	100.0	broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
42	100.0	container/src/main/java/org/apache/rocketmq/container/InnerBrokerController.java
44	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/PollingInfoProcessor.java
44	100.0	common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java
45	100.0	broker/src/main/java/org/apache/rocketmq/broker/dledger/DLedgerRoleChangeHandler.java
45	100.0	broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java
45	100.0	store/src/main/java/org/apache/rocketmq/store/ha/HAConnectionStateNotificationService.java
47	100.0	store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java
48	100.0	store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java
52	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java
52	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopRequest.java
52	100.0	store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java
53	100.0	client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
55	100.0	broker/src/main/java/org/apache/rocketmq/broker/util/HookUtils.java
56	100.0	common/src/main/java/org/apache/rocketmq/common/UtilAll.java
56	100.0	store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAClient.java
57	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/body/HARuntimeInfo.java
57	100.0	common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItem.java
59	100.0	common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsManager.java
61	100.0	namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
61	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/consumer/SetConsumeModeSubCommand.java
62	100.0	store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAConnection.java
63	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java
64	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/DefaultPullMessageResultHandler.java
68	100.0	store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java
70	100.0	container/src/main/java/org/apache/rocketmq/container/BrokerContainerStartup.java
71	100.0	container/src/main/java/org/apache/rocketmq/container/BrokerContainer.java
72	100.0	broker/src/main/java/org/apache/rocketmq/broker/plugin/AbstractPluginMessageStore.java
72	100.0	common/src/main/java/org/apache/rocketmq/common/namesrv/DefaultTopAddressing.java
77	100.0	common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsBrief.java
83	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
84	100.0	common/src/main/java/org/apache/rocketmq/common/rpc/ClientMetadata.java
86	100.0	store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java
88	100.0	common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
92	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateStaticTopicSubCommand.java
93	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
93	100.0	tools/src/main/java/org/apache/rocketmq/tools/command/topic/RemappingStaticTopicSubCommand.java
94	100.0	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
96	100.0	store/src/main/java/org/apache/rocketmq/store/queue/BatchConsumeQueue.java
98	100.0	store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
110	100.0	broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java
114	100.0	namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
115	100.0	common/src/main/java/org/apache/rocketmq/common/protocol/header/ExtraInfoUtil.java
124	100.0	common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingUtils.java
124	100.0	common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemScheduledIncrementPrinter.java
124	100.0	store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
131	100.0	broker/src/main/java/org/apache/rocketmq/broker/BrokerPreOnlineService.java
133	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java
137	100.0	container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
150	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java
152	100.0	common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
155	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
156	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopOrderlyService.java
156	100.0	test/src/main/java/org/apache/rocketmq/test/util/MQAdminTestUtils.java
161	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
162	100.0	common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientImpl.java
166	100.0	broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingCleanService.java
169	100.0	client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
183	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
183	100.0	store/src/main/java/org/apache/rocketmq/store/CommitLog.java
188	100.0	broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java
190	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
190	100.0	tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminUtils.java
191	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
196	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java
215	100.0	client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java
246	100.0	broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
263	100.0	broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
276	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
290	100.0	store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
373	100.0	tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
428	100.0	broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java

Jobs

ID	Job ID	Ran	Files	Coverage
1	7460.1	13 Jul 2022 08:44AM UTC	0	47.57	Travis Job 7460.1
2	7460.2	13 Jul 2022 08:45AM UTC	0	47.6	Travis Job 7460.2

apache / rocketmq / 7460
49%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Jobs

Source Files on build 7460

apache / rocketmq / 7460 49%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Jobs

Source Files on build 7460

apache / rocketmq / 7460
49%

README BADGES
x