com.revolsys.parallel.process

Class BaseInProcess<T>

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

com.revolsys.parallel.process.AbstractInProcess<T>

com.revolsys.parallel.process.BaseInProcess<T>

All Implemented Interfaces:

InProcess<T>, Process, Runnable, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

Direct Known Subclasses:

BlackHole, RecordStoreUpdateProcess, ScriptExecutorProcess, WriterProcess

public class BaseInProcess<T>
extends AbstractInProcess<T>

Constructor Summary

Constructors

Constructor and Description
BaseInProcess()
BaseInProcess(Channel<T> in)
BaseInProcess(int bufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	postRun(Channel<T> in)
protected void	preRun(Channel<T> in)
protected void	process(Channel<T> in, T object)
protected void	run(Channel<T> in)

Methods inherited from class com.revolsys.parallel.process.AbstractInProcess

destroy, getIn, getInBufferSize, init, run, setIn, setInBufferSize

Methods inherited from class com.revolsys.parallel.process.AbstractProcess

getBeanName, getProcessNetwork, setBeanName, setProcessNetwork, stop, toString

Methods inherited from class java.lang.Object

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

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

getBeanName, getProcessNetwork, setProcessNetwork

Methods inherited from interface org.springframework.beans.factory.BeanNameAware

setBeanName

Constructor Detail

BaseInProcess

public BaseInProcess()

BaseInProcess

public BaseInProcess(Channel<T> in)

BaseInProcess

public BaseInProcess(int bufferSize)

Method Detail

postRun

protected void postRun(Channel<T> in)

preRun

protected void preRun(Channel<T> in)

process

protected void process(Channel<T> in,
           T object)

run

protected final void run(Channel<T> in)

Specified by:

run in class AbstractInProcess<T>