org.openanzo.model.transaction.impl
Class RDBPersistedTransactionQueue

java.lang.Object
  org.openanzo.model.transaction.impl.TransactionQueue
      org.openanzo.model.transaction.impl.RDBPersistedTransactionQueue

All Implemented Interfaces:

ITransactionQueue

public class RDBPersistedTransactionQueue
extends TransactionQueue

TransactionQueue that is backed by an RDB persisted store

Author:

Matthew Roy ( mroy@cambridgesemantics.com )

Constructor Summary

RDBPersistedTransactionQueue(RDBNamedGraphContainer container, boolean clearOnStartup)
Create a RDBPersistedTransactionQueue with given properties

Method Summary

ITransaction	createNewTransaction()
void	push(ITransaction transaction, boolean saveTransaction) Push a transaction onto the queue, this will commit the currentTransaction if not null.

Methods inherited from class org.openanzo.model.transaction.impl.TransactionQueue

abortCurrentTransaction, addTransactionQueueListener, clear, getCurrentTransaction, getSize, getTransactions, queueCurrentTransaction, removeTransactionHandler, removeTransactionQueueListener, setTransactionHandler, transactionsCommitted

Methods inherited from class java.lang.Object

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

Constructor Detail

RDBPersistedTransactionQueue

public RDBPersistedTransactionQueue(RDBNamedGraphContainer container,
                                    boolean clearOnStartup)
                             throws AnzoException

Create a RDBPersistedTransactionQueue with given properties

Parameters:

container - JDBC container for data

clearOnStartup - Clear the contents of the transaction queue on startup

Throws:

AnzoException - if there was an error clearing or loading the transaction queue

Method Detail

push

public void push(ITransaction transaction,
                 boolean saveTransaction)
          throws AnzoException

Description copied from interface: ITransactionQueue

Push a transaction onto the queue, this will commit the currentTransaction if not null.

Specified by:

push in interface ITransactionQueue

Overrides:

push in class TransactionQueue

Parameters:

transaction - Transaction to push onto queue.

saveTransaction - Whether this transaction needs to be persisted when added. If loading persisted transactions, they might only need to added, and not saved.

Throws:

AnzoException

createNewTransaction

public ITransaction createNewTransaction()