]> source.dussan.org Git - archiva.git/commitdiff
extract inner classes
authorOlivier Lamy <olamy@apache.org>
Tue, 17 Dec 2013 07:29:07 +0000 (07:29 +0000)
committerOlivier Lamy <olamy@apache.org>
Tue, 17 Dec 2013 07:29:07 +0000 (07:29 +0000)
git-svn-id: https://svn.apache.org/repos/asf/archiva/trunk@1551474 13f79535-47bb-0310-9956-ffa450edef68

archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/DefaultMergedRemoteIndexesScheduler.java
archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/MergedRemoteIndexesTask.java
archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/MergedRemoteIndexesTaskRequest.java [new file with mode: 0644]
archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/MergedRemoteIndexesTaskResult.java [new file with mode: 0644]
archiva-modules/archiva-web/archiva-webdav/src/main/java/org/apache/archiva/webdav/ArchivaDavResourceFactory.java

index 787c1c69e4419408068033f47709ee6ad02a1d30..480529b44e26df0b8573f18c61f4781bcf8f33a1 100644 (file)
@@ -76,8 +76,8 @@ public class DefaultMergedRemoteIndexesScheduler
             new IndexMergerRequest( repositories, true, repositoryGroup.getId(), repositoryGroup.getMergedIndexPath(),
                                     repositoryGroup.getMergedIndexTtl() ).mergedIndexDirectory( directory );
 
-        MergedRemoteIndexesTask.MergedRemoteIndexesTaskRequest taskRequest =
-            new MergedRemoteIndexesTask.MergedRemoteIndexesTaskRequest( indexMergerRequest, indexMerger );
+        MergedRemoteIndexesTaskRequest taskRequest =
+            new MergedRemoteIndexesTaskRequest( indexMergerRequest, indexMerger );
 
         ScheduledFuture scheduledFuture =
             taskScheduler.schedule( new MergedRemoteIndexesTask( taskRequest ), cronTrigger );
index 346d08f4b430ed03a381c336e06d27e75105cfeb..bcb39051bfb47a09fe195293d8d86db5a3fd5002 100644 (file)
@@ -56,95 +56,14 @@ public class MergedRemoteIndexesTask
     public MergedRemoteIndexesTaskResult execute()
         throws IndexMergerException
     {
-        IndexMerger indexMerger = mergedRemoteIndexesTaskRequest.indexMerger;
+        IndexMerger indexMerger = mergedRemoteIndexesTaskRequest.getIndexMerger();
 
         IndexingContext indexingContext =
-            indexMerger.buildMergedIndex( mergedRemoteIndexesTaskRequest.indexMergerRequest );
+            indexMerger.buildMergedIndex( mergedRemoteIndexesTaskRequest.getIndexMergerRequest() );
 
         return new MergedRemoteIndexesTaskResult( indexingContext );
     }
 
-    public static class MergedRemoteIndexesTaskRequest
-    {
-        private IndexMergerRequest indexMergerRequest;
-
-        private IndexMerger indexMerger;
-
-        public MergedRemoteIndexesTaskRequest( IndexMergerRequest indexMergerRequest, IndexMerger indexMerger )
-        {
-            this.indexMergerRequest = indexMergerRequest;
-            this.indexMerger = indexMerger;
-        }
-
-        public IndexMergerRequest getIndexMergerRequest()
-        {
-            return indexMergerRequest;
-        }
-
-        public void setIndexMergerRequest( IndexMergerRequest indexMergerRequest )
-        {
-            this.indexMergerRequest = indexMergerRequest;
-        }
-
-        public IndexMerger getIndexMerger()
-        {
-            return indexMerger;
-        }
-
-        public void setIndexMerger( IndexMerger indexMerger )
-        {
-            this.indexMerger = indexMerger;
-        }
-
-        @Override
-        public boolean equals( Object o )
-        {
-            if ( this == o )
-            {
-                return true;
-            }
-            if ( o == null || getClass() != o.getClass() )
-            {
-                return false;
-            }
-
-            MergedRemoteIndexesTaskRequest that = (MergedRemoteIndexesTaskRequest) o;
-
-            if ( !indexMergerRequest.equals( that.indexMergerRequest ) )
-            {
-                return false;
-            }
-
-            return true;
-        }
-
-        @Override
-        public int hashCode()
-        {
-            return indexMergerRequest.hashCode();
-        }
-    }
-
-    public static class MergedRemoteIndexesTaskResult
-    {
-        private IndexingContext indexingContext;
-
-        public MergedRemoteIndexesTaskResult( IndexingContext indexingContext )
-        {
-            this.indexingContext = indexingContext;
-        }
-
-        public IndexingContext getIndexingContext()
-        {
-            return indexingContext;
-        }
-
-        public void setIndexingContext( IndexingContext indexingContext )
-        {
-            this.indexingContext = indexingContext;
-        }
-    }
-
     @Override
     public boolean equals( Object o )
     {
diff --git a/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/MergedRemoteIndexesTaskRequest.java b/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/MergedRemoteIndexesTaskRequest.java
new file mode 100644 (file)
index 0000000..57219f7
--- /dev/null
@@ -0,0 +1,85 @@
+package org.apache.archiva.indexer.merger;
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+/**
+ * @author Olivier Lamy
+ * @since 2.0.0
+ */
+public class MergedRemoteIndexesTaskRequest
+{
+    private IndexMergerRequest indexMergerRequest;
+
+    private IndexMerger indexMerger;
+
+    public MergedRemoteIndexesTaskRequest( IndexMergerRequest indexMergerRequest, IndexMerger indexMerger )
+    {
+        this.indexMergerRequest = indexMergerRequest;
+        this.indexMerger = indexMerger;
+    }
+
+    public IndexMergerRequest getIndexMergerRequest()
+    {
+        return indexMergerRequest;
+    }
+
+    public void setIndexMergerRequest( IndexMergerRequest indexMergerRequest )
+    {
+        this.indexMergerRequest = indexMergerRequest;
+    }
+
+    public IndexMerger getIndexMerger()
+    {
+        return indexMerger;
+    }
+
+    public void setIndexMerger( IndexMerger indexMerger )
+    {
+        this.indexMerger = indexMerger;
+    }
+
+    @Override
+    public boolean equals( Object o )
+    {
+        if ( this == o )
+        {
+            return true;
+        }
+        if ( o == null || getClass() != o.getClass() )
+        {
+            return false;
+        }
+
+        MergedRemoteIndexesTaskRequest that = (MergedRemoteIndexesTaskRequest) o;
+
+        if ( !indexMergerRequest.equals( that.indexMergerRequest ) )
+        {
+            return false;
+        }
+
+        return true;
+    }
+
+    @Override
+    public int hashCode()
+    {
+        return indexMergerRequest.hashCode();
+    }
+}
diff --git a/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/MergedRemoteIndexesTaskResult.java b/archiva-modules/archiva-base/archiva-indexer/src/main/java/org/apache/archiva/indexer/merger/MergedRemoteIndexesTaskResult.java
new file mode 100644 (file)
index 0000000..b75a292
--- /dev/null
@@ -0,0 +1,46 @@
+package org.apache.archiva.indexer.merger;
+
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+
+import org.apache.maven.index.context.IndexingContext;
+
+/**
+ * @author Olivier Lamy
+ * @since 2.0.0
+ */
+public class MergedRemoteIndexesTaskResult
+{
+    private IndexingContext indexingContext;
+
+    public MergedRemoteIndexesTaskResult( IndexingContext indexingContext )
+    {
+        this.indexingContext = indexingContext;
+    }
+
+    public IndexingContext getIndexingContext()
+    {
+        return indexingContext;
+    }
+
+    public void setIndexingContext( IndexingContext indexingContext )
+    {
+        this.indexingContext = indexingContext;
+    }
+}
index 181eddc63316eaf88925b120e4756f8cdbecd59b..2bc10e101ae0fc64119eae4c4aeb98e6192b4400 100644 (file)
@@ -39,6 +39,7 @@ import org.apache.archiva.indexer.merger.IndexMerger;
 import org.apache.archiva.indexer.merger.IndexMergerException;
 import org.apache.archiva.indexer.merger.IndexMergerRequest;
 import org.apache.archiva.indexer.merger.MergedRemoteIndexesTask;
+import org.apache.archiva.indexer.merger.MergedRemoteIndexesTaskRequest;
 import org.apache.archiva.indexer.merger.TemporaryGroupIndex;
 import org.apache.archiva.indexer.search.RepositorySearch;
 import org.apache.archiva.maven2.metadata.MavenMetadataReader;
@@ -1315,8 +1316,8 @@ public class ArchivaDavResourceFactory
                                     repositoryGroupConfiguration.getMergedIndexPath(),
                                     repositoryGroupConfiguration.getMergedIndexTtl() ).mergedIndexDirectory( tempRepoFile );
 
-            MergedRemoteIndexesTask.MergedRemoteIndexesTaskRequest taskRequest =
-                new MergedRemoteIndexesTask.MergedRemoteIndexesTaskRequest(indexMergerRequest, indexMerger);
+            MergedRemoteIndexesTaskRequest taskRequest =
+                new MergedRemoteIndexesTaskRequest(indexMergerRequest, indexMerger);
 
             MergedRemoteIndexesTask job = new MergedRemoteIndexesTask( taskRequest );