Skip to content

Commit 4aafde8

Browse files
committed
[ISSUE #9687] Cleanup BrokerHeartbeatManager code
1 parent a4da5f5 commit 4aafde8

1 file changed

Lines changed: 5 additions & 5 deletions

File tree

controller/src/main/java/org/apache/rocketmq/controller/BrokerHeartbeatManager.java

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -26,9 +26,9 @@
2626
import java.util.Map;
2727

2828
public interface BrokerHeartbeatManager {
29-
public static final long DEFAULT_BROKER_CHANNEL_EXPIRED_TIME = 1000 * 10;
29+
long DEFAULT_BROKER_CHANNEL_EXPIRED_TIME = 1000 * 10;
3030

31-
public static BrokerHeartbeatManager newBrokerHeartbeatManager(ControllerConfig controllerConfig) {
31+
static BrokerHeartbeatManager newBrokerHeartbeatManager(ControllerConfig controllerConfig) {
3232
if (controllerConfig.getControllerType().equals(ControllerConfig.JRAFT_CONTROLLER)) {
3333
return new RaftBrokerHeartBeatManager(controllerConfig);
3434
} else {
@@ -37,9 +37,7 @@ public static BrokerHeartbeatManager newBrokerHeartbeatManager(ControllerConfig
3737
}
3838

3939
/**
40-
* initialize the resources
41-
*
42-
* @return
40+
* Initialize the resources
4341
*/
4442
void initialize();
4543

@@ -72,6 +70,8 @@ void onBrokerHeartbeat(final String clusterName, final String brokerName, final
7270

7371
/**
7472
* Get broker live information by clusterName and brokerAddr
73+
*
74+
* @return broker live information or null if not found
7575
*/
7676
BrokerLiveInfo getBrokerLiveInfo(String clusterName, String brokerName, Long brokerId);
7777

0 commit comments

Comments
 (0)