1 package org.apache.maven.archiva.repository.scanner;
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.archiva.configuration.ManagedRepositoryConfiguration;
23 import org.apache.maven.archiva.consumers.AbstractMonitoredConsumer;
24 import org.apache.maven.archiva.consumers.ConsumerException;
25 import org.apache.maven.archiva.consumers.KnownRepositoryContentConsumer;
26
27 import java.util.ArrayList;
28 import java.util.Arrays;
29 import java.util.Date;
30 import java.util.List;
31
32
33
34
35
36
37 public class KnownScanConsumer
38 extends AbstractMonitoredConsumer
39 implements KnownRepositoryContentConsumer
40 {
41 private int processCount = 0;
42
43 private List<String> includes = new ArrayList<String>();
44
45 private boolean processUnmodified = false;
46
47 public List<String> getExcludes()
48 {
49 return null;
50 }
51
52 public void setIncludes( String includesArray[] )
53 {
54 this.includes.clear();
55 this.includes.addAll( Arrays.asList( includesArray ) );
56 }
57
58 public List<String> getIncludes()
59 {
60 return includes;
61 }
62
63 public String getId()
64 {
65 return "test-scan-consumer";
66 }
67
68 public String getDescription()
69 {
70 return "Scan Consumer (for testing)";
71 }
72
73 public void beginScan( ManagedRepositoryConfiguration repository, Date whenGathered )
74 throws ConsumerException
75 {
76
77 }
78
79 public void beginScan( ManagedRepositoryConfiguration repository, Date whenGathered, boolean executeOnEntireRepo )
80 throws ConsumerException
81 {
82 beginScan( repository, whenGathered );
83 }
84
85 public void processFile( String path )
86 throws ConsumerException
87 {
88 this.processCount++;
89 }
90
91 public void processFile( String path, boolean executeOnEntireRepo )
92 throws Exception
93 {
94 processFile( path );
95 }
96
97 public void completeScan()
98 {
99
100 }
101
102 public void completeScan( boolean executeOnEntireRepo )
103 {
104 completeScan();
105 }
106
107 public int getProcessCount()
108 {
109 return processCount;
110 }
111
112 public void setProcessCount( int processCount )
113 {
114 this.processCount = processCount;
115 }
116
117 public boolean isPermanent()
118 {
119 return false;
120 }
121
122 public boolean isProcessUnmodified()
123 {
124 return processUnmodified;
125 }
126
127 public void setProcessUnmodified( boolean processUnmodified )
128 {
129 this.processUnmodified = processUnmodified;
130 }
131 }