OPENDJ-1611 Check serverState before returning a message

Nicolas Capponi

02.56.2014 83c3954ccae5d6c59a0239c2c29fbdc9960109f5

 opends/src/server/org/opends/server/replication/server/ReplicationServerDomain.java

@@ -35,7 +35,6 @@
import java.util.List;
import java.util.Map;
import java.util.Map.Entry;
import java.util.Set;
import java.util.Timer;
import java.util.TimerTask;
import java.util.concurrent.ConcurrentHashMap;
@@ -1294,13 +1293,7 @@
  public UpdateMsg take(ServerHandler sHandler)
  {
    // Next message can only be taken from connected DSs
    final Set<Integer> connectedReplicaIds = new HashSet<Integer>(getConnectedDSs().keySet());
    if (sHandler.isDataServer())
    {
      // Prevents sending to a DS its own messages
      connectedReplicaIds.remove(sHandler.getServerId());
    }
    return sHandler.take(connectedReplicaIds);
    return sHandler.take(new HashSet<Integer>(getConnectedDSs().keySet()));
  }

  /**