diff options
Diffstat (limited to 'same/src/test/java/com/orbekk')
-rw-r--r-- | same/src/test/java/com/orbekk/same/FunctionalTest.java | 11 |
1 files changed, 6 insertions, 5 deletions
diff --git a/same/src/test/java/com/orbekk/same/FunctionalTest.java b/same/src/test/java/com/orbekk/same/FunctionalTest.java index 79bd9b8..c0b710e 100644 --- a/same/src/test/java/com/orbekk/same/FunctionalTest.java +++ b/same/src/test/java/com/orbekk/same/FunctionalTest.java @@ -53,8 +53,9 @@ public class FunctionalTest { connections.clientMap0.put(location, client.getNewService()); clients.add(client); String paxosUrl = clientUrl.replace("ClientService", "PaxosService"); - PaxosService paxos = new PaxosServiceImpl(paxosUrl); + PaxosServiceImpl paxos = new PaxosServiceImpl(paxosUrl); connections.paxosMap.put(paxosUrl, paxos); + connections.paxosMap0.put(location, paxos.getService()); return client; } @@ -86,10 +87,10 @@ public class FunctionalTest { @Test public void testJoin() { joinClients(); for (State s : getStates()) { - List<String> participants = s.getList(".participants"); - assertThat(participants, hasItem("http://client1/ClientService.json")); - assertThat(participants, hasItem("http://client2/ClientService.json")); - assertThat(participants, hasItem("http://client3/ClientService.json")); + List<String> participants = s.getList(State.PARTICIPANTS); + assertThat(participants, hasItem("client1")); + assertThat(participants, hasItem("client2")); + assertThat(participants, hasItem("client3")); } for (Client c : clients) { assertThat(c.getConnectionState(), is(ConnectionState.STABLE)); |