opends/src/server/org/opends/server/replication/server/DbHandler.java
@@ -182,7 +182,7 @@ { try { msgQueue.wait(5000); msgQueue.wait(500); } catch (InterruptedException e) { // simply loop to try again. @@ -337,7 +337,7 @@ } if ((msgQueue.size() < queueLowmark) && (queueByteSize < queueLowmarkBytes)) msgQueue.notify(); msgQueue.notifyAll(); } }