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

Final final

Browse Source
This commit is contained in:
Edward Capriolo
2016-05-16 19:10:53 -04:00
parent 266e039b29
commit 3366f63641
1 changed files with 3 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@ -29,10 +29,6 @@ import java.util.concurrent.atomic.AtomicBoolean;
import org.apache.log4j.Logger; import org.apache.log4j.Logger;
import org.codehaus.jackson.map.ObjectMapper; 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.GossipMember;
import com.google.code.gossip.GossipService; import com.google.code.gossip.GossipService;
import com.google.code.gossip.RemoteGossipMember; 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); public static final Logger LOGGER = Logger.getLogger(PassiveGossipThread.class);
/** The socket used for the passive thread of the gossip service. */ /** The socket used for the passive thread of the gossip service. */
private DatagramSocket server; private final DatagramSocket server;
private final GossipManager gossipManager; private final GossipManager gossipManager;
private AtomicBoolean keepRunning; private final AtomicBoolean keepRunning;
private final String cluster; private final String cluster;
private ObjectMapper MAPPER = new ObjectMapper(); private final ObjectMapper MAPPER = new ObjectMapper();
public PassiveGossipThread(GossipManager gossipManager) { public PassiveGossipThread(GossipManager gossipManager) {
this.gossipManager = gossipManager; this.gossipManager = gossipManager;