fix bug

qq254963746 · qq254963746 · commit 1725b602432b · 2015-03-18T16:29:41.000+08:00
diff --git a/job-core/src/main/java/com/lts/job/core/cluster/MasterElector.java b/job-core/src/main/java/com/lts/job/core/cluster/MasterElector.java
@@ -39,7 +39,6 @@ public Node getMaster() {
         return master;
     }
 
-
     public void addNodes(List<Node> nodes) {
         Node newMaster = null;
         for (Node node : nodes) {
@@ -51,10 +50,7 @@ public void addNodes(List<Node> nodes) {
                 }
             }
         }
-        if (master == null || !master.equals(newMaster)) {
-            master = newMaster;
-            notifyListener();
-        }
+        addNode(newMaster);
     }
 
     public void addNode(Node newNode) {

Original file line number	Diff line number	Diff line change
`@@ -39,7 +39,6 @@ public Node getMaster() {`
`39`	`39`	`return master;`
`40`	`40`	`}`
`41`	`41`
`42`		`-`
`43`	`42`	`public void addNodes(List<Node> nodes) {`
`44`	`43`	`Node newMaster = null;`
`45`	`44`	`for (Node node : nodes) {`
`@@ -51,10 +50,7 @@ public void addNodes(List<Node> nodes) {`
`51`	`50`	`}`
`52`	`51`	`}`
`53`	`52`	`}`
`54`		`- if (master == null \|\| !master.equals(newMaster)) {`
`55`		`- master = newMaster;`
`56`		`- notifyListener();`
`57`		`- }`
	`53`	`+ addNode(newMaster);`
`58`	`54`	`}`
`59`	`55`
`60`	`56`	`public void addNode(Node newNode) {`