OPENDJ-1611 Check serverState before returning a message

Nicolas Capponi

02.35.2014 9e32be8e70b69713d75c1be22907429e56928279

 opendj3-server-dev/src/server/org/opends/server/replication/server/MessageHandler.java

@@ -330,8 +330,10 @@
                following = true;
                lateQueue.clear();
                msgQueue.consumeUpTo(msg);
                updateServerState(msg);
                return msg;
                if (updateServerState(msg))
                {
                  return msg;
                }
              }
            }
          }
@@ -344,8 +346,11 @@
          {
            msg = lateQueue.removeFirst();
          }
          updateServerState(msg);
          return msg;
          if (updateServerState(msg))
          {
            return msg;
          }
          continue;
        }
      }