1 package org.apache.archiva.scheduler.repository;
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.redback.components.scheduler.AbstractJob;
23 import org.apache.archiva.redback.components.taskqueue.TaskQueue;
24 import org.apache.archiva.redback.components.taskqueue.TaskQueueException;
25 import org.apache.archiva.scheduler.repository.model.RepositoryTask;
26 import org.quartz.JobDataMap;
27 import org.quartz.JobExecutionContext;
28 import org.quartz.JobExecutionException;
29
30
31
32
33 public class RepositoryTaskJob
34 extends AbstractJob
35 {
36
37
38
39
40
41
42 @Override
43 public void execute( JobExecutionContext context )
44 throws JobExecutionException
45 {
46 JobDataMap dataMap = context.getJobDetail().getJobDataMap();
47 setJobDataMap( dataMap );
48
49 TaskQueue taskQueue = (TaskQueue) dataMap.get( DefaultRepositoryArchivaTaskScheduler.TASK_QUEUE );
50
51 String repositoryId = (String) dataMap.get( DefaultRepositoryArchivaTaskScheduler.TASK_REPOSITORY );
52 RepositoryTask task = new RepositoryTask();
53 task.setRepositoryId( repositoryId );
54
55 try
56 {
57 taskQueue.put( task );
58 }
59 catch ( TaskQueueException e )
60 {
61 throw new JobExecutionException( e );
62 }
63 }
64 }