org.apache.activemq.kaha.impl.async

Class ReadOnlyAsyncDataManager

java.lang.Object

org.apache.activemq.kaha.impl.async.AsyncDataManager

org.apache.activemq.kaha.impl.async.ReadOnlyAsyncDataManager

public class ReadOnlyAsyncDataManager
extends AsyncDataManager

An AsyncDataManager that works in read only mode against multiple data directories. Useful for reading back archived data files.

Field Summary

Fields inherited from class org.apache.activemq.kaha.impl.async.AsyncDataManager

accessorPool, appender, archiveDataLogs, cleanupTask, CONTROL_RECORD_MAX_LENGTH, controlFile, currentWriteFile, DATA_ITEM_TYPE, DEFAULT_ARCHIVE_DIRECTORY, DEFAULT_CLEANUP_INTERVAL, DEFAULT_DIRECTORY, DEFAULT_FILE_PREFIX, DEFAULT_MAX_FILE_LENGTH, directory, directoryArchive, fileByFileMap, fileMap, filePrefix, inflightWrites, ITEM_FOOT_SPACE, ITEM_HEAD_EOR, ITEM_HEAD_FOOT_SPACE, ITEM_HEAD_OFFSET_TO_SOR, ITEM_HEAD_RESERVED_SPACE, ITEM_HEAD_SOR, ITEM_HEAD_SPACE, lastAppendLocation, mark, maxFileLength, PREFERED_DIFF, preferedFileLength, REDO_ITEM_TYPE, scheduler, started, storeSize, useNio

Constructor Summary

Constructors

Constructor and Description
ReadOnlyAsyncDataManager(ArrayList<File> dirs)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
boolean	delete()
Location	getFirstLocation()
void	start()

Methods inherited from class org.apache.activemq.kaha.impl.async.AsyncDataManager

addInterestInFile, consolidateDataFiles, consolidateDataFilesNotIn, consolidateDataFilesNotIn, getCurrentDataFileId, getDirectory, getDirectoryArchive, getDiskSize, getDiskSizeUntil, getFilePrefix, getFiles, getInflightWrites, getLastAppendLocation, getMark, getMaxFileLength, getNextLocation, getNextLocation, getNextLocation, isArchiveDataLogs, isUseNio, lock, read, recoveryCheck, removeInterestInFile, removeLocation, setArchiveDataLogs, setDirectory, setDirectoryArchive, setFilePrefix, setLastAppendLocation, setMark, setMaxFileLength, setUseNio, storeState, toString, unmarshallState, update, write, write, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

ReadOnlyAsyncDataManager

public ReadOnlyAsyncDataManager(ArrayList<File> dirs)

Method Detail

start

public void start()
           throws IOException

Overrides:

start in class AsyncDataManager

Throws:

IOException

close

public void close()
           throws IOException

Overrides:

close in class AsyncDataManager

Throws:

IOException

getFirstLocation

public Location getFirstLocation()
                          throws IllegalStateException,
                                 IOException

Throws:

IllegalStateException

IOException

delete

public boolean delete()
               throws IOException

Overrides:

delete in class AsyncDataManager

Throws:

IOException