]> source.dussan.org Git - archiva.git/blob
364e11c4672c8acad4e6bbc15988e8acb48b086c
[archiva.git] /
1 package org.apache.archiva.repository.scanner;
2
3 /*
4  * Licensed to the Apache Software Foundation (ASF) under one
5  * or more contributor license agreements.  See the NOTICE file
6  * distributed with this work for additional information
7  * regarding copyright ownership.  The ASF licenses this file
8  * to you under the Apache License, Version 2.0 (the
9  * "License"); you may not use this file except in compliance
10  * with the License.  You may obtain a copy of the License at
11  *
12  *  http://www.apache.org/licenses/LICENSE-2.0
13  *
14  * Unless required by applicable law or agreed to in writing,
15  * software distributed under the License is distributed on an
16  * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
17  * KIND, either express or implied.  See the License for the
18  * specific language governing permissions and limitations
19  * under the License.
20  */
21
22 import org.apache.archiva.admin.model.beans.ManagedRepository;
23 import org.apache.archiva.consumers.AbstractMonitoredConsumer;
24 import org.apache.archiva.consumers.ConsumerException;
25 import org.apache.archiva.consumers.KnownRepositoryContentConsumer;
26 import org.springframework.context.annotation.Scope;
27 import org.springframework.stereotype.Service;
28
29 import java.util.ArrayList;
30 import java.util.Arrays;
31 import java.util.Date;
32 import java.util.List;
33
34 /**
35  * ScanConsumer 
36  *
37  * @version $Id$
38  */
39 public class KnownScanConsumer
40     extends AbstractMonitoredConsumer
41     implements KnownRepositoryContentConsumer
42 {
43     private int processCount = 0;
44
45     private List<String> includes = new ArrayList<String>();
46
47     private boolean processUnmodified = false;
48
49     public List<String> getExcludes()
50     {
51         return null;
52     }
53
54     public void setIncludes( String includesArray[] )
55     {
56         this.includes.clear();
57         this.includes.addAll( Arrays.asList( includesArray ) );
58     }
59
60     public List<String> getIncludes()
61     {
62         return includes;
63     }
64
65     public String getId()
66     {
67         return "test-scan-consumer";
68     }
69
70     public String getDescription()
71     {
72         return "Scan Consumer (for testing)";
73     }
74
75     public void beginScan( ManagedRepository repository, Date whenGathered )
76         throws ConsumerException
77     {
78         /* do nothing */
79     }
80
81     public void beginScan( ManagedRepository repository, Date whenGathered, boolean executeOnEntireRepo )
82         throws ConsumerException
83     {
84         beginScan( repository, whenGathered );
85     }
86
87     public void processFile( String path )
88         throws ConsumerException
89     {
90         this.processCount++;
91     }
92
93     public void processFile( String path, boolean executeOnEntireRepo )
94         throws Exception
95     {
96         processFile( path );
97     }
98
99     public void completeScan()
100     {
101         /* do nothing */
102     }
103
104     public void completeScan( boolean executeOnEntireRepo )
105     {
106        completeScan();
107     }
108
109     public int getProcessCount()
110     {
111         return processCount;
112     }
113
114     public void setProcessCount( int processCount )
115     {
116         this.processCount = processCount;
117     }
118
119     public boolean isPermanent()
120     {
121         return false;
122     }
123
124     public boolean isProcessUnmodified()
125     {
126         return processUnmodified;
127     }
128
129     public void setProcessUnmodified( boolean processUnmodified )
130     {
131         this.processUnmodified = processUnmodified;
132     }
133 }