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

Nicolas Capponi
02.56.2014 83c3954ccae5d6c59a0239c2c29fbdc9960109f5
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;
        }
      }