Uses of Class
com.rhi.architecture.parc.ProcessingException

Packages that use ProcessingException

com.rhi.architecture.parc
com.rhi.architecture.parc.adapter
com.rhi.architecture.parc.adapter.file
com.rhi.architecture.parc.adapter.jdbc
com.rhi.architecture.parc.adapter.jdo
com.rhi.architecture.parc.adapter.xml
com.rhi.architecture.parc.filter

Uses of ProcessingException in com.rhi.architecture.parc

Methods in com.rhi.architecture.parc with parameters of type ProcessingException

void	ExceptionHandler.reportException(ProcessingException e) Method used by Filters to report a fatal error.

Methods in com.rhi.architecture.parc that throw ProcessingException

void	SingleCallStrategy.run() Perform processing using concrete execution strategy.
void	PipelineStrategy.run() The run method provides the strategy implementation It should run the pipeline using whatever strategy it provides.
void	LinkedListQueue.push(java.util.Collection collection) Push an entire collection into the channel.
java.util.Collection	LinkedListQueue.pull(int max) Pull a set of records out of the channel for processing.
void	InfiniteLoopStrategy.run() Perform processing using concrete execution strategy.
void	ConditionalLoopStrategy.run() The ConditionalLoopStrategy continues executing until the input adapter finds no more work.
void	ArrayListQueue.push(java.util.Collection collection) Push an entire collection into the channel.
java.util.Collection	ArrayListQueue.pull(int max) Pull a set of records out of the channel for processing.
void	AbstractFilter.process() Deprecated. Push a collection of records through the filter.
void	SingleCallApplicationStrategy.run() The SingleCallApplicationStrategy does a single execution of the Process.
void	SerialMTPipeline.process() Run the filter set.
void	ProcessSet.run() Run each Process w/in the set serially in the order they were added.
void	PipelineProcess.run() Run the Process.
void	ParallelMTPipeline.process() Run the filter set.
void	Process.run() The run method provides the strategy implementation It should run the pipeline using whatever strategy it provides.
void	ApplicationStrategy.run() The run method provides the strategy implementation It should run the pipeline using whatever strategy it provides.
void	Filter.process() do filter processing.
void	ExceptionHandler.rethrowException() Rethrow the first reported exception.
java.util.Collection	Supplier.pull(int max) Get a collection from the channel, possibly waiting indefinitely until a group of items can be returned.
void	Consumer.push(java.util.Collection c) Place a collection of items in the channel, possibly waiting indefinitely until it can be accepted.
void	Channel.push(java.util.Collection set) Place a collection of Records in the channel, blocking until they are all accepted.
java.util.Collection	Channel.pull(int max) Extract a collection of records from the Channel up to the provided maximum record count.
void	Pipeline.process() Run the filter.
void	OutputAdapter.close() Close is called outside of the strategy to allow the output adapter to commit any work that should only be done once per interface run.
int	InputAdapter.push(Channel ch) Send a set of records requiring processing to the pipeline.
void	ExecutionStrategy.run() The run method provides the strategy implementation It should run the pipeline using whatever strategy it provides.
protected int	AbstractExecutionStrategy.doRun() ExecutionStrategies can use this method to run the pipeline using shared standard logic.
protected java.util.Properties	AbstractExecutionStrategy.getProperties() Get the configuration settings from the ConfigFacility

Uses of ProcessingException in com.rhi.architecture.parc.adapter

Methods in com.rhi.architecture.parc.adapter that throw ProcessingException

void	ValidRecordsTask.processRecords(java.util.Collection records, Transaction transaction) Process Error records and update audit information.
protected abstract void	OutputRecordsTask.processRecords(java.util.Collection records, Transaction transacttion) Abstract method overriden by the concreate classes to perform processing specific to each subclass.
void	ErrorRecordsTask.processRecords(java.util.Collection records, Transaction transaction) Process Error records and update audit information.
void	AbstractOutputAdapter.flush() Do any required processing prior to completing the batch cycle.
void	AbstractOutputAdapter.write(Channel ch, Channel err) Persist valid and errored records to the appropriate data store.
void	AbstractOutputAdapter.writeValidRecords(Channel ch) To Improve Performance, a thread pool is created and used.
void	AbstractOutputAdapter.writeErrorRecords(Channel err) To Improve Performance, a thread pool is created and used.
protected abstract java.util.Collection	AbstractOutputAdapter.handleValidRecords(java.util.Collection c, Transaction t) Defer handling of valid records to sub-classes..
protected abstract void	AbstractOutputAdapter.handleErrorRecords(java.util.Collection c, Transaction t) Defer handling of valid records to sub-classes..
protected void	AbstractOutputAdapter.completeBatch(Transaction transaction) Do any non-record level processing required to finish this batch cycle.
void	AbstractOutputAdapter.close() No op by default.
Transaction	AbstractOutputAdapter.createTransaction() Create a transaction of the appropriate type.
int	AbstractInputAdapter.push(Channel validChannel) Push a set of records into the pipeline.
protected abstract java.util.Collection	AbstractInputAdapter.loadBatch() Retrieve the batch.

Uses of ProcessingException in com.rhi.architecture.parc.adapter.file

Methods in com.rhi.architecture.parc.adapter.file that throw ProcessingException

protected java.util.Collection	AbstractFileInputAdapter.loadBatch() Reads the file one record at a time using readRecordString(), parses each record into column values and passes this list of colums to the method readRow().
protected abstract Record	AbstractFileInputAdapter.readRow(java.util.ArrayList al) Extract the attributes from the ArrayList and return a Record object.
java.util.Collection	FlatFileOutputAdapter.handleValidRecords(java.util.Collection c, Transaction t) Persist Valid Records - FlatFileOutputAdapter does not
protected void	FlatFileOutputAdapter.handleErrorRecords(java.util.Collection c, Transaction t) General Case implementation for persisting error records.

Uses of ProcessingException in com.rhi.architecture.parc.adapter.jdbc

Methods in com.rhi.architecture.parc.adapter.jdbc that throw ProcessingException

protected java.util.Collection	JDBCOutputAdapter.handleValidRecords(java.util.Collection c, Transaction t) Handle persistence of valid records from the framework.
protected boolean	JDBCOutputAdapter.persistValidRecord(Record record, Transaction t) Add or update valid records to the output table.
protected java.sql.PreparedStatement	JDBCOutputAdapter.prepareValidStatement(Record record, java.sql.Connection conn) Get SQL, prepare SQL statement, and set all the appropriate fields.
protected void	JDBCOutputAdapter.setValidStatementFields(Record record, java.sql.PreparedStatement stmt) Set all the fields on the prepared statement using the output record.
protected void	JDBCOutputAdapter.handleErrorRecords(java.util.Collection c, Transaction t) General Case implementation for persisting error records.
protected boolean	JDBCOutputAdapter.persistErrorRecord(Error error, Transaction t) Add or update the error record.
protected java.sql.PreparedStatement	JDBCOutputAdapter.prepareErrorStatement(Error error, java.sql.Connection conn) Get SQL, prepare SQL statement, and set all the error fields.
protected void	JDBCOutputAdapter.setErrorStatementFields(Error error, java.sql.PreparedStatement stmt) Set the appropriate fields on the prepared statement Not abstract so that sub-classes that don't use prepareErrorStatement need not implement this w/ a no-op, but if anyone who _should_ implement it doesn't, it will "fail fast" & let them know immediately.
protected boolean	JDBCOutputAdapter.updateSourceForValidRecord(Record record, Transaction t) Mark the source record complete.
protected java.sql.PreparedStatement	JDBCOutputAdapter.prepareStatementForValidSourceRecord(Record record, java.sql.Connection conn) Get SQL, prepare SQL statement, and set all the error fields.
protected void	JDBCOutputAdapter.setStatementForValidSourceRecord(Record record, java.sql.PreparedStatement stmt) Set the appropriate fields on the prepared statement Not abstract so that sub-classes that don't use prepareErrorStatement need not implement this w/ a no-op, but if anyone who _should_ implement it doesn't, it will "fail fast" & let them know immediately.
protected boolean	JDBCOutputAdapter.updateSourceForErrorRecord(Record record, Transaction t) Mark the source record complete.
protected java.sql.PreparedStatement	JDBCOutputAdapter.prepareStatementForErrorSourceRecord(Record record, java.sql.Connection conn) Get SQL, prepare SQL statement, and set all the error fields.
protected void	JDBCOutputAdapter.setStatementForErrorSourceRecord(Record record, java.sql.PreparedStatement stmt) Set the appropriate fields on the prepared statement Not abstract so that sub-classes that don't use prepareErrorStatement need not implement this w/ a no-op, but if anyone who _should_ implement it doesn't, it will "fail fast" & let them know immediately.
protected java.util.Collection	JDBCInputAdapter.loadBatch() Retrieve all the source records that should be processed by the pipeline.

Uses of ProcessingException in com.rhi.architecture.parc.adapter.jdo

Methods in com.rhi.architecture.parc.adapter.jdo that throw ProcessingException

java.util.Collection	JDOOutputAdapter.handleValidRecords(java.util.Collection c, Transaction t) Handle persistence of valid records from the framework.
protected java.util.Collection	JDOInputAdapter.loadBatch() Push a dummy set of records into the pipeline.

Uses of ProcessingException in com.rhi.architecture.parc.adapter.xml

Methods in com.rhi.architecture.parc.adapter.xml that throw ProcessingException

java.util.Collection	XMLOutputAdapter.handleValidRecords(java.util.Collection c, Transaction t) Handle persistence of valid records from the framework.
protected void	XMLOutputAdapter.handleErrorRecords(java.util.Collection c, Transaction t) Stream errored records to file in XML format.
protected java.util.Collection	XMLInputAdapter.loadBatch() Retrieve the batch.

Uses of ProcessingException in com.rhi.architecture.parc.filter

Methods in com.rhi.architecture.parc.filter that throw ProcessingException

void	NotificationFilter.process() Push a collection of records through the filter.
void	FilterSet.process() do filter processing.
protected abstract java.util.Collection	AbstractFilter.doWork(java.util.Collection in) Template method to facilitate simple Filter implementations.
void	PollingFilter.process() Push a collection of records through the filter.