net.cnri.apps.doserver.txnlog

Class TransactionQueue

java.lang.Object

net.cnri.apps.doserver.txnlog.AbstractTransactionQueue

net.cnri.apps.doserver.txnlog.TransactionQueue

public class TransactionQueue
extends AbstractTransactionQueue

Class responsible for keeping track of the different transaction queue files. The transaction queue is separated into separate files so that it will be easy to wipe out old transactions (just delete the old files). It also makes replication slightly faster since the entire queue doesn't need to be scanned when starting replication at a certain transaction ID.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	TransactionQueue.QueueScanner

Nested classes/interfaces inherited from class net.cnri.apps.doserver.txnlog.AbstractTransactionQueue

AbstractTransactionQueue.CloseableEnumeration

Constructor Summary

Constructors

Constructor and Description
TransactionQueue(java.io.File queueDir)

Method Summary

Methods

Modifier and Type	Method and Description
void	addTransaction(Transaction txn) Log the specified transaction to the current queue (creating a new queue, if necessary
void	finalize()
AbstractTransactionQueue.CloseableEnumeration	getCloseableScanner(long lastTimestamp) Returns an Enumeration of Transaction objects starting after the given timestamp.
long	getFirstDate()
long	getLastTimestamp()
void	shutdown()

Methods inherited from class net.cnri.apps.doserver.txnlog.AbstractTransactionQueue

addQueueListener, getScanner, removeQueueListener

Methods inherited from class java.lang.Object

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

Constructor Detail

TransactionQueue

public TransactionQueue(java.io.File queueDir)
                 throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

getLastTimestamp

public long getLastTimestamp()

Specified by:

getLastTimestamp in class AbstractTransactionQueue

getFirstDate

public long getFirstDate()

addTransaction

public void addTransaction(Transaction txn)
                    throws java.lang.Exception

Log the specified transaction to the current queue (creating a new queue, if necessary

Specified by:

addTransaction in class AbstractTransactionQueue

Throws:

java.lang.Exception

finalize

public void finalize()

Overrides:

finalize in class java.lang.Object

shutdown

public void shutdown()

Specified by:

shutdown in class AbstractTransactionQueue

getCloseableScanner

public AbstractTransactionQueue.CloseableEnumeration getCloseableScanner(long lastTimestamp)
                                                                  throws java.lang.Exception

Returns an Enumeration of Transaction objects starting after the given timestamp.

Specified by:

getCloseableScanner in class AbstractTransactionQueue

Throws:

java.lang.Exception