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

[ISSUE #5544] Replace DLedgerServer#getdLedgerLeaderElector deprecated method (#5545)

Browse Source
This commit is contained in:
mxsm
2022-11-20 10:03:24 +08:00
committed by GitHub
parent da5a5b6292
commit 5293eba547
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
controller/src/main/java/org/apache/rocketmq/controller/impl/DLedgerController.java
+1 -1
View File
@@ -112,7 +112,7 @@ public class DLedgerController implements Controller {
// Register statemachine and role handler.
this.dLedgerServer = new DLedgerServer(dLedgerConfig, nettyServerConfig, nettyClientConfig, channelEventListener);
this.dLedgerServer.registerStateMachine(this.statemachine);
this.dLedgerServer.getdLedgerLeaderElector().addRoleChangeHandler(this.roleHandler);
this.dLedgerServer.getDLedgerLeaderElector().addRoleChangeHandler(this.roleHandler);
}
@Override