commit 1d064f467633c0db751c28abd18c5095f77697ea
author edwardcapriolo <edlinuxguru@gmail.com> Fri Jan 29 23:33:07 2016 -0430
committer edwardcapriolo <edlinuxguru@gmail.com> Fri Jan 29 23:33:07 2016 -0430
tree 34a3fa0050fb0fa98da80012fcdc85554837a021
parent c8c3332eb084a937bc4001f7a78a7f44d1082df1
parent 0393d99c099d8c77c6aed22fda99058fe2eb8b3c

Merge pull request #13 from irstevenson/unittest-multiport

Change to unit test so that it doesn't require the setup of multiple loopback devices.

src/main/java/com/google/code/gossip/GossipService.java

diff --git a/src/main/java/com/google/code/gossip/GossipService.java b/src/main/java/com/google/code/gossip/GossipService.java
index 5c8ac7b..728e77e 100644
--- a/src/main/java/com/google/code/gossip/GossipService.java
+++ b/src/main/java/com/google/code/gossip/GossipService.java
@@ -47,6 +47,9 @@
   }
 
   public void start() {
+    String address = get_gossipManager().getMyself().getHost() + ":" + get_gossipManager().getMyself().getPort();
+    LOGGER.debug( "Starting: " + _gossipManager.getName() + " - " + address );
+
     _gossipManager.start();
   }
 

src/test/java/io/teknek/gossip/TenNodeThreeSeedTest.java

diff --git a/src/test/java/io/teknek/gossip/TenNodeThreeSeedTest.java b/src/test/java/io/teknek/gossip/TenNodeThreeSeedTest.java
index f91f689..5dcca8c 100644
--- a/src/test/java/io/teknek/gossip/TenNodeThreeSeedTest.java
+++ b/src/test/java/io/teknek/gossip/TenNodeThreeSeedTest.java
@@ -9,6 +9,7 @@
 import java.util.concurrent.TimeUnit;
 
 
+import org.apache.log4j.Logger;
 import org.junit.Assert;
 import org.junit.Test;
 
@@ -20,6 +21,7 @@
 import com.google.code.gossip.event.GossipState;
 
 public class TenNodeThreeSeedTest {
+  private static final Logger log = Logger.getLogger( TenNodeThreeSeedTest.class );
 
   @Test
   public void test() throws UnknownHostException, InterruptedException{
@@ -33,15 +35,19 @@
 
   public void abc() throws InterruptedException, UnknownHostException{
     GossipSettings settings = new GossipSettings();
+
+    log.info( "Adding seed nodes" );
     int seedNodes = 3;
     List<GossipMember> startupMembers = new ArrayList<>();
     for (int i = 1; i < seedNodes+1; ++i) {
-      startupMembers.add(new RemoteGossipMember("127.0.0." + i, 2000, i + ""));
+      startupMembers.add(new RemoteGossipMember("127.0.0.1", 50000 + i, i + ""));
     }
+
+    log.info( "Adding clients" );
     final List<GossipService> clients = new ArrayList<>();
     final int clusterMembers = 5;
     for (int i = 1; i < clusterMembers+1; ++i) {
-      GossipService gossipService = new GossipService("127.0.0." + i, 2000, i + "", 
+      GossipService gossipService = new GossipService("127.0.0.1", 50000 + i, i + "",
               startupMembers, settings,
               new GossipListener(){
         @Override