Remove unused UDP broadcast code.

2 files changed, 3 insertions, 23 deletions

diff --git a/same/src/main/java/com/orbekk/same/App.java b/same/src/main/java/com/orbekk/same/App.java
index 464668d..ca12fa2 100644
--- a/same/src/main/java/com/orbekk/same/App.java
+++ b/same/src/main/java/com/orbekk/same/App.java
@@ -13,7 +13,6 @@ public class App {
         SameController controller = SameController.create(configuration);
         try {
             controller.start();
-            controller.searchNetworks();
             if ("true".equals(configuration.get("isMaster"))) {
                 controller.createNetwork(configuration.get("networkName"));
             } else {
diff --git a/same/src/main/java/com/orbekk/same/SameController.java b/same/src/main/java/com/orbekk/same/SameController.java
index c1c7901..95b8c29 100644
--- a/same/src/main/java/com/orbekk/same/SameController.java
+++ b/same/src/main/java/com/orbekk/same/SameController.java
@@ -3,10 +3,6 @@ package com.orbekk.same;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import com.orbekk.net.BroadcastListener;
-import com.orbekk.net.BroadcasterFactory;
-import com.orbekk.net.BroadcasterInterface;
-import com.orbekk.net.DefaultBroadcasterFactory;
 import com.orbekk.paxos.PaxosService;
 import com.orbekk.paxos.PaxosServiceImpl;
 import com.orbekk.same.config.Configuration;
@@ -23,7 +19,6 @@ public class SameController {
     private Master master;
     private Client client;
     private PaxosServiceImpl paxos;
-    private BroadcasterFactory broadcasterFactory;
     private Configuration configuration;
     private ConnectionManager connections;
     private Broadcaster serviceBroadcaster;
@@ -57,8 +52,7 @@ public class SameController {
         }
     };
     
-    public static SameController create(BroadcasterFactory broadcasterFactory,
-            Configuration configuration) {
+    public static SameController create(Configuration configuration) {
         int port = configuration.getInt("port");
         ConnectionManagerImpl connections = new ConnectionManagerImpl(
                 timeout, timeout);
@@ -91,14 +85,10 @@ public class SameController {
 
         SameController controller = new SameController(
                 configuration, connections, server, master, client,
-                paxos, broadcaster, broadcasterFactory);
+                paxos, broadcaster);
         return controller;
     }
 
-    public static SameController create(Configuration configuration) {
-        return create(new DefaultBroadcasterFactory(), configuration);
-    }
-
     public SameController(
             Configuration configuration,
             ConnectionManager connections,
@@ -106,8 +96,7 @@ public class SameController {
             MasterServiceProxy master,
             Client client,
             PaxosServiceImpl paxos,
-            Broadcaster serviceBroadcaster,
-            BroadcasterFactory broadcasterFactory) {
+            Broadcaster serviceBroadcaster) {
         this.configuration = configuration;
         this.connections = connections;
         this.server = server;
@@ -115,7 +104,6 @@ public class SameController {
         this.client = client;
         this.paxos = paxos;
         this.serviceBroadcaster = serviceBroadcaster;
-        this.broadcasterFactory = broadcasterFactory;
     }
 
     public void start() throws Exception {
@@ -151,13 +139,6 @@ public class SameController {
                 "MasterService.json";
         joinNetwork(masterUrl);
     }
-    
-    public void searchNetworks() {
-        BroadcasterInterface broadcaster = broadcasterFactory.create();
-        String message = "Discover " + client.getUrl();
-        broadcaster.sendBroadcast(configuration.getInt("discoveryPort"),
-                message.getBytes());
-    }
 
     public void joinNetwork(String url) {
         client.joinNetwork(url);