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

gbellato
02.22.2007 3fcf167e0af7a8f405442b3b4c8b07404ec6c0ff
opendj-sdk/opends/src/server/org/opends/server/synchronization/plugin/ChangelogBroker.java
@@ -163,6 +163,7 @@
     * Open Socket to the Changelog
     * Send the Start message
     */
    shutdown = false;
    this.servers = servers;
    if (servers.size() < 1)
    {
@@ -173,6 +174,7 @@
               message, msgID);
    }
    this.rcvWindow = this.maxRcvWindow;
    this.connect();
  }
@@ -537,7 +539,9 @@
   */
  public void stop()
  {
    changelogServer = "stopped";
    shutdown = true;
    connected = false;
    try
    {
      session.close();