1 package org.apache.archiva.indexer.merger;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import org.apache.maven.index.context.IndexingContext;
23 import org.slf4j.Logger;
24 import org.slf4j.LoggerFactory;
25
26
27
28
29
30 public class MergedRemoteIndexesTask
31 implements Runnable
32 {
33
34 private Logger logger = LoggerFactory.getLogger( getClass() );
35
36 private MergedRemoteIndexesTaskRequest mergedRemoteIndexesTaskRequest;
37
38 public MergedRemoteIndexesTask( MergedRemoteIndexesTaskRequest mergedRemoteIndexesTaskRequest )
39 {
40 this.mergedRemoteIndexesTaskRequest = mergedRemoteIndexesTaskRequest;
41 }
42
43 @Override
44 public void run()
45 {
46 try
47 {
48 this.execute();
49 }
50 catch ( IndexMergerException e )
51 {
52 logger.error( e.getMessage(), e );
53 }
54 }
55
56 public MergedRemoteIndexesTaskResult execute()
57 throws IndexMergerException
58 {
59 IndexMerger indexMerger = mergedRemoteIndexesTaskRequest.getIndexMerger();
60
61 IndexingContext indexingContext =
62 indexMerger.buildMergedIndex( mergedRemoteIndexesTaskRequest.getIndexMergerRequest() );
63
64 return new MergedRemoteIndexesTaskResult( indexingContext );
65 }
66
67 @Override
68 public boolean equals( Object o )
69 {
70 if ( this == o )
71 {
72 return true;
73 }
74 if ( !( o instanceof MergedRemoteIndexesTask ) )
75 {
76 return false;
77 }
78
79 MergedRemoteIndexesTask that = (MergedRemoteIndexesTask) o;
80
81 return mergedRemoteIndexesTaskRequest.equals( that.mergedRemoteIndexesTaskRequest );
82 }
83
84 @Override
85 public int hashCode()
86 {
87 return mergedRemoteIndexesTaskRequest.hashCode();
88 }
89 }