org.apache.continuum.builder.distributed.executor
Class ThreadedDistributedBuildTaskQueueExecutor

java.lang.Object
  extended by org.apache.continuum.builder.distributed.executor.ThreadedDistributedBuildTaskQueueExecutor
All Implemented Interfaces:
DistributedBuildTaskQueueExecutor, org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable, org.codehaus.plexus.personality.plexus.lifecycle.phase.Startable

public class ThreadedDistributedBuildTaskQueueExecutor
extends Object
implements DistributedBuildTaskQueueExecutor, org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable, org.codehaus.plexus.personality.plexus.lifecycle.phase.Startable

Codes were taken from Plexus' ThreadedTaskQueueExecutor


Field Summary
 
Fields inherited from interface org.apache.continuum.builder.distributed.executor.DistributedBuildTaskQueueExecutor
ROLE
 
Constructor Summary
ThreadedDistributedBuildTaskQueueExecutor()
           
 
Method Summary
 boolean cancelTask(org.codehaus.plexus.taskqueue.Task task)
          Cancels execution of this task, if it's currently running.
 String getBuildAgentUrl()
          Returns the build agent url of task queue executor
 org.codehaus.plexus.taskqueue.Task getCurrentTask()
          Returns the currently executing task.
 org.codehaus.plexus.taskqueue.TaskQueue getQueue()
          Returns the task queue
 void initialize()
           
 void setBuildAgentUrl(String buildAgentUrl)
          Sets the build agent url of this task queue executor
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

ThreadedDistributedBuildTaskQueueExecutor

public ThreadedDistributedBuildTaskQueueExecutor()
Method Detail

initialize

public void initialize()
                throws org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException
Specified by:
initialize in interface org.codehaus.plexus.personality.plexus.lifecycle.phase.Initializable
Throws:
org.codehaus.plexus.personality.plexus.lifecycle.phase.InitializationException

start

public void start()
           throws org.codehaus.plexus.personality.plexus.lifecycle.phase.StartingException
Specified by:
start in interface org.codehaus.plexus.personality.plexus.lifecycle.phase.Startable
Throws:
org.codehaus.plexus.personality.plexus.lifecycle.phase.StartingException

stop

public void stop()
          throws org.codehaus.plexus.personality.plexus.lifecycle.phase.StoppingException
Specified by:
stop in interface org.codehaus.plexus.personality.plexus.lifecycle.phase.Startable
Throws:
org.codehaus.plexus.personality.plexus.lifecycle.phase.StoppingException

getCurrentTask

public org.codehaus.plexus.taskqueue.Task getCurrentTask()
Description copied from interface: DistributedBuildTaskQueueExecutor
Returns the currently executing task.

Specified by:
getCurrentTask in interface DistributedBuildTaskQueueExecutor
Returns:
the currently executing task.

cancelTask

public boolean cancelTask(org.codehaus.plexus.taskqueue.Task task)
Description copied from interface: DistributedBuildTaskQueueExecutor
Cancels execution of this task, if it's currently running. Does NOT remove it from the associated queue!

Specified by:
cancelTask in interface DistributedBuildTaskQueueExecutor
Parameters:
task - The task to cancel
Returns:
true if the task was cancelled, false if the task was not executing.

setBuildAgentUrl

public void setBuildAgentUrl(String buildAgentUrl)
Description copied from interface: DistributedBuildTaskQueueExecutor
Sets the build agent url of this task queue executor

Specified by:
setBuildAgentUrl in interface DistributedBuildTaskQueueExecutor

getBuildAgentUrl

public String getBuildAgentUrl()
Description copied from interface: DistributedBuildTaskQueueExecutor
Returns the build agent url of task queue executor

Specified by:
getBuildAgentUrl in interface DistributedBuildTaskQueueExecutor
Returns:
the build agent url

getQueue

public org.codehaus.plexus.taskqueue.TaskQueue getQueue()
Description copied from interface: DistributedBuildTaskQueueExecutor
Returns the task queue

Specified by:
getQueue in interface DistributedBuildTaskQueueExecutor
Returns:
the TaskQueue of the task queue executor


Copyright © 2003-2013 The Apache Software Foundation. All Rights Reserved.