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.components.scheduler.AbstractJob;
23 import org.apache.archiva.components.taskqueue.TaskQueue;
24 import org.apache.archiva.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 @SuppressWarnings( "unchecked" )
43 @Override
44 public void execute( JobExecutionContext context )
45 throws JobExecutionException
46 {
47 JobDataMap dataMap = context.getJobDetail().getJobDataMap();
48 setJobDataMap( dataMap );
49
50 TaskQueue taskQueue = (TaskQueue) dataMap.get( DefaultRepositoryArchivaTaskScheduler.TASK_QUEUE );
51
52 String repositoryId = (String) dataMap.get( DefaultRepositoryArchivaTaskScheduler.TASK_REPOSITORY );
53 RepositoryTaskpository/model/RepositoryTask.html#RepositoryTask">RepositoryTask task = new RepositoryTask();
54 task.setRepositoryId( repositoryId );
55
56 try
57 {
58 taskQueue.put( task );
59 }
60 catch ( TaskQueueException e )
61 {
62 throw new JobExecutionException( e );
63 }
64 }
65 }