mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

Jean-Noel Rouvignac
21.40.2015 fd7b82c90daf271ef5b7cfeee889e97712c49a99
Reverted part of r12768
1 files modified
6 ■■■■ changed files
opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/AssuredReplicationPluginTest.java 6 ●●●● patch | view | raw | blame | history
opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/AssuredReplicationPluginTest.java
@@ -443,7 +443,7 @@
    {
      {
        // Receive server start
        ServerStartMsg serverStartMsg = waitForSpecificMsg(session, ServerStartMsg.class);
        ServerStartMsg serverStartMsg = (ServerStartMsg) session.receive();
        baseDN = serverStartMsg.getBaseDN();
        serverState = serverStartMsg.getServerState();
@@ -464,7 +464,7 @@
        }
        // Read start session or stop
        ReplicationMsg msg = waitForSpecificMsgs(session, StopMsg.class, ServerStartMsg.class);
        ReplicationMsg msg = session.receive();
        if (msg instanceof StopMsg){
          // Disconnection of DS looking for best server
          return false;
@@ -584,7 +584,7 @@
        session.publish(addMsg);
        // Read and return matching ack
        return waitForSpecificMsg(session, AckMsg.class);
        return (AckMsg)session.receive();
      }
    }