diff options
author | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-01-11 10:47:27 +0100 |
---|---|---|
committer | Kjetil Ørbekk <kjetil.orbekk@gmail.com> | 2012-01-11 10:47:27 +0100 |
commit | 52088a08a9edb6d4b60e1e8923e1b3199db9f391 (patch) | |
tree | 191f3bbde90eb14b011c772c27a5f67aff28049e /jsonrpc/src/main/java/com/orbekk/rpc/App.java | |
parent | 5befe48a4cca6121cbce7f7fd5436cfc09f643f0 (diff) |
Continue SameService implementation.
- Implement ConnectionManager.
- SameService now calls notifyParticipation() when a client tries to
join.
- Add client ids – this may or may not be a good idea.
- Refactor App and Client code.
Diffstat (limited to 'jsonrpc/src/main/java/com/orbekk/rpc/App.java')
-rw-r--r-- | jsonrpc/src/main/java/com/orbekk/rpc/App.java | 11 |
1 files changed, 8 insertions, 3 deletions
diff --git a/jsonrpc/src/main/java/com/orbekk/rpc/App.java b/jsonrpc/src/main/java/com/orbekk/rpc/App.java index 2f956fe..d92003e 100644 --- a/jsonrpc/src/main/java/com/orbekk/rpc/App.java +++ b/jsonrpc/src/main/java/com/orbekk/rpc/App.java @@ -1,6 +1,7 @@ package com.orbekk.rpc; import com.googlecode.jsonrpc4j.JsonRpcServer; +import com.orbekk.same.ConnectionManagerImpl; import com.orbekk.same.SameState; import com.orbekk.same.SameService; import com.orbekk.same.SameServiceImpl; @@ -8,14 +9,18 @@ import org.eclipse.jetty.server.Server; public class App { public static void main(String[] args) { - if (args.length < 2) { - System.err.println("Arguments: port networkName"); + if (args.length < 3) { + System.err.println("Arguments: port networkName clientId"); System.exit(1); } int port = Integer.parseInt(args[0]); String networkName = args[1]; + String clientId = args[2]; - SameState sameState = new SameState(networkName); + ConnectionManagerImpl connections = new ConnectionManagerImpl(); + + SameState sameState = new SameState(networkName, clientId, + connections); sameState.start(); SameServiceImpl service = new SameServiceImpl(sameState); |