org.apache.archiva.scheduler.repository

Class ArchivaRepositoryScanningTaskExecutor

java.lang.Object

org.apache.archiva.scheduler.repository.ArchivaRepositoryScanningTaskExecutor

All Implemented Interfaces:

org.apache.archiva.redback.components.taskqueue.execution.TaskExecutor<RepositoryTask>

@Service(value="taskExecutor#repository-scanning")
public class ArchivaRepositoryScanningTaskExecutor
extends Object
implements org.apache.archiva.redback.components.taskqueue.execution.TaskExecutor<RepositoryTask>

ArchivaRepositoryScanningTaskExecutor

Field Summary

Fields

Modifier and Type	Field and Description
private RepositoryContentConsumers	consumers
private org.slf4j.Logger	log
private ManagedRepositoryAdmin	managedRepositoryAdmin
private RepositoryScanner	repoScanner
private RepositorySessionFactory	repositorySessionFactory FIXME: this could be multiple implementations and needs to be configured.
private RepositoryStatisticsManager	repositoryStatisticsManager
private org.apache.archiva.redback.components.taskqueue.Task	task

Constructor Summary

Constructors

Constructor and Description
ArchivaRepositoryScanningTaskExecutor()

Method Summary

Modifier and Type	Method and Description
void	executeTask(RepositoryTask task)
RepositoryContentConsumers	getConsumers()
org.apache.archiva.redback.components.taskqueue.Task	getCurrentTaskInExecution()
ManagedRepositoryAdmin	getManagedRepositoryAdmin()
RepositoryScanner	getRepoScanner()
RepositorySessionFactory	getRepositorySessionFactory()
RepositoryStatisticsManager	getRepositoryStatisticsManager()
void	initialize()
void	setConsumers(RepositoryContentConsumers consumers)
void	setManagedRepositoryAdmin(ManagedRepositoryAdmin managedRepositoryAdmin)
void	setRepoScanner(RepositoryScanner repoScanner)
void	setRepositorySessionFactory(RepositorySessionFactory repositorySessionFactory)
void	setRepositoryStatisticsManager(RepositoryStatisticsManager repositoryStatisticsManager)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

private org.slf4j.Logger log

managedRepositoryAdmin

@Inject
private ManagedRepositoryAdmin managedRepositoryAdmin

repoScanner

@Inject
private RepositoryScanner repoScanner

consumers

@Inject
private RepositoryContentConsumers consumers

task

private org.apache.archiva.redback.components.taskqueue.Task task

repositoryStatisticsManager

@Inject
private RepositoryStatisticsManager repositoryStatisticsManager

repositorySessionFactory

@Inject
private RepositorySessionFactory repositorySessionFactory

FIXME: this could be multiple implementations and needs to be configured.

Constructor Detail

ArchivaRepositoryScanningTaskExecutor

public ArchivaRepositoryScanningTaskExecutor()

Method Detail

initialize

@PostConstruct
public void initialize()
                               throws org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException

Throws:

org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException

executeTask

public void executeTask(RepositoryTask task)
                 throws org.apache.archiva.redback.components.taskqueue.execution.TaskExecutionException

Specified by:

executeTask in interface org.apache.archiva.redback.components.taskqueue.execution.TaskExecutor<RepositoryTask>

Throws:

org.apache.archiva.redback.components.taskqueue.execution.TaskExecutionException

getCurrentTaskInExecution

public org.apache.archiva.redback.components.taskqueue.Task getCurrentTaskInExecution()

getRepoScanner

public RepositoryScanner getRepoScanner()

setRepoScanner

public void setRepoScanner(RepositoryScanner repoScanner)

getConsumers

public RepositoryContentConsumers getConsumers()

setConsumers

public void setConsumers(RepositoryContentConsumers consumers)

getRepositorySessionFactory

public RepositorySessionFactory getRepositorySessionFactory()

setRepositorySessionFactory

public void setRepositorySessionFactory(RepositorySessionFactory repositorySessionFactory)

getRepositoryStatisticsManager

public RepositoryStatisticsManager getRepositoryStatisticsManager()

setRepositoryStatisticsManager

public void setRepositoryStatisticsManager(RepositoryStatisticsManager repositoryStatisticsManager)

getManagedRepositoryAdmin

public ManagedRepositoryAdmin getManagedRepositoryAdmin()

setManagedRepositoryAdmin

public void setManagedRepositoryAdmin(ManagedRepositoryAdmin managedRepositoryAdmin)