7450
48%
develop: 49%

Ran 13 Jul 2022 01:46AM UTC

Jobs 2

Files 920

Run time 51s

Badge

Embed ▾

pending completion

Build # 7450

Build Type

Pull #4578

travis-ci-com

Committed by RongtongJin

Commit Message

Remove useless variables in PullMessageProcessor

Pull Request Pull Request #4578: 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%)

27506 of 57654 relevant lines covered (47.71%)

0.95 hits per line

New Missed Lines in Diff

Lines	Coverage	∆	File
1	3.11	0.0%	broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
1	0.0	0.0%	broker/src/main/java/org/apache/rocketmq/broker/longpolling/ManyPullRequest.java
1	63.64	-6.36%	broker/src/main/java/org/apache/rocketmq/broker/plugin/MessageStorePluginContext.java
1	95.0	-5.0%	broker/src/main/java/org/apache/rocketmq/broker/transaction/TransactionalMessageCheckService.java
1	66.67		broker/src/main/java/org/apache/rocketmq/broker/util/MsgUtil.java
1	79.28	-1.8%	client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
1	61.4	-0.22%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
1	58.29	0.2%	client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
1	90.0		common/src/main/java/org/apache/rocketmq/common/TopicAttributes.java
1	90.91	-9.09%	common/src/main/java/org/apache/rocketmq/common/admin/TopicOffset.java
1	87.5		common/src/main/java/org/apache/rocketmq/common/attribute/BooleanAttribute.java
1	87.5		common/src/main/java/org/apache/rocketmq/common/attribute/EnumAttribute.java
1	90.0		common/src/main/java/org/apache/rocketmq/common/attribute/LongRangeAttribute.java
1	0.0		common/src/main/java/org/apache/rocketmq/common/constant/ConsumeInitMode.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/constant/PermName.java
1	85.71		common/src/main/java/org/apache/rocketmq/common/message/MessageRequestMode.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetEarliestMsgStoretimeRequestHeader.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetTopicStatsInfoRequestHeader.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/SearchOffsetRequestHeader.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageRequestHeader.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateConsumerOffsetRequestHeader.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/GetRouteInfoRequestHeader.java
1	0.0		common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientHook.java
1	50.0	-2.38%	common/src/main/java/org/apache/rocketmq/common/sysflag/PullSysFlag.java
1	95.24		container/src/main/java/org/apache/rocketmq/container/BrokerContainerConfig.java
1	42.86	0.0%	logging/src/main/java/org/apache/rocketmq/logging/inner/SysLogger.java
1	72.73	0.0%	namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/BrokerHousekeepingService.java
1	14.81	0.66%	remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingUtil.java
1	77.97	0.1%	store/src/main/java/org/apache/rocketmq/store/ConsumeQueueExt.java
1	90.0		store/src/main/java/org/apache/rocketmq/store/PutMessageContext.java
1	0.0	0.0%	store/src/main/java/org/apache/rocketmq/store/QueryMessageResult.java
1	77.78	-3.47%	store/src/main/java/org/apache/rocketmq/store/SelectMappedBufferResult.java
1	56.08	13.22%	store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
1	85.09	-0.37%	store/src/main/java/org/apache/rocketmq/store/index/IndexFile.java
1	0.0	0.0%	store/src/main/java/org/apache/rocketmq/store/stats/BrokerStats.java
1	0.0	0.0%	test/src/main/java/org/apache/rocketmq/test/listener/AbstractListener.java
1	0.0	0.0%	tools/src/main/java/org/apache/rocketmq/tools/command/cluster/CLusterSendMsgRTCommand.java
1	27.27	0.0%	tools/src/main/java/org/apache/rocketmq/tools/command/topic/DeleteTopicSubCommand.java
2	0.0	0.0%	broker/src/main/java/org/apache/rocketmq/broker/longpolling/LmqPullRequestHoldService.java
2	55.56	-4.44%	broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotifyMessageArrivingListener.java
2	65.54	0.2%	broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java
2	55.09	-0.31%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
2	87.5	-1.39%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/MessageQueueLock.java
2	54.3	-0.29%	common/src/main/java/org/apache/rocketmq/common/MixAll.java
2	84.62	-15.38%	common/src/main/java/org/apache/rocketmq/common/protocol/body/CheckClientRequestBody.java
2	52.38	4.17%	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyClientConfig.java
2	54.17	-1.32%	store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java
2	89.66	-2.5%	store/src/main/java/org/apache/rocketmq/store/StoreCheckpoint.java
2	0.0	0.0%	test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQNormalConsumer.java
2	0.0	0.0%	tools/src/main/java/org/apache/rocketmq/tools/command/SubCommandException.java
3	63.96	6.69%	broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupInfo.java
3	79.83	-1.08%	broker/src/main/java/org/apache/rocketmq/broker/client/ProducerManager.java
3	90.0		broker/src/main/java/org/apache/rocketmq/broker/loadbalance/MessageRequestModeManager.java
3	72.73		client/src/main/java/org/apache/rocketmq/client/consumer/AckResult.java
3	33.33	-0.6%	client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
3	80.0	-13.33%	client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragely.java
3	73.33	-16.67%	client/src/main/java/org/apache/rocketmq/client/consumer/rebalance/AllocateMessageQueueAveragelyByCircle.java
3	72.6	-2.4%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceLitePullImpl.java
3	69.39	-4.53%	client/src/main/java/org/apache/rocketmq/client/producer/SendResult.java
3	90.32		common/src/main/java/org/apache/rocketmq/common/attribute/AttributeParser.java
3	0.0		common/src/main/java/org/apache/rocketmq/common/attribute/CQType.java
3	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerOffsetSerializeWrapper.java
3	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/DeleteSubscriptionGroupRequestHeader.java
3	25.0		common/src/main/java/org/apache/rocketmq/common/rpc/TopicRequestHeader.java
3	72.88	1.14%	store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java
3	95.08		store/src/main/java/org/apache/rocketmq/store/ha/GroupTransferService.java
3	86.54	4.4%	store/src/main/java/org/apache/rocketmq/store/ha/WaitNotifyObject.java
3	50.0	0.0%	tools/src/main/java/org/apache/rocketmq/tools/command/CommandUtil.java
4	27.78	-3.47%	broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
4	7.14	0.0%	broker/src/main/java/org/apache/rocketmq/broker/processor/QueryMessageProcessor.java
4	33.33		client/src/main/java/org/apache/rocketmq/client/exception/OffsetNotFoundException.java
4	51.55	-0.06%	client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
4	67.57	-8.19%	common/src/main/java/org/apache/rocketmq/common/ConfigManager.java
4	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/body/GetBrokerMemberGroupResponseBody.java
4	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchRequestBody.java
4	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryAssignmentResponseBody.java
4	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/body/UnlockBatchRequestBody.java
4	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryConsumerOffsetRequestHeader.java
4	46.15	-0.72%	common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java
4	0.0		common/src/main/java/org/apache/rocketmq/common/utils/ServiceProvider.java
4	72.84	2.69%	store/src/main/java/org/apache/rocketmq/store/DispatchRequest.java
4	0.0	0.0%	test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQNormalProducer.java
4	0.0	0.0%	test/src/main/java/org/apache/rocketmq/test/factory/ConsumerFactory.java
4	62.0	1.13%	tools/src/main/java/org/apache/rocketmq/tools/command/broker/UpdateBrokerConfigSubCommand.java
4	32.38	0.75%	tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateTopicSubCommand.java
5	21.43	-1.65%	broker/src/main/java/org/apache/rocketmq/broker/plugin/MessageStoreFactory.java
5	90.78	20.19%	broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
5	27.78	-10.68%	client/src/main/java/org/apache/rocketmq/client/exception/MQBrokerException.java
5	0.0		common/src/main/java/org/apache/rocketmq/common/PopAckConstants.java
5	50.0		common/src/main/java/org/apache/rocketmq/common/attribute/Attribute.java
5	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/message/MessageExtBatch.java
5	67.27	-6.73%	common/src/main/java/org/apache/rocketmq/common/message/MessageQueue.java
5	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/body/GetRemoteClientConfigBody.java
5	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/AddBrokerRequestHeader.java
5	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMaxOffsetRequestHeader.java
5	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/GetSubscriptionGroupConfigRequestHeader.java
5	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/GetTopicConfigRequestHeader.java
5	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/PollingInfoResponseHeader.java
5	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/QueryTopicsByConsumerRequestHeader.java
5	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/ResetMasterFlushOffsetHeader.java
5	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterTopicRequestHeader.java
5	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/route/MessageQueueRouteState.java
5	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteDatas.java
5	80.77		common/src/main/java/org/apache/rocketmq/common/subscription/GroupRetryPolicy.java
5	83.67	-8.83%	remoting/src/main/java/org/apache/rocketmq/remoting/netty/ResponseFuture.java
5	82.76		store/src/main/java/org/apache/rocketmq/store/queue/CqUnit.java
5	0.0		test/src/main/java/org/apache/rocketmq/test/client/rmq/RMQPopConsumer.java
6	75.61	-2.77%	broker/src/main/java/org/apache/rocketmq/broker/transaction/AbstractTransactionalMessageCheckListener.java
6	71.43		client/src/main/java/org/apache/rocketmq/client/consumer/PopResult.java
6	19.23	-4.58%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePullImpl.java
6	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/NotificationResponseHeader.java
6	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/RegisterBrokerRequestHeader.java
6	81.25		common/src/main/java/org/apache/rocketmq/common/subscription/CustomizedRetryPolicy.java
6	0.0		common/src/main/java/org/apache/rocketmq/common/utils/PositiveAtomicCounter.java
6	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/utils/ThreadUtils.java
6	23.08	-0.61%	namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
7	0.0		client/src/main/java/org/apache/rocketmq/client/exception/MQRedirectException.java
7	0.0		common/src/main/java/org/apache/rocketmq/common/AbstractBrokerRunnable.java
7	0.0		common/src/main/java/org/apache/rocketmq/common/KeyBuilder.java
7	0.0		common/src/main/java/org/apache/rocketmq/common/future/FutureTaskExt.java
7	70.83	-29.17%	common/src/main/java/org/apache/rocketmq/common/protocol/body/ClusterInfo.java
7	52.73	-6.85%	common/src/main/java/org/apache/rocketmq/common/protocol/route/QueueData.java
7	0.0		common/src/main/java/org/apache/rocketmq/common/rpc/RpcRequest.java
8	83.23	-3.1%	acl/src/main/java/org/apache/rocketmq/acl/common/AclUtils.java
8	69.57	-4.12%	broker/src/main/java/org/apache/rocketmq/broker/latency/BrokerFastFailure.java
8	42.86		broker/src/main/java/org/apache/rocketmq/broker/mqtrace/AbortProcessException.java
8	55.56	-44.44%	common/src/main/java/org/apache/rocketmq/common/ThreadFactoryImpl.java
8	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/body/TopicQueueMappingSerializeWrapper.java
8	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/CreateTopicRequestHeader.java
8	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/GetBrokerMemberGroupRequestHeader.java
8	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/InitConsumerOffsetRequestHeader.java
8	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/QuerySubscriptionByConsumerRequestHeader.java
8	0.0		store/src/main/java/org/apache/rocketmq/store/SelectMappedFileResult.java
8	0.0		tools/src/main/java/org/apache/rocketmq/tools/admin/api/BrokerOperatorResult.java
8	0.0	0.0%	tools/src/main/java/org/apache/rocketmq/tools/command/consumer/DeleteSubscriptionGroupCommand.java
9	33.0	0.78%	broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
9	62.63	9.29%	broker/src/main/java/org/apache/rocketmq/broker/mqtrace/SendMessageContext.java
9	38.38	-0.24%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java
9	85.32	-7.07%	common/src/main/java/org/apache/rocketmq/common/protocol/body/RegisterBrokerBody.java
9	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/ConsumeMessageDirectlyResultRequestHeader.java
9	0.0		common/src/main/java/org/apache/rocketmq/common/rpc/RpcException.java
9	0.0		common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemFormatter.java
9	0.0		common/src/main/java/org/apache/rocketmq/common/utils/DataConverter.java
9	47.83	-35.51%	store/src/main/java/org/apache/rocketmq/store/PutMessageResult.java
9	56.0	-4.0%	tools/src/main/java/org/apache/rocketmq/tools/command/broker/GetBrokerConfigCommand.java
9	0.0	-34.23%	tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java
10	48.57	9.44%	broker/src/main/java/org/apache/rocketmq/broker/mqtrace/ConsumeMessageContext.java
10	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/body/QuerySubscriptionResponseBody.java
10	47.37		common/src/main/java/org/apache/rocketmq/common/protocol/body/TopicConfigAndMappingSerializeWrapper.java
10	0.0		common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsKindMeta.java
10	0.0		store/src/main/java/org/apache/rocketmq/store/ha/HAConnectionStateNotificationRequest.java
11	0.0		broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotificationRequest.java
11	58.56	-0.35%	client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
11	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/body/PopProcessQueueInfo.java
11	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/ChangeInvisibleTimeResponseHeader.java
11	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/ExchangeHAInfoRequestHeader.java
11	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/ExchangeHAInfoResponseHeader.java
11	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/RemoveBrokerRequestHeader.java
11	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/UpdateGroupForbiddenRequestHeader.java
11	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/namesrv/BrokerHeartbeatRequestHeader.java
11	0.0		common/src/main/java/org/apache/rocketmq/common/utils/MessageUtils.java
11	0.0		common/src/main/java/org/apache/rocketmq/common/utils/QueueTypeUtils.java
11	75.0	-2.66%	remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingCommand.java
11	63.33		store/src/main/java/org/apache/rocketmq/store/queue/QueueOffsetAssigner.java
12	7.69		common/src/main/java/org/apache/rocketmq/common/rpc/RpcRequestHeader.java
12	0.0		tools/src/main/java/org/apache/rocketmq/tools/admin/common/AdminToolsResultCodeEnum.java
12	64.63	-6.55%	tools/src/main/java/org/apache/rocketmq/tools/command/offset/ResetOffsetByTimeCommand.java
13	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/message/MessageType.java
13	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/PollingInfoRequestHeader.java
13	61.9	15.75%	common/src/main/java/org/apache/rocketmq/common/subscription/SubscriptionGroupConfig.java
13	0.0	0.0%	tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
13	0.0	0.0%	tools/src/main/java/org/apache/rocketmq/tools/command/consumer/UpdateSubGroupSubCommand.java
14	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/PeekMessageRequestHeader.java
14	45.37	0.93%	common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
14	0.0		common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemPrinter.java
14	39.13		common/src/main/java/org/apache/rocketmq/common/subscription/ExponentialRetryPolicy.java
15	0.0		common/src/main/java/org/apache/rocketmq/common/BrokerSyncInfo.java
15	0.0		common/src/main/java/org/apache/rocketmq/common/fastjson/GenericMapSuperclassDeserializer.java
15	0.0		common/src/main/java/org/apache/rocketmq/common/message/MessageVersion.java
15	21.05		common/src/main/java/org/apache/rocketmq/common/statictopic/TopicConfigAndQueueMapping.java
15	86.97	3.01%	store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
16	14.41	-1.05%	broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
16	56.31	-10.36%	common/src/main/java/org/apache/rocketmq/common/message/MessageExt.java
16	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/body/QueryAssignmentRequestBody.java
16	45.0	-1.88%	common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java
17	35.76	12.62%	broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
17	53.85	-21.71%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
17	45.76	-8.52%	common/src/main/java/org/apache/rocketmq/common/DataVersion.java
17	0.0		common/src/main/java/org/apache/rocketmq/common/TopicQueueId.java
17	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/NotifyMinBrokerIdChangeRequestHeader.java
17	45.16		common/src/main/java/org/apache/rocketmq/common/statictopic/TopicRemappingDetailWrapper.java
18	65.88		broker/src/main/java/org/apache/rocketmq/broker/schedule/ScheduleMessageService.java
18	4.93	-0.16%	client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
18	64.66	20.34%	common/src/main/java/org/apache/rocketmq/common/TopicConfig.java
18	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/AckMessageRequestHeader.java
18	38.71	-8.91%	common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java
18	57.75	1.98%	logging/src/main/java/org/apache/rocketmq/logging/Slf4jLoggerFactory.java
18	24.32	-3.15%	remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java
19	8.33	2.0%	broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
19	34.48		broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopRequest.java
19	54.92	-8.63%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java
19	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/Configuration.java
19	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/NotificationRequestHeader.java
19	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/StatisticsMessagesRequestHeader.java
19	62.75		common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingInfo.java
19	0.0		common/src/main/java/org/apache/rocketmq/common/statistics/FutureHolder.java
19	59.86	1.46%	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
19	71.04	2.8%	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingServer.java
20	31.88	-0.97%	common/src/main/java/org/apache/rocketmq/common/protocol/body/ConsumerRunningInfo.java
20	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/ChangeInvisibleTimeRequestHeader.java
20	0.0		common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemScheduledPrinter.java
20	50.0		namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/ClientRequestProcessor.java
20	25.0	-60.71%	store/src/main/java/org/apache/rocketmq/store/StoreUtil.java
21	20.79	-3.3%	broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
21	28.71	-2.47%	broker/src/main/java/org/apache/rocketmq/broker/processor/ClientManageProcessor.java
21	0.0		common/src/main/java/org/apache/rocketmq/common/rpc/RpcResponse.java
21	0.0		store/src/main/java/org/apache/rocketmq/store/FileQueueSnapshot.java
21	0.0		tools/src/main/java/org/apache/rocketmq/tools/admin/common/AdminToolResult.java
21	0.0		tools/src/main/java/org/apache/rocketmq/tools/command/broker/ResetMasterFlushOffsetSubCommand.java
21	0.0		tools/src/main/java/org/apache/rocketmq/tools/command/container/AddBrokerSubCommand.java
22	0.0		common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientUtils.java
23	49.06	-28.22%	broker/src/main/java/org/apache/rocketmq/broker/client/DefaultConsumerIdsChangeListener.java
23	0.0		client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopProcessQueue.java
23	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/PopMessageResponseHeader.java
23	28.13		common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingOne.java
23	67.0	-0.2%	store/src/main/java/org/apache/rocketmq/store/index/IndexService.java
24	74.74		container/src/main/java/org/apache/rocketmq/container/logback/BrokerLogbackConfigurator.java
24	66.67	-5.91%	namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvController.java
25	0.0		common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsBriefInterceptor.java
26	49.02		broker/src/main/java/org/apache/rocketmq/broker/loadbalance/AssignmentManager.java
26	0.0		common/src/main/java/org/apache/rocketmq/common/message/MessageQueueAssignment.java
27	67.07		common/src/main/java/org/apache/rocketmq/common/statictopic/LogicQueueMappingItem.java
28	0.0		common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingContext.java
28	77.63	3.86%	store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
29	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/body/BrokerMemberGroup.java
29	0.0		common/src/main/java/org/apache/rocketmq/common/rpc/RequestBuilder.java
29	0.0		common/src/main/java/org/apache/rocketmq/common/subscription/GroupForbidden.java
31	71.3		broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java
31	77.21		broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java
31	0.0		tools/src/main/java/org/apache/rocketmq/tools/command/container/RemoveBrokerSubCommand.java
32	0.0		store/src/main/java/org/apache/rocketmq/store/pop/AckMsg.java
34	53.35		store/src/main/java/org/apache/rocketmq/store/logfile/DefaultMappedFile.java
35	39.29	-23.01%	common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java
35	33.33	-8.02%	tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
36	38.98		common/src/main/java/org/apache/rocketmq/common/BrokerIdentity.java
36	7.69		container/src/main/java/org/apache/rocketmq/container/ContainerClientHouseKeepingService.java
37	0.0	0.0%	tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java
38	48.17	-10.8%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullAPIWrapper.java
39	4.67	-4.19%	broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
39	23.53		common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingDetail.java
40	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/PopMessageRequestHeader.java
41	71.25	2.4%	broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
42	48.15		container/src/main/java/org/apache/rocketmq/container/InnerBrokerController.java
44	8.33		broker/src/main/java/org/apache/rocketmq/broker/processor/PollingInfoProcessor.java
44	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java
45	0.0	0.0%	broker/src/main/java/org/apache/rocketmq/broker/dledger/DLedgerRoleChangeHandler.java
45	61.54		broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingManager.java
45	29.69		store/src/main/java/org/apache/rocketmq/store/ha/HAConnectionStateNotificationService.java
47	70.44		store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAService.java
48	74.87		store/src/main/java/org/apache/rocketmq/store/util/PerfCounter.java
52	53.15		broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java
52	0.0		client/src/main/java/org/apache/rocketmq/client/impl/consumer/PopRequest.java
52	0.0		store/src/main/java/org/apache/rocketmq/store/pop/PopCheckPoint.java
53	55.33	-3.7%	client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
55	21.43		broker/src/main/java/org/apache/rocketmq/broker/util/HookUtils.java
55	71.79		store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAClient.java
56	44.53	-4.85%	common/src/main/java/org/apache/rocketmq/common/UtilAll.java
57	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/body/HARuntimeInfo.java
57	0.0		common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItem.java
59	0.0		common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsManager.java
61	67.71	-10.8%	namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
61	0.0		tools/src/main/java/org/apache/rocketmq/tools/command/consumer/SetConsumeModeSubCommand.java
62	75.1		store/src/main/java/org/apache/rocketmq/store/ha/DefaultHAConnection.java
63	0.0		tools/src/main/java/org/apache/rocketmq/tools/command/ha/HAStatusSubCommand.java
64	42.34		broker/src/main/java/org/apache/rocketmq/broker/processor/DefaultPullMessageResultHandler.java
68	60.89	-8.31%	store/src/main/java/org/apache/rocketmq/store/MappedFileQueue.java
70	70.21		container/src/main/java/org/apache/rocketmq/container/BrokerContainerStartup.java
71	66.19		container/src/main/java/org/apache/rocketmq/container/BrokerContainer.java
72	0.0	0.0%	broker/src/main/java/org/apache/rocketmq/broker/plugin/AbstractPluginMessageStore.java
72	0.0		common/src/main/java/org/apache/rocketmq/common/namesrv/DefaultTopAddressing.java
77	0.0		common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsBrief.java
83	52.4	3.78%	broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
84	0.0		common/src/main/java/org/apache/rocketmq/common/rpc/ClientMetadata.java
86	63.25		store/src/main/java/org/apache/rocketmq/store/queue/ConsumeQueueStore.java
88	66.02	-20.74%	common/src/main/java/org/apache/rocketmq/common/message/MessageDecoder.java
92	0.0		tools/src/main/java/org/apache/rocketmq/tools/command/topic/UpdateStaticTopicSubCommand.java
93	12.27	6.39%	broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
93	0.0		tools/src/main/java/org/apache/rocketmq/tools/command/topic/RemappingStaticTopicSubCommand.java
94	54.51	-1.43%	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingClient.java
98	57.37	-6.21%	store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
98	79.67		store/src/main/java/org/apache/rocketmq/store/queue/BatchConsumeQueue.java
110	14.06		broker/src/main/java/org/apache/rocketmq/broker/failover/EscapeBridge.java
114	76.79	-9.35%	namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
115	0.0		common/src/main/java/org/apache/rocketmq/common/protocol/header/ExtraInfoUtil.java
124	70.26		common/src/main/java/org/apache/rocketmq/common/statictopic/TopicQueueMappingUtils.java
124	0.0		common/src/main/java/org/apache/rocketmq/common/statistics/StatisticsItemScheduledIncrementPrinter.java
124	51.85	-28.15%	store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
131	9.66		broker/src/main/java/org/apache/rocketmq/broker/BrokerPreOnlineService.java
133	4.32		broker/src/main/java/org/apache/rocketmq/broker/processor/PeekMessageProcessor.java
137	4.2		container/src/main/java/org/apache/rocketmq/container/BrokerContainerProcessor.java
150	11.76		broker/src/main/java/org/apache/rocketmq/broker/processor/NotificationProcessor.java
152	28.37	-4.46%	common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
155	44.07	-5.93%	broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
156	13.33		client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopOrderlyService.java
156	0.0		test/src/main/java/org/apache/rocketmq/test/util/MQAdminTestUtils.java
161	34.42	-16.04%	broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
162	0.0		common/src/main/java/org/apache/rocketmq/common/rpc/RpcClientImpl.java
166	13.99		broker/src/main/java/org/apache/rocketmq/broker/topic/TopicQueueMappingCleanService.java
169	30.8	13.99%	client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
183	33.94		broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
183	74.89	-9.44%	store/src/main/java/org/apache/rocketmq/store/CommitLog.java
188	10.05		broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java
190	44.62	-10.49%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPushConsumerImpl.java
190	7.77		tools/src/main/java/org/apache/rocketmq/tools/admin/MQAdminUtils.java
191	37.95	-12.45%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
197	53.1		broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java
215	5.7		client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessagePopConcurrentlyService.java
246	25.49	-28.63%	broker/src/main/java/org/apache/rocketmq/broker/out/BrokerOuterAPI.java
263	60.85	3.13%	broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
276	50.8		broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
291	61.93	-4.25%	store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
373	30.31	-14.97%	tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
428	29.63	-8.87%	broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java

Uncovered Existing Lines

Lines	Coverage	∆	File
1	3.11	0.0%	broker/src/main/java/org/apache/rocketmq/broker/client/net/Broker2Client.java
1	0.0	0.0%	broker/src/main/java/org/apache/rocketmq/broker/dledger/DLedgerRoleChangeHandler.java
1	0.0	0.0%	broker/src/main/java/org/apache/rocketmq/broker/longpolling/LmqPullRequestHoldService.java
1	55.56	-4.44%	broker/src/main/java/org/apache/rocketmq/broker/longpolling/NotifyMessageArrivingListener.java
1	20.79	-3.3%	broker/src/main/java/org/apache/rocketmq/broker/longpolling/PullRequestHoldService.java
1	21.43	-1.65%	broker/src/main/java/org/apache/rocketmq/broker/plugin/MessageStoreFactory.java
1	12.27	6.39%	broker/src/main/java/org/apache/rocketmq/broker/processor/ConsumerManageProcessor.java
1	84.0	-0.57%	broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageBridge.java
1	33.33	-0.6%	client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPullConsumer.java
1	58.56	-0.35%	client/src/main/java/org/apache/rocketmq/client/consumer/DefaultMQPushConsumer.java
1	79.28	-1.8%	client/src/main/java/org/apache/rocketmq/client/consumer/store/RemoteBrokerOffsetStore.java
1	38.38	-0.24%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultMQPullConsumerImpl.java
1	54.92	-8.63%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalancePushImpl.java
1	55.33	-3.7%	client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
1	58.29	0.2%	client/src/main/java/org/apache/rocketmq/client/producer/DefaultMQProducer.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/Configuration.java
1	45.76	-8.52%	common/src/main/java/org/apache/rocketmq/common/DataVersion.java
1	54.3	-0.29%	common/src/main/java/org/apache/rocketmq/common/MixAll.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/body/LockBatchRequestBody.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/body/UnlockBatchRequestBody.java
1	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/protocol/header/DeleteSubscriptionGroupRequestHeader.java
1	45.37	0.93%	common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageRequestHeader.java
1	45.0	-1.88%	common/src/main/java/org/apache/rocketmq/common/protocol/header/PullMessageResponseHeader.java
1	46.15	-0.72%	common/src/main/java/org/apache/rocketmq/common/protocol/header/SendMessageResponseHeader.java
1	23.08	-0.61%	namesrv/src/main/java/org/apache/rocketmq/namesrv/NamesrvStartup.java
1	59.86	1.46%	remoting/src/main/java/org/apache/rocketmq/remoting/netty/NettyRemotingAbstract.java
1	83.33	-5.56%	remoting/src/main/java/org/apache/rocketmq/remoting/protocol/RemotingSerializable.java
1	63.64	-6.36%	store/src/main/java/org/apache/rocketmq/store/config/StorePathConfigHelper.java
1	77.97	0.1%	store/src/main/java/org/apache/rocketmq/store/ConsumeQueueExt.java
1	77.63	3.86%	store/src/main/java/org/apache/rocketmq/store/ConsumeQueue.java
1	94.55	-1.82%	store/src/main/java/org/apache/rocketmq/store/index/IndexHeader.java
1	47.83	-35.51%	store/src/main/java/org/apache/rocketmq/store/PutMessageResult.java
1	56.08	13.22%	store/src/main/java/org/apache/rocketmq/store/StoreStatsService.java
1	0.0	0.0%	tools/src/main/java/org/apache/rocketmq/tools/command/consumer/DeleteSubscriptionGroupCommand.java
2	8.33	2.0%	broker/src/main/java/org/apache/rocketmq/broker/BrokerStartup.java
2	33.0	0.78%	broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerManager.java
2	44.07	-5.93%	broker/src/main/java/org/apache/rocketmq/broker/processor/AbstractSendMessageProcessor.java
2	52.4	3.78%	broker/src/main/java/org/apache/rocketmq/broker/processor/SendMessageProcessor.java
2	90.78	20.19%	broker/src/main/java/org/apache/rocketmq/broker/subscription/SubscriptionGroupManager.java
2	53.85	-21.71%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/PullMessageService.java
2	4.93	-0.16%	client/src/main/java/org/apache/rocketmq/client/impl/MQAdminImpl.java
2	0.0	0.0%	common/src/main/java/org/apache/rocketmq/common/namesrv/NamesrvConfig.java
2	38.1	-9.52%	common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItem.java
2	84.62	-15.38%	common/src/main/java/org/apache/rocketmq/common/stats/StatsSnapshot.java
2	64.66	20.34%	common/src/main/java/org/apache/rocketmq/common/TopicConfig.java
2	51.85	-28.15%	store/src/main/java/org/apache/rocketmq/store/stats/BrokerStatsManager.java
3	27.78	-3.47%	broker/src/main/java/org/apache/rocketmq/broker/client/ClientHousekeepingService.java
3	35.76	12.62%	broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOffsetManager.java
3	4.67	-4.19%	broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
3	37.95	-12.45%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceImpl.java
3	28.37	-4.46%	common/src/main/java/org/apache/rocketmq/common/BrokerConfig.java
3	38.71	-8.91%	common/src/main/java/org/apache/rocketmq/common/protocol/route/BrokerData.java
3	54.17	-1.32%	store/src/main/java/org/apache/rocketmq/store/AllocateMappedFileService.java
3	86.97	3.01%	store/src/main/java/org/apache/rocketmq/store/dledger/DLedgerCommitLog.java
4	60.85	3.13%	broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
4	14.41	-1.05%	broker/src/main/java/org/apache/rocketmq/broker/client/rebalance/RebalanceLockManager.java
4	0.0	0.0%	tools/src/main/java/org/apache/rocketmq/tools/command/MQAdminStartup.java
5	34.42	-16.04%	broker/src/main/java/org/apache/rocketmq/broker/processor/PullMessageProcessor.java
5	56.67	-4.17%	common/src/main/java/org/apache/rocketmq/common/stats/StatsItem.java
5	49.25	-3.73%	common/src/main/java/org/apache/rocketmq/common/stats/StatsItemSet.java
6	71.25	2.4%	broker/src/main/java/org/apache/rocketmq/broker/topic/TopicConfigManager.java
6	41.3	-13.04%	common/src/main/java/org/apache/rocketmq/common/stats/MomentStatsItemSet.java
6	67.71	-10.8%	namesrv/src/main/java/org/apache/rocketmq/namesrv/processor/DefaultRequestProcessor.java
6	33.33	-8.02%	tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExt.java
8	74.89	-9.44%	store/src/main/java/org/apache/rocketmq/store/CommitLog.java
8	72.88	1.14%	store/src/main/java/org/apache/rocketmq/store/GetMessageResult.java
8	0.0	0.0%	tools/src/main/java/org/apache/rocketmq/tools/command/cluster/ClusterListSubCommand.java
10	78.41	-0.4%	client/src/main/java/org/apache/rocketmq/client/impl/consumer/DefaultLitePullConsumerImpl.java
10	30.31	-14.97%	tools/src/main/java/org/apache/rocketmq/tools/admin/DefaultMQAdminExtImpl.java
11	39.29	-23.01%	common/src/main/java/org/apache/rocketmq/common/protocol/route/TopicRouteData.java
11	57.37	-6.21%	store/src/main/java/org/apache/rocketmq/store/config/MessageStoreConfig.java
12	76.79	-9.35%	namesrv/src/main/java/org/apache/rocketmq/namesrv/routeinfo/RouteInfoManager.java
15	61.93	-4.25%	store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
24	30.8	13.99%	client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
42	29.63	-8.87%	broker/src/main/java/org/apache/rocketmq/broker/processor/AdminBrokerProcessor.java
50	0.0	-34.23%	tools/src/main/java/org/apache/rocketmq/tools/command/consumer/ConsumerProgressSubCommand.java

Jobs

ID	Job ID	Ran	Files	Coverage
1	7450.1	13 Jul 2022 01:46AM UTC	920	47.51	Travis Job 7450.1
2	7450.2	13 Jul 2022 01:47AM UTC	920	47.61	Travis Job 7450.2

apache / rocketmq / 7450
48%
develop: 49%

README BADGES
x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Uncovered Existing Lines

Jobs

Source Files on build 7450

apache / rocketmq / 7450 48% develop: 49%

README BADGES x

Markdown

Textile

RDoc

HTML

Rst

New Missed Lines in Diff

Uncovered Existing Lines

Jobs

Source Files on build 7450

apache / rocketmq / 7450
48%
develop: 49%

README BADGES
x