-
Notifications
You must be signed in to change notification settings - Fork 11.9k
Closed
Description
- Reuse the
DefaultMessageStore.this.getConfirmOffset()
.
rocketmq/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
Lines 2462 to 2465 in 3690049
if (DefaultMessageStore.this.getBrokerConfig().isEnableControllerMode()) { return this.reputFromOffset < ((AutoSwitchHAService) DefaultMessageStore.this.haService).getConfirmOffset(); } return this.reputFromOffset < DefaultMessageStore.this.commitLog.getMaxOffset(); - Reduce unnecessary branches statement
rocketmq/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
Line 2518 in 368d125
} else if (!dispatchRequest.isSuccess()) { - Reduce deep branches statement
rocketmq/store/src/main/java/org/apache/rocketmq/store/DefaultMessageStore.java
Lines 2539 to 2541 in 368d125
} else { doNext = false; }
Metadata
Metadata
Assignees
Labels
No labels