summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
-rw-r--r--same/src/main/java/com/orbekk/same/ClientApp.java39
1 files changed, 0 insertions, 39 deletions
diff --git a/same/src/main/java/com/orbekk/same/ClientApp.java b/same/src/main/java/com/orbekk/same/ClientApp.java
index bc873fa..c9ab52e 100644
--- a/same/src/main/java/com/orbekk/same/ClientApp.java
+++ b/same/src/main/java/com/orbekk/same/ClientApp.java
@@ -13,45 +13,6 @@ public class ClientApp {
private Server server;
private static final int timeout = 1000;
- @Deprecated
- public SameInterface 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,
- timeout);
- State state = new State(networkName);
- Broadcaster broadcaster =
- BroadcasterImpl.getDefaultBroadcastRunner();
- MasterServiceImpl master = new MasterServiceImpl(state, connections,
- broadcaster);
- ClientServiceImpl client = new ClientServiceImpl(state, connections);
-
- JsonRpcServer jsonServer = new JsonRpcServer(client, ClientService.class);
- server = new Server(port);
- RpcHandler rpcHandler = new RpcHandler(client);
- rpcHandler.addRpcServer("/ClientService.json", jsonServer);
- server.setHandler(rpcHandler);
-
- try {
- server.start();
- } catch (Exception e) {
- logger.error("Could not start jetty server: {}", e);
- }
-
- while (client.getUrl() == null) {
- HttpUtil.sendHttpRequest(masterUrl + "ping?port=" + port);
- try {
- Thread.sleep(500);
- } catch (InterruptedException e) {
- // Ignore interrupt in wait loop.
- }
- }
-
- client.joinNetwork(masterUrl + "MasterService.json");
- return Same.createSame(client);
- }
-
public void run(int port, String networkName,
String masterUrl) {
SameController controller = SameController.create(null);