Field Detail

• 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

Constructor Detail

• DefaultRepositoryArchivaTaskScheduler

  public DefaultRepositoryArchivaTaskScheduler()

Method Detail

• 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