rdev/gossip-revisited
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix gossiping port as id

Browse Source
This commit is contained in:
Edward Capriolo
2015-01-12 10:46:38 -05:00
parent 4245908b38
commit 61332bfbe7
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
src/main/java/com/google/code/gossip/GossipMember.java
View File

@ -40,8 +40,8 @@ public abstract class GossipMember {
public GossipMember(String host, int port, String id, int heartbeat) { public GossipMember(String host, int port, String id, int heartbeat) {
_host = host; _host = host;
_port = port; _port = port;
_heartbeat = heartbeat;
_id = id; _id = id;
_heartbeat = heartbeat;
} }
/** /**

2
src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java
View File

@ -90,7 +90,7 @@ abstract public class PassiveGossipThread implements Runnable {
RemoteGossipMember member = new RemoteGossipMember( RemoteGossipMember member = new RemoteGossipMember(
memberJSONObject.getString(GossipMember.JSON_HOST), memberJSONObject.getString(GossipMember.JSON_HOST),
memberJSONObject.getInt(GossipMember.JSON_PORT), memberJSONObject.getInt(GossipMember.JSON_PORT),
memberJSONObject.getString(GossipMember.JSON_PORT), memberJSONObject.getString(GossipMember.JSON_ID),
memberJSONObject.getInt(GossipMember.JSON_HEARTBEAT)); memberJSONObject.getInt(GossipMember.JSON_HEARTBEAT));
GossipService.LOGGER.debug(member.toString()); GossipService.LOGGER.debug(member.toString());
// This is the first member found, so this should be the member who is communicating // This is the first member found, so this should be the member who is communicating