Class ReadOnlyJournal
- java.lang.Object
-
- org.apache.activemq.store.kahadb.disk.journal.Journal
-
- org.apache.activemq.store.kahadb.disk.journal.ReadOnlyJournal
-
public class ReadOnlyJournal extends Journal
An AsyncDataManager that works in read only mode against multiple data directories. Useful for reading back archived data files.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.activemq.store.kahadb.disk.journal.Journal
Journal.DataFileRemovedListener, Journal.JournalDiskSyncStrategy, Journal.PreallocationScope, Journal.PreallocationStrategy, Journal.WriteCommand, Journal.WriteKey
-
-
Field Summary
-
Fields inherited from class org.apache.activemq.store.kahadb.disk.journal.Journal
accessorPool, appender, archiveDataLogs, BATCH_CONTROL_RECORD_HEADER, BATCH_CONTROL_RECORD_MAGIC, BATCH_CONTROL_RECORD_SIZE, BATCH_CONTROL_RECORD_TYPE, CALLER_BUFFER_APPENDER, callerBufferAppender, checkForCorruptionOnStartup, checksum, cleanupTask, dataFiles, DEFAULT_ARCHIVE_DIRECTORY, DEFAULT_CLEANUP_INTERVAL, DEFAULT_DIRECTORY, DEFAULT_FILE_PREFIX, DEFAULT_FILE_SUFFIX, DEFAULT_MAX_FILE_LENGTH, DEFAULT_MAX_WRITE_BATCH_SIZE, directory, directoryArchive, EMPTY_BATCH_CONTROL_RECORD, enableAsyncDiskSync, EOF_EOT, EOF_INT, EOF_RECORD, fileByFileMap, fileMap, filePrefix, fileSuffix, inflightWrites, journalDiskSyncStrategy, lastAppendLocation, maxFileLength, preallocationScope, preallocationStrategy, RECORD_HEAD_SPACE, started, totalLength, USER_RECORD_TYPE, writeBatchSize
-
-
Constructor Summary
Constructors Constructor Description ReadOnlyJournal(ArrayList<File> dirs)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
boolean
delete()
Location
getFirstLocation()
void
start()
-
Methods inherited from class org.apache.activemq.store.kahadb.disk.journal.Journal
allowIOResumption, cleanup, corruptRecoveryLocation, getAccessorPool, getCleanupInterval, getCurrentDataFile, getCurrentDataFileId, getDataFileById, getDirectory, getDirectoryArchive, getDiskSize, getFile, getFileMap, getFilePrefix, getFiles, getFileSuffix, getInflightWrites, getJournalDiskSyncStrategy, getLastAppendLocation, getMaxFileLength, getNextLocation, getNextLocation, getPreallocationScope, getPreallocationStrategy, getReplicationTarget, getWriteBatchSize, isArchiveDataLogs, isCheckForCorruptionOnStartup, isChecksum, isEnableAsyncDiskSync, isJournalDiskSyncPeriodic, isUnusedPreallocated, length, preallocateEntireJournalDataFile, read, recoveryCheck, removeDataFiles, reserveDataFile, rotateWriteFile, setArchiveDataLogs, setCheckForCorruptionOnStartup, setChecksum, setCleanupInterval, setDataFileRemovedListener, setDirectory, setDirectoryArchive, setEnableAsyncDiskSync, setFilePrefix, setFileSuffix, setJournalDiskSyncStrategy, setLastAppendLocation, setMaxFileLength, setPreallocationScope, setPreallocationStrategy, setReplicationTarget, setSizeAccumulator, setWriteBatchSize, toString, update, write, write
-
-
-
-
Method Detail
-
start
public void start() throws IOException
- Overrides:
start
in classJournal
- Throws:
IOException
-
close
public void close() throws IOException
- Overrides:
close
in classJournal
- Throws:
IOException
-
getFirstLocation
public Location getFirstLocation() throws IllegalStateException, IOException
- Throws:
IllegalStateException
IOException
-
delete
public boolean delete() throws IOException
- Overrides:
delete
in classJournal
- Throws:
IOException
-
-