[rocketmq] branch develop updated: [ISSUE #5780]Replace DLedgerServer's deprecated getdLedgerLeaderElector method with getDLedgerLeaderElector (#5781)

[lizhanhui]

This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new fefbc3c46 [ISSUE #5780]Replace DLedgerServer's deprecated 
getdLedgerLeaderElector method with getDLedgerLeaderElector (#5781)
fefbc3c46 is described below

commit fefbc3c46a6e4d0c2af3cb31fd81a66c0563b0d3
Author: mxsm <ljbm...@gmail.com>
AuthorDate: Fri Dec 30 11:03:09 2022 +0800

    [ISSUE #5780]Replace DLedgerServer's deprecated getdLedgerLeaderElector 
method with getDLedgerLeaderElector (#5781)
---
 broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java 
b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
index 7804dfc78..eb9f629b5 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/BrokerController.java
@@ -746,7 +746,7 @@ public class BrokerController {
 
                 if (messageStoreConfig.isEnableDLegerCommitLog()) {
                     DLedgerRoleChangeHandler roleChangeHandler = new 
DLedgerRoleChangeHandler(this, defaultMessageStore);
-                    ((DLedgerCommitLog) 
defaultMessageStore.getCommitLog()).getdLedgerServer().getdLedgerLeaderElector().addRoleChangeHandler(roleChangeHandler);
+                    ((DLedgerCommitLog) 
defaultMessageStore.getCommitLog()).getdLedgerServer().getDLedgerLeaderElector().addRoleChangeHandler(roleChangeHandler);
                 }
                 this.brokerStats = new BrokerStats(defaultMessageStore);
                 //load plugin