| |
|
| java.lang.Object org.apache.jetspeed.aggregator.impl.CommonjWorkerMonitorImpl
CommonjWorkerMonitorImpl | public class CommonjWorkerMonitorImpl implements WorkerMonitor,WorkListener(Code) | | The CommonjWorkerMonitorImpl is responsible for dispatching jobs to workers
It wraps CommonJ WorkManager supported by IBM WebSphere and BEA WebLogic sever.
author: Woonsan Ko version: $Id: CommonjWorkerMonitorImpl.java 568339 2007-08-22 00:14:51Z ate $ |
Inner Class :class RenderingJobCommonjWork implements Work | |
Inner Class :class MonitoringJobCommonjWork implements Work | |
Inner Class :class CommonjWorkerRenderingJobTimeoutMonitor extends Thread | |
ACCESS_CONTROL_CONTEXT_WORKER_ATTR | final public static String ACCESS_CONTROL_CONTEXT_WORKER_ATTR(Code) | | |
COMMONJ_WORK_ITEM_ATTR | final public static String COMMONJ_WORK_ITEM_ATTR(Code) | | |
WORKER_THREAD_ATTR | final public static String WORKER_THREAD_ATTR(Code) | | |
interruptOnTimeout | protected boolean interruptOnTimeout(Code) | | If true, invoke interrupt() on the worker thread when the job is timeout.
|
jobMonitor | protected CommonjWorkerRenderingJobTimeoutMonitor jobMonitor(Code) | | Renering Job Timeout monitor
|
jobWorksMonitorEnabled | protected boolean jobWorksMonitorEnabled(Code) | | Enable rendering job works monitor thread for timeout checking
|
jobWorksMonitored | protected Map jobWorksMonitored(Code) | | Rendering job works to be monitored for timeout checking
|
log | final protected static Log log(Code) | | Commons logging
|
workManager | protected WorkManager workManager(Code) | | CommonJ Work Manamger provided by JavaEE container
|
CommonjWorkerMonitorImpl | public CommonjWorkerMonitorImpl(WorkManager workManager)(Code) | | |
CommonjWorkerMonitorImpl | public CommonjWorkerMonitorImpl(WorkManager workManager, boolean jobWorksMonitorEnabled)(Code) | | |
CommonjWorkerMonitorImpl | public CommonjWorkerMonitorImpl(WorkManager workManager, boolean jobWorksMonitorEnabled, boolean interruptOnTimeout)(Code) | | |
getAvailableJobsCount | public int getAvailableJobsCount()(Code) | | Returns a snapshot of the available jobs
available jobs |
getQueuedJobsCount | public int getQueuedJobsCount()(Code) | | |
getRunningJobsCount | public int getRunningJobsCount()(Code) | | |
process | public void process(RenderingJob job)(Code) | | Assign a job to a worker and execute it or queue the job if no
worker is available.
Parameters: job - the Job to process |
removeMonitoredJobWork | protected Object removeMonitoredJobWork(WorkItem workItem)(Code) | | |
start | public void start()(Code) | | |
waitForRenderingJobs | public void waitForRenderingJobs(List renderingJobs)(Code) | | Wait for all rendering jobs in the collection to finish successfully or otherwise.
Parameters: renderingJobs - the Collection of rendering job objects to wait for. |
workAccepted | public void workAccepted(WorkEvent we)(Code) | | |
workCompleted | public void workCompleted(WorkEvent we)(Code) | | |
workRejected | public void workRejected(WorkEvent we)(Code) | | |
workStarted | public void workStarted(WorkEvent we)(Code) | | |
|
|
|