From 6c150264b21eded212b9e2cf9c802b36c3f75144 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kjetil=20=C3=98rbekk?= Date: Wed, 18 Jan 2012 20:17:10 +0100 Subject: Refactor client. --- same/src/main/java/com/orbekk/same/ClientApp.java | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) (limited to 'same/src/main/java') 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); + } } -- cgit v1.2.3