summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--same/src/main/java/com/orbekk/same/ClientApp.java13
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);
+
}
}