opendj-server-legacy/src/main/java/org/opends/server/replication/server/MessageHandler.java
@@ -130,7 +130,7 @@ */ if (msgQueue.isEmpty()) { msgQueue.notify(); msgQueue.notifyAll(); } msgQueue.add(update); @@ -644,7 +644,6 @@ synchronized (msgQueue) { msgQueue.clear(); msgQueue.notify(); msgQueue.notifyAll(); }