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

Jean-Noel Rouvignac
08.16.2013 fa73aa0575f97205255d66ffed45d64bc04434ed
opends/src/server/org/opends/server/replication/server/MessageHandler.java
@@ -140,9 +140,8 @@
   *
   * @param update The update that must be added to the list of updates of
   * this handler.
   * @param sourceHandler The source handler that generated the update.
   */
  public void add(UpdateMsg update, MessageHandler sourceHandler)
  public void add(UpdateMsg update)
  {
    synchronized (msgQueue)
    {
@@ -445,15 +444,13 @@
    {
      if (following)
      {
        if (msgQueue.isEmpty())
        {
          result = null;
        } else
        if (!msgQueue.isEmpty())
        {
          UpdateMsg msg = msgQueue.first();
          result = msg.getChangeNumber();
        }
      } else
      }
      else
      {
        if (lateQueue.isEmpty())
        {