From 61332bfbe7f7c9e1e3f086b17635e847258f5237 Mon Sep 17 00:00:00 2001 From: Edward Capriolo Date: Mon, 12 Jan 2015 10:46:38 -0500 Subject: [PATCH] fix gossiping port as id --- src/main/java/com/google/code/gossip/GossipMember.java | 2 +- .../com/google/code/gossip/manager/PassiveGossipThread.java | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/google/code/gossip/GossipMember.java b/src/main/java/com/google/code/gossip/GossipMember.java index f34aead..0a859bc 100644 --- a/src/main/java/com/google/code/gossip/GossipMember.java +++ b/src/main/java/com/google/code/gossip/GossipMember.java @@ -40,8 +40,8 @@ public abstract class GossipMember { public GossipMember(String host, int port, String id, int heartbeat) { _host = host; _port = port; - _heartbeat = heartbeat; _id = id; + _heartbeat = heartbeat; } /** diff --git a/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java b/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java index 61c87bb..d95acd7 100644 --- a/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java +++ b/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java @@ -90,7 +90,7 @@ abstract public class PassiveGossipThread implements Runnable { RemoteGossipMember member = new RemoteGossipMember( memberJSONObject.getString(GossipMember.JSON_HOST), memberJSONObject.getInt(GossipMember.JSON_PORT), - memberJSONObject.getString(GossipMember.JSON_PORT), + memberJSONObject.getString(GossipMember.JSON_ID), memberJSONObject.getInt(GossipMember.JSON_HEARTBEAT)); GossipService.LOGGER.debug(member.toString()); // This is the first member found, so this should be the member who is communicating