ca.bc.gov.open.cpf.api.scheduler

Class AbstractBatchJobChannelProcess

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

ca.bc.gov.open.cpf.api.scheduler.AbstractBatchJobChannelProcess

All Implemented Interfaces:

com.revolsys.parallel.process.Process, PropertyChangeListener, Runnable, Executor, ExecutorService, EventListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

Direct Known Subclasses:

BatchJobPostProcess, BatchJobPreProcess

public abstract class AbstractBatchJobChannelProcess
extends ThreadPoolExecutor
implements com.revolsys.parallel.process.Process, PropertyChangeListener

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
AbstractBatchJobChannelProcess(String jobStatusToProcess)

Method Summary

Modifier and Type	Method and Description
protected void	afterExecute(Runnable r, Throwable t)
void	execute(Runnable command)
BatchJobService	getBatchJobService() Get the batch job service used to interact with the database.
String	getBeanName()
CpfConfig	getConfig()
com.revolsys.parallel.channel.Channel<com.revolsys.identifier.Identifier>	getIn()
com.revolsys.parallel.process.ProcessNetwork	getProcessNetwork()
protected abstract boolean	processJob(com.revolsys.identifier.Identifier batchJobId)
void	run()
protected void	run(com.revolsys.parallel.channel.Channel<com.revolsys.identifier.Identifier> in)
void	schedule(com.revolsys.identifier.Identifier batchJobId)
void	scheduleFromDatabase(String moduleName, String businessApplicationName)
void	setBatchJobService(BatchJobService batchJobService) Set the batch job service used to interact with the database.
void	setBeanName(String beanName)
void	setProcessNetwork(com.revolsys.parallel.process.ProcessNetwork processNetwork)
String	toString()

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.revolsys.parallel.process.Process

initialize

Methods inherited from interface java.beans.PropertyChangeListener

propertyChange

Constructor Detail

AbstractBatchJobChannelProcess

public AbstractBatchJobChannelProcess(String jobStatusToProcess)

Method Detail

afterExecute

protected void afterExecute(Runnable r,
                            Throwable t)

Overrides:

afterExecute in class ThreadPoolExecutor

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

Overrides:

execute in class ThreadPoolExecutor

getBatchJobService

public BatchJobService getBatchJobService()

Get the batch job service used to interact with the database.

Returns:

The batch job service used to interact with the database.

getBeanName

public String getBeanName()

Specified by:

getBeanName in interface com.revolsys.parallel.process.Process

getConfig

public CpfConfig getConfig()

getIn

public com.revolsys.parallel.channel.Channel<com.revolsys.identifier.Identifier> getIn()

getProcessNetwork

public com.revolsys.parallel.process.ProcessNetwork getProcessNetwork()

Specified by:

getProcessNetwork in interface com.revolsys.parallel.process.Process

processJob

protected abstract boolean processJob(com.revolsys.identifier.Identifier batchJobId)

run

public final void run()

Specified by:

run in interface Runnable

run

protected void run(com.revolsys.parallel.channel.Channel<com.revolsys.identifier.Identifier> in)

schedule

public void schedule(com.revolsys.identifier.Identifier batchJobId)

scheduleFromDatabase

public void scheduleFromDatabase(String moduleName,
                                 String businessApplicationName)

setBatchJobService

public void setBatchJobService(BatchJobService batchJobService)

Set the batch job service used to interact with the database.

Parameters:

batchJobService - The batch job service used to interact with the database.

setBeanName

public void setBeanName(String beanName)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware

setProcessNetwork

public void setProcessNetwork(com.revolsys.parallel.process.ProcessNetwork processNetwork)

Specified by:

setProcessNetwork in interface com.revolsys.parallel.process.Process

toString

public String toString()

Overrides:

toString in class ThreadPoolExecutor