opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-28 20:09:14 +08:00
Code Issues Packages Projects Releases Wiki Activity

[ISSUE #9687] Cleanup BrokerHeartbeatManager code (#9688)

Browse Source
This commit is contained in:
majialong
2025-09-24 13:48:53 +08:00
committed by GitHub
parent d197028f83
commit 6d6921b473
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
controller/src/main/java/org/apache/rocketmq/controller/BrokerHeartbeatManager.java
+5 -5
View File
@@ -26,9 +26,9 @@ import org.apache.rocketmq.controller.impl.heartbeat.RaftBrokerHeartBeatManager;
import java.util.Map;
public interface BrokerHeartbeatManager {
public static final long DEFAULT_BROKER_CHANNEL_EXPIRED_TIME = 1000 * 10;
long DEFAULT_BROKER_CHANNEL_EXPIRED_TIME = 1000 * 10;
public static BrokerHeartbeatManager newBrokerHeartbeatManager(ControllerConfig controllerConfig) {
static BrokerHeartbeatManager newBrokerHeartbeatManager(ControllerConfig controllerConfig) {
if (controllerConfig.getControllerType().equals(ControllerConfig.JRAFT_CONTROLLER)) {
return new RaftBrokerHeartBeatManager(controllerConfig);
} else {
@@ -37,9 +37,7 @@ public interface BrokerHeartbeatManager {
}
/**
* initialize the resources
*
* @return
* Initialize the resources
*/
void initialize();
@@ -72,6 +70,8 @@ public interface BrokerHeartbeatManager {
/**
* Get broker live information by clusterName and brokerAddr
*
* @return broker live information or null if not found
*/
BrokerLiveInfo getBrokerLiveInfo(String clusterName, String brokerName, Long brokerId);