Final final
Project: http://git-wip-us.apache.org/repos/asf/incubator-gossip/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gossip/commit/3366f636 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gossip/tree/3366f636 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gossip/diff/3366f636 Branch: refs/heads/master Commit: 3366f6364142ad8460c7899fff5a90b67b81976d Parents: 266e039 Author: Edward Capriolo <[email protected]> Authored: Mon May 16 19:10:53 2016 -0400 Committer: Edward Capriolo <[email protected]> Committed: Tue Jun 7 22:52:53 2016 -0400 ---------------------------------------------------------------------- .../google/code/gossip/manager/PassiveGossipThread.java | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gossip/blob/3366f636/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java ---------------------------------------------------------------------- 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 ec11cfe..6bf1494 100644 --- a/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java +++ b/src/main/java/com/google/code/gossip/manager/PassiveGossipThread.java @@ -29,10 +29,6 @@ import java.util.concurrent.atomic.AtomicBoolean; import org.apache.log4j.Logger; import org.codehaus.jackson.map.ObjectMapper; -import org.json.JSONArray; -import org.json.JSONException; -import org.json.JSONObject; - import com.google.code.gossip.GossipMember; import com.google.code.gossip.GossipService; import com.google.code.gossip.RemoteGossipMember; @@ -49,15 +45,15 @@ abstract public class PassiveGossipThread implements Runnable { public static final Logger LOGGER = Logger.getLogger(PassiveGossipThread.class); /** The socket used for the passive thread of the gossip service. */ - private DatagramSocket server; + private final DatagramSocket server; private final GossipManager gossipManager; - private AtomicBoolean keepRunning; + private final AtomicBoolean keepRunning; private final String cluster; - private ObjectMapper MAPPER = new ObjectMapper(); + private final ObjectMapper MAPPER = new ObjectMapper(); public PassiveGossipThread(GossipManager gossipManager) { this.gossipManager = gossipManager;
