mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git
blame | history | patch | commit | commitdiff | ignore whitespace
Matthew Swift
13.23.2011 96eaa516a85e620a6b76a64ffbe71cdc6037e026 
 opends/src/server/org/opends/server/replication/server/ReplicationServer.java


@@ -312,6 +312,12 @@




  void runListen()


  {


    Message listenMsg = NOTE_REPLICATION_SERVER_LISTENING.get(


        getServerId(),


        listenSocket.getInetAddress().getHostAddress(),


        listenSocket.getLocalPort());


    logError(listenMsg);




    while ((shutdown == false) && (stopListen  == false))


    {


      // Wait on the replicationServer port.


@@ -517,7 +523,7 @@


      socket.connect(ServerAddr, 500);




      ReplicationServerHandler handler = new ReplicationServerHandler(


          replSessionSecurity.createClientSession(remoteServerURL,


          replSessionSecurity.createClientSession(


              socket,


              ReplSessionSecurity.HANDSHAKE_TIMEOUT),


              queueSize,