net.cnri.apps.doserver.txnlog

Class TransactionQueueBerkeleyDB

java.lang.Object

net.cnri.apps.doserver.txnlog.AbstractTransactionQueue

net.cnri.apps.doserver.txnlog.TransactionQueueBerkeleyDB

public class TransactionQueueBerkeleyDB
extends AbstractTransactionQueue

Class responsible for keeping track of the transactions. Transactions are stored in a BerkleyDB. The berkelydb database files will be stored in a subfolder of /txns

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TransactionQueueBerkeleyDB.QueueScanner

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

AbstractTransactionQueue.CloseableEnumeration

Constructor Summary

Constructors

Constructor and Description
TransactionQueueBerkeleyDB(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
static long	fromByteArray(byte[] bytes)
AbstractTransactionQueue.CloseableEnumeration	getCloseableScanner(long lastTimestamp) Returns an Enumeration of Transaction objects starting after the given timestamp.
long	getLastTimestamp()
void	shutdown()
static byte[]	toByteArray(long data)

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

TransactionQueueBerkeleyDB

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

Throws:

java.lang.Exception

Method Detail

getLastTimestamp

public long getLastTimestamp()

Specified by:

getLastTimestamp in class AbstractTransactionQueue

addTransaction

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

Description copied from class: AbstractTransactionQueue

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

Specified by:

addTransaction in class AbstractTransactionQueue

Throws:

java.lang.Exception

shutdown

public void shutdown()

Specified by:

shutdown in class AbstractTransactionQueue

getCloseableScanner

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

Description copied from class: AbstractTransactionQueue

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

Specified by:

getCloseableScanner in class AbstractTransactionQueue

Throws:

java.lang.Exception

toByteArray

public static byte[] toByteArray(long data)

fromByteArray

public static long fromByteArray(byte[] bytes)