You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by pa...@apache.org on 2022/07/17 12:27:39 UTC

[rocketmq] branch develop updated: Fix issue 4617

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

panzhi33 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 870e8e462 Fix issue 4617
     new d9cec7f6b Merge pull request #4618 from Oliverwqcwrw/develop-same-addr-27
870e8e462 is described below

commit 870e8e462e861739a30babef99b77650667ec033
Author: Oliver <wq...@163.com>
AuthorDate: Sat Jul 16 20:54:14 2022 +0800

    Fix issue 4617
---
 .../main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java b/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
index 09cfecf17..89a6d7c0b 100644
--- a/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
+++ b/broker/src/main/java/org/apache/rocketmq/broker/slave/SlaveSynchronize.java
@@ -47,8 +47,8 @@ public class SlaveSynchronize {
 
     public void setMasterAddr(String masterAddr) {
         if (!StringUtils.equals(this.masterAddr, masterAddr)) {
-            this.masterAddr = masterAddr;
             LOGGER.info("Update master address from {} to {}", this.masterAddr, masterAddr);
+            this.masterAddr = masterAddr;
         }
     }