org.apache.archiva.scheduler.repository
Class DefaultRepositoryArchivaTaskScheduler

java.lang.Object
  org.apache.archiva.scheduler.repository.DefaultRepositoryArchivaTaskScheduler

All Implemented Interfaces:

ConfigurationListener, ArchivaTaskScheduler<RepositoryTask>, RepositoryArchivaTaskScheduler

@Service(value="archivaTaskScheduler#repository")
public class DefaultRepositoryArchivaTaskScheduler
extends Object
implements RepositoryArchivaTaskScheduler, ConfigurationListener

Default implementation of a scheduling component for archiva.

log

private org.slf4j.Logger log

scheduler

@Inject
private org.apache.archiva.redback.components.scheduler.Scheduler scheduler

cronValidator

@Inject
private org.apache.archiva.redback.components.scheduler.CronExpressionValidator cronValidator

repositoryScanningQueue

@Inject
@Named(value="taskQueue#repository-scanning")
private org.apache.archiva.redback.components.taskqueue.TaskQueue repositoryScanningQueue

archivaConfiguration

@Inject
private ArchivaConfiguration archivaConfiguration

repositoryStatisticsManager

@Inject
@Named(value="repositoryStatisticsManager#default")
private RepositoryStatisticsManager repositoryStatisticsManager

repositorySessionFactory

@Inject
private RepositorySessionFactory repositorySessionFactory

TODO: could have multiple implementations

REPOSITORY_SCAN_GROUP

private static final String REPOSITORY_SCAN_GROUP

See Also:

Constant Field Values

REPOSITORY_JOB

private static final String REPOSITORY_JOB

See Also:

Constant Field Values

REPOSITORY_JOB_TRIGGER

private static final String REPOSITORY_JOB_TRIGGER

See Also:

Constant Field Values

TASK_QUEUE

static final String TASK_QUEUE

See Also:

Constant Field Values

TASK_REPOSITORY

static final String TASK_REPOSITORY

See Also:

Constant Field Values

CRON_HOURLY

public static final String CRON_HOURLY

See Also:

Constant Field Values

jobs

private Set<String> jobs

queuedRepos

private List<String> queuedRepos

DefaultRepositoryArchivaTaskScheduler

public DefaultRepositoryArchivaTaskScheduler()

startup

@PostConstruct
public void startup()
             throws ArchivaException

Throws:

ArchivaException

stop

@PreDestroy
public void stop()
          throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException

isProcessingRepositoryTask

public boolean isProcessingRepositoryTask(String repositoryId)

Specified by:

isProcessingRepositoryTask in interface RepositoryArchivaTaskScheduler

isProcessingRepositoryTask

public boolean isProcessingRepositoryTask(RepositoryTask task)

Specified by:

isProcessingRepositoryTask in interface RepositoryArchivaTaskScheduler

queueTask

public void queueTask(RepositoryTask task)
               throws org.apache.archiva.redback.components.taskqueue.TaskQueueException

Description copied from interface: ArchivaTaskScheduler

Adds the task to the scanning queue.

Specified by:

queueTask in interface ArchivaTaskScheduler<RepositoryTask>

Specified by:

queueTask in interface RepositoryArchivaTaskScheduler

Throws:

org.apache.archiva.redback.components.taskqueue.TaskQueueException

unQueueTask

public boolean unQueueTask(RepositoryTask task)
                    throws org.apache.archiva.redback.components.taskqueue.TaskQueueException

Specified by:

unQueueTask in interface RepositoryArchivaTaskScheduler

Throws:

org.apache.archiva.redback.components.taskqueue.TaskQueueException

configurationEvent

public void configurationEvent(ConfigurationEvent event)

Description copied from interface: ConfigurationListener

Generic event point to notify components that something has happend in the configuration.

Specified by:

configurationEvent in interface ConfigurationListener

isPreviouslyScanned

private boolean isPreviouslyScanned(ManagedRepositoryConfiguration repoConfig,
                                    MetadataRepository metadataRepository)
                             throws MetadataRepositoryException

Throws:

MetadataRepositoryException

queueInitialRepoScan

private void queueInitialRepoScan(ManagedRepositoryConfiguration repoConfig)

scheduleRepositoryJobs

private void scheduleRepositoryJobs(ManagedRepositoryConfiguration repoConfig)
                             throws org.quartz.SchedulerException

Throws:

org.quartz.SchedulerException