1 package org.apache.archiva.scheduler.indexing;
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22 import org.apache.archiva.scheduler.ArchivaTaskScheduler;
23 import org.apache.archiva.redback.components.taskqueue.TaskQueue;
24 import org.apache.archiva.redback.components.taskqueue.TaskQueueException;
25 import org.slf4j.Logger;
26 import org.slf4j.LoggerFactory;
27 import org.springframework.stereotype.Service;
28
29 import javax.inject.Inject;
30 import javax.inject.Named;
31
32
33
34
35
36
37 @Service("archivaTaskScheduler#indexing")
38 public class IndexingArchivaTaskScheduler
39 implements ArchivaTaskScheduler<ArtifactIndexingTask>
40 {
41 private Logger log = LoggerFactory.getLogger( IndexingArchivaTaskScheduler.class );
42
43
44
45
46 @Inject
47 @Named(value = "taskQueue#indexing")
48 private TaskQueue indexingQueue;
49
50 @Override
51 public void queueTask( ArtifactIndexingTask task )
52 throws TaskQueueException
53 {
54 indexingQueue.put( task );
55 }
56
57 }