net.cnri.apps.doserver.txnlog

Class AbstractTransactionQueue

java.lang.Object

net.cnri.apps.doserver.txnlog.AbstractTransactionQueue

Direct Known Subclasses:

ConcatenatedTransactionQueue, TransactionQueue, TransactionQueueBerkeleyDB

public abstract class AbstractTransactionQueue
extends java.lang.Object

Class responsible for keeping track of the transaction queue.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	AbstractTransactionQueue.CloseableEnumeration

Constructor Summary

Constructors

Constructor and Description
AbstractTransactionQueue()

Method Summary

Methods

Modifier and Type	Method and Description
void	addQueueListener(TransactionQueueListener l)
abstract void	addTransaction(Transaction txn) Log the specified transaction to the current queue (creating a new queue, if necessary
abstract AbstractTransactionQueue.CloseableEnumeration	getCloseableScanner(long lastTimestamp) Returns an Enumeration of Transaction objects starting after the given timestamp.
abstract long	getLastTimestamp()
java.util.Enumeration	getScanner(long lastTimestamp) Deprecated. Use #getCloseableScanner(long).
void	removeQueueListener(TransactionQueueListener l)
abstract void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractTransactionQueue

public AbstractTransactionQueue()

Method Detail

addQueueListener

public void addQueueListener(TransactionQueueListener l)

removeQueueListener

public void removeQueueListener(TransactionQueueListener l)

getLastTimestamp

public abstract long getLastTimestamp()

addTransaction

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

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

Throws:

java.lang.Exception

shutdown

public abstract void shutdown()

getScanner

@Deprecated
public final java.util.Enumeration getScanner(long lastTimestamp)
                                       throws java.lang.Exception

Deprecated. Use #getCloseableScanner(long).

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

Throws:

java.lang.Exception

getCloseableScanner

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

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

Throws:

java.lang.Exception