net.cnri.apps.doserver.txnlog

Class ConcatenatedTransactionQueue

java.lang.Object

net.cnri.apps.doserver.txnlog.AbstractTransactionQueue

net.cnri.apps.doserver.txnlog.ConcatenatedTransactionQueue

public class ConcatenatedTransactionQueue
extends AbstractTransactionQueue

Given the old style file based transaction queue and the new style queue this class provides a common interface concatenating the two queues allowing the data to be iterated over as if in a single queue.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ConcatenatedTransactionQueue.QueueScanner

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

AbstractTransactionQueue.CloseableEnumeration

Constructor Summary

Constructors

Constructor and Description
ConcatenatedTransactionQueue(TransactionQueue oldQueue, AbstractTransactionQueue currentQueue)

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
AbstractTransactionQueue.CloseableEnumeration	getCloseableScanner(long lastTimestamp) Returns an Enumeration of Transaction objects starting after the given timestamp.
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

ConcatenatedTransactionQueue

public ConcatenatedTransactionQueue(TransactionQueue oldQueue,
                            AbstractTransactionQueue currentQueue)

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