com.rhi.architecture.parc.adapter.jdo
Class JDOOutputAdapter

java.lang.Object
  com.rhi.architecture.parc.adapter.AbstractOutputAdapter
      com.rhi.architecture.parc.adapter.jdo.JDOOutputAdapter

All Implemented Interfaces:

Adapter, OutputAdapter, java.lang.Runnable

public abstract class JDOOutputAdapter

extends AbstractOutputAdapter

JDO Output Adapter. Uses Castor to perform mapping from java objects to DB rows.

Since:

1.0

Author:

Pete McKinstry

Field Summary

Fields inherited from interface com.rhi.architecture.parc.OutputAdapter

DEFAULT_THREAD_MODE, RUN_AS_THREAD, RUN_AS_THREAD_KEY

Constructor Summary

JDOOutputAdapter()
Default constructor

Method Summary

void	cleanup() cleanup any resources.
java.util.Collection	handleValidRecords(java.util.Collection c, Transaction t) Handle persistence of valid records from the framework.
void	init(java.util.Properties props) Initialize the Castor data binding facilities so that the doWrite() method is ready to go.

Methods inherited from class com.rhi.architecture.parc.adapter.AbstractOutputAdapter

close, completeBatch, createTransaction, flush, getAuditAgent, handleErrorRecords, log, markComplete, run, setAuditAgent, setErrorChannel, setExceptionHandler, setValidChannel, write, writeErrorRecords, writeValidRecords

Methods inherited from class java.lang.Object

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

Constructor Detail

JDOOutputAdapter

public JDOOutputAdapter()

Default constructor

Since:

1.0

Method Detail

init

public void init(java.util.Properties props)
          throws InitializationException

Initialize the Castor data binding facilities so that the doWrite() method is ready to go.

Specified by:

init in interface OutputAdapter

Overrides:

init in class AbstractOutputAdapter

Parameters:

props -

Throws:

InitializationException

cleanup

public void cleanup()

cleanup any resources.

Specified by:

cleanup in interface OutputAdapter

Overrides:

cleanup in class AbstractOutputAdapter

handleValidRecords

public java.util.Collection handleValidRecords(java.util.Collection c,
                                               Transaction t)
                                        throws ProcessingException

Handle persistence of valid records from the framework.

Specified by:

handleValidRecords in class AbstractOutputAdapter

Parameters:

c - - valid records.

t - - the transaction to use when persisting the records.

Returns:

Collection - records errored during persistence.

Throws:

ProcessingException

Since:

1.0