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.
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 |
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 |
ReadOnlyAsyncDataManager
public ReadOnlyAsyncDataManager(ArrayList<File> dirs)
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
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.