summaryrefslogtreecommitdiff
path: root/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java
diff options
context:
space:
mode:
Diffstat (limited to 'jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java')
-rw-r--r--jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java31
1 files changed, 20 insertions, 11 deletions
diff --git a/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java b/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java
index 0e17f54..a946c61 100644
--- a/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java
+++ b/jsonrpc/src/main/java/com/orbekk/same/SameServiceImpl.java
@@ -35,17 +35,26 @@ public class SameServiceImpl implements SameService {
}
@Override
- public void notifyParticipation(String networkName, String masterId,
- Map<String, String> participants) {
+ public void notifyParticipation(String networkName, String masterId) {
logger.info("Joining network {}. Master is {}", networkName, masterId);
- int i = 1;
- for (Map.Entry<String, String> e : participants.entrySet()) {
- String clientId = e.getKey();
- String url = e.getValue();
- logger.info(" {} participant {}: {}, {}",
- new Object[]{networkName, i, clientId, url});
- i++;
- }
- sameState.joinNetwork(networkName, masterId, participants);
+ // int i = 1;
+ // for (Map.Entry<String, String> e : participants.entrySet()) {
+ // String clientId = e.getKey();
+ // String url = e.getValue();
+ // logger.info(" {} participant {}: {}, {}",
+ // new Object[]{networkName, i, clientId, url});
+ // i++;
+ // }
+ sameState.joinNetwork(networkName, masterId);
+ }
+
+ @Override
+ public void setParticipants(Map<String, String> participants) {
+ sameState.setParticipants(participants);
+ }
+
+ @Override
+ public void setState(String newState) {
+ logger.error("setState not implemented.");
}
}