public class

DefaultTaskQueue

extends Object
implements TaskQueue
java.lang.Object
   ↳ org.apache.archiva.redback.components.taskqueue.DefaultTaskQueue

Summary

Public Constructors
DefaultTaskQueue()
Public Methods
List<Task> getQueueSnapshot()
List<TaskEntryEvaluator> getTaskEntryEvaluators()
List<TaskExitEvaluator> getTaskExitEvaluators()
List<TaskViabilityEvaluator> getTaskViabilityEvaluators()
Task poll(int timeout, TimeUnit timeUnit)
Retrieves and removes the head of the queue, waiting at most timeout timeUnit when no element is available.
boolean put(Task task)
boolean remove(Task task)
boolean removeAll(List<Task> tasks)
void setTaskEntryEvaluators(List<TaskEntryEvaluator> taskEntryEvaluators)
void setTaskExitEvaluators(List<TaskExitEvaluator> taskExitEvaluators)
void setTaskViabilityEvaluators(List<TaskViabilityEvaluator> taskViabilityEvaluators)
Task take()
[Expand]
Inherited Methods
From class java.lang.Object
From interface org.apache.archiva.redback.components.taskqueue.TaskQueue

Public Constructors

public DefaultTaskQueue ()

Public Methods

public List<Task> getQueueSnapshot ()

Throws
TaskQueueException

public List<TaskEntryEvaluator> getTaskEntryEvaluators ()

public List<TaskExitEvaluator> getTaskExitEvaluators ()

public List<TaskViabilityEvaluator> getTaskViabilityEvaluators ()

public Task poll (int timeout, TimeUnit timeUnit)

Retrieves and removes the head of the queue, waiting at most timeout timeUnit when no element is available.

Parameters
timeout time to wait, in timeUnit units
timeUnit how to interpret the timeout parameter.
Returns
  • the head of the queue, or null if the timeout elapsed
Throws
InterruptedException

public boolean put (Task task)

Throws
TaskQueueException

public boolean remove (Task task)

Throws
ClassCastException
NullPointerException

public boolean removeAll (List<Task> tasks)

Throws
ClassCastException
NullPointerException

public void setTaskEntryEvaluators (List<TaskEntryEvaluator> taskEntryEvaluators)

public void setTaskExitEvaluators (List<TaskExitEvaluator> taskExitEvaluators)

public void setTaskViabilityEvaluators (List<TaskViabilityEvaluator> taskViabilityEvaluators)

public Task take ()

Throws
TaskQueueException