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();