com.revolsys.gis.parallel

Class RecordStoreUpdateProcess

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

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

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

com.revolsys.gis.parallel.RecordStoreUpdateProcess

All Implemented Interfaces:

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

public class RecordStoreUpdateProcess
extends BaseInProcess<Record>

The RecordStoreUpdateProcess process reads each object from the input channel and updates the object in the record store based on the object's state.

The following actions will be performed based on the state of the object.

New

Insert the object into the record store.

Persisted

No action performed.

Modified

Update the object in the record store.

Deleted

Delete the object from the record store.

Constructor Summary

Constructors

Constructor and Description
RecordStoreUpdateProcess() Construct a new RecordStoreUpdateProcess.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
RecordStore	getRecordStore() Get the record store.
protected void	process(Channel<Record> in, Record object) Process each object from the channel
void	setRecordStore(RecordStore recordStore) Set the record store.

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

postRun, preRun, run

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

RecordStoreUpdateProcess

public RecordStoreUpdateProcess()

Construct a new RecordStoreUpdateProcess.

Method Detail

close

@PreDestroy
public void close()

getRecordStore

public RecordStore getRecordStore()

Get the record store.

Returns:

The record store.

process

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

Process each object from the channel

Overrides:

process in class BaseInProcess<Record>

Parameters:

in - The input channel.

object - The object to process.

setRecordStore

public void setRecordStore(RecordStore recordStore)

Set the record store.

Parameters:

recordStore - The record store.