com.revolsys.parallel.process

Class AbstractInOutProcess<I,O>

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

com.revolsys.parallel.process.AbstractInOutProcess<I,O>

All Implemented Interfaces:

InOutProcess<I,O>, InProcess<I>, OutProcess<O>, Process, Runnable, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

Direct Known Subclasses:

AbstractMergeProcess, AddDefaultValuesProcess, BaseInOutProcess, SynchronizationProcess

public abstract class AbstractInOutProcess<I,O>
extends AbstractProcess
implements InOutProcess<I,O>

Constructor Summary

Constructors

Constructor and Description
AbstractInOutProcess()
AbstractInOutProcess(Channel<I> in, Channel<O> out)

Method Summary

Methods

Modifier and Type	Method and Description
protected ChannelValueStore<I>	createInValueStore()
protected ChannelValueStore<O>	createOutValueStore()
protected void	destroy()
Channel<I>	getIn()
int	getInBufferSize()
Channel<O>	getOut()
int	getOutBufferSize()
protected void	init()
void	run()
protected abstract void	run(Channel<I> in, Channel<O> out)
void	setIn(Channel<I> in)
void	setInBufferSize(int inBufferSize)
void	setOut(Channel<O> out)
void	setOutBufferSize(int outBufferSize)

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

AbstractInOutProcess

public AbstractInOutProcess()

AbstractInOutProcess

public AbstractInOutProcess(Channel<I> in,
                    Channel<O> out)

Method Detail

createInValueStore

protected ChannelValueStore<I> createInValueStore()

createOutValueStore

protected ChannelValueStore<O> createOutValueStore()

destroy

protected void destroy()

getIn

public Channel<I> getIn()

Specified by:

getIn in interface InProcess<I>

Returns:

the in

getInBufferSize

public int getInBufferSize()

getOut

public Channel<O> getOut()

Specified by:

getOut in interface OutProcess<O>

Returns:

the out

getOutBufferSize

public int getOutBufferSize()

init

protected void init()

run

public final void run()

Specified by:

run in interface Runnable

run

protected abstract void run(Channel<I> in,
       Channel<O> out)

setIn

public void setIn(Channel<I> in)

Specified by:

setIn in interface InProcess<I>

Parameters:

in - the in to set

setInBufferSize

public void setInBufferSize(int inBufferSize)

setOut

public void setOut(Channel<O> out)

Specified by:

setOut in interface OutProcess<O>

Parameters:

out - the out to set

setOutBufferSize

public void setOutBufferSize(int outBufferSize)