opends/src/server/org/opends/server/replication/server/MessageHandler.java
@@ -329,8 +329,10 @@ following = true; lateQueue.clear(); msgQueue.consumeUpTo(msg); updateServerState(msg); return msg; if (updateServerState(msg)) { return msg; } } } } @@ -343,8 +345,11 @@ { msg = lateQueue.removeFirst(); } updateServerState(msg); return msg; if (updateServerState(msg)) { return msg; } continue; } }