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.
| Constructor and Description |
|---|
RecordStoreUpdateProcess()
Construct a new RecordStoreUpdateProcess.
|
| 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.
|
postRun, preRun, rundestroy, getIn, getInBufferSize, init, run, setIn, setInBufferSizegetBeanName, getProcessNetwork, setBeanName, setProcessNetwork, stop, toStringclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetBeanName, getProcessNetwork, setProcessNetworkpublic RecordStoreUpdateProcess()
@PreDestroy public void close()
public RecordStore getRecordStore()
protected void process(Channel<Record> in, Record object)
process in class BaseInProcess<Record>in - The input channel.object - The object to process.public void setRecordStore(RecordStore recordStore)
recordStore - The record store.Copyright © 2015 Revolution Systems Inc.. All rights reserved.