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

java.lang.Object
  extended by org.apache.activemq.kaha.impl.async.AsyncDataManager
      extended by 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
ReadOnlyAsyncDataManager(ArrayList<File> dirs)
           
 
Method Summary
 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


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.