ArchivaIndexingTaskExecutor (Archiva

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV CLASS NEXT CLASS

FRAMES NO FRAMES

SUMMARY: NESTED | FIELD | CONSTR | METHOD

DETAIL: FIELD | CONSTR | METHOD

org.apache.archiva.scheduler.indexing
Class ArchivaIndexingTaskExecutor

java.lang.Object
  org.apache.archiva.scheduler.indexing.ArchivaIndexingTaskExecutor

All Implemented Interfaces:: org.apache.archiva.redback.components.taskqueue.execution.TaskExecutor

@Service(value="taskExecutor#indexing") public class ArchivaIndexingTaskExecutor
extends Object
implements org.apache.archiva.redback.components.taskqueue.execution.TaskExecutor
extends Object
implements org.apache.archiva.redback.components.taskqueue.execution.TaskExecutor

ArchivaIndexingTaskExecutor Executes all indexing tasks. Adding, updating and removing artifacts from the index are all performed by this executor. Add and update artifact in index tasks are added in the indexing task queue by the NexusIndexerConsumer while remove artifact from index tasks are added by the LuceneCleanupRemoveIndexedConsumer.

Field Summary
`private org.apache.maven.index.ArtifactContextProducer`	`artifactContextProducer`
`private org.apache.maven.index.packer.IndexPacker`	`indexPacker`
`private org.slf4j.Logger`	`log`
`private ManagedRepositoryAdmin`	`managedRepositoryAdmin`
`private org.apache.maven.index.NexusIndexer`	`nexusIndexer`
`private PlexusSisuBridge`	`plexusSisuBridge`

Constructor Summary
`ArchivaIndexingTaskExecutor()`

Method Summary
`void`	`executeTask(org.apache.archiva.redback.components.taskqueue.Task task)` depending on current `Task` you have.
`private void`	`finishIndexingTask(ArtifactIndexingTask indexingTask, ManagedRepository repository, org.apache.maven.index.context.IndexingContext context)`
`PlexusSisuBridge`	`getPlexusSisuBridge()`
`void`	`initialize()`
`void`	`setIndexPacker(org.apache.maven.index.packer.IndexPacker indexPacker)`
`void`	`setPlexusSisuBridge(PlexusSisuBridge plexusSisuBridge)`

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

indexPacker

private org.apache.maven.index.packer.IndexPacker indexPacker

artifactContextProducer

private org.apache.maven.index.ArtifactContextProducer artifactContextProducer

plexusSisuBridge

@Inject
private PlexusSisuBridge plexusSisuBridge

managedRepositoryAdmin

@Inject
private ManagedRepositoryAdmin managedRepositoryAdmin

nexusIndexer

private org.apache.maven.index.NexusIndexer nexusIndexer

Constructor Detail

ArchivaIndexingTaskExecutor

public ArchivaIndexingTaskExecutor()

Method Detail

initialize

@PostConstruct
public void initialize()
                throws PlexusSisuBridgeException

Throws:: PlexusSisuBridgeException

executeTask

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

depending on current Task you have. If org.apache.archiva.scheduler.indexing.ArtifactIndexingTask.Action.FINISH && isExecuteOnEntireRepo: repository will be scanned.

Specified by:: executeTask in interface org.apache.archiva.redback.components.taskqueue.execution.TaskExecutor

Parameters:: task -
Throws:: org.apache.archiva.redback.components.taskqueue.execution.TaskExecutionException

finishIndexingTask

private void finishIndexingTask(ArtifactIndexingTask indexingTask,
                                ManagedRepository repository,
                                org.apache.maven.index.context.IndexingContext context)
                         throws org.apache.archiva.redback.components.taskqueue.execution.TaskExecutionException

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

setIndexPacker

public void setIndexPacker(org.apache.maven.index.packer.IndexPacker indexPacker)

getPlexusSisuBridge

public PlexusSisuBridge getPlexusSisuBridge()

setPlexusSisuBridge

public void setPlexusSisuBridge(PlexusSisuBridge plexusSisuBridge)