diff options
Diffstat (limited to 'same/src/main/java')
| -rw-r--r-- | same/src/main/java/com/orbekk/same/ClientApp.java | 13 | 
1 files changed, 10 insertions, 3 deletions
diff --git a/same/src/main/java/com/orbekk/same/ClientApp.java b/same/src/main/java/com/orbekk/same/ClientApp.java index 34380a0..5829c5d 100644 --- a/same/src/main/java/com/orbekk/same/ClientApp.java +++ b/same/src/main/java/com/orbekk/same/ClientApp.java @@ -12,7 +12,8 @@ public class ClientApp {      private Server server;      private static final int timeout = 1000; -    public void run(int port, String networkName, String masterUrl) { +    public ClientService getClient(int port, String networkName, +            String masterUrl) {          logger.info("Starting client with port:{}, networkName:{}, masterUrl:{}",                  new Object[]{port, networkName, masterUrl});          ConnectionManagerImpl connections = new ConnectionManagerImpl(timeout, @@ -45,11 +46,16 @@ public class ClientApp {          }          client.joinNetwork(masterUrl + "MasterService.json"); -         +        return client; +    } +     +    public void run(int port, String networkName, +            String masterUrl) { +        getClient(port, networkName, masterUrl);          try {              server.join();          } catch (InterruptedException e) { -            logger.info("Received exception. Exiting. {}", e); +            logger.warn("Interrupted.", e);          }      } @@ -62,5 +68,6 @@ public class ClientApp {          String networkName = args[1];          String masterUrl = args[2];          (new ClientApp()).run(port, networkName, masterUrl); +              }  }  | 
