Skip to content

Commit de46652

Browse files
authored
fix bug
1 parent 825f81b commit de46652

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

src/main/java/net/lvsq/jgossip/core/GossipManager.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -70,8 +70,6 @@ public static GossipManager getInstance() {
7070
}
7171

7272
public void init(String cluster, String ipAddress, Integer port, String id, List<SeedMember> seedMembers, GossipSettings settings, GossipListener listener) {
73-
this.settings = settings;
74-
this.settings.setSeedMembers(seedMembers);
7573
this.cluster = cluster;
7674
this.localGossipMember = new GossipMember();
7775
this.localGossipMember.setCluster(cluster);
@@ -81,6 +79,8 @@ public void init(String cluster, String ipAddress, Integer port, String id, List
8179
this.localGossipMember.setState(GossipState.JOIN);
8280
this.endpointMembers.put(localGossipMember, new HeartbeatState());
8381
this.listener = listener;
82+
this.settings = settings;
83+
this.settings.setSeedMembers(seedMembers);
8484
fireGossipEvent(localGossipMember, GossipState.JOIN);
8585
}
8686

0 commit comments

Comments
 (0)