Package org.apache.activemq.artemis.core.journal

Interface TestableJournal

All Superinterfaces:

ActiveMQComponent, Journal

All Known Implementing Classes:

JournalImpl

public interface TestableJournal
extends Journal

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.activemq.artemis.core.journal.Journal

Journal.JournalState

Method Summary

Modifier and Type	Method	Description
void	checkReclaimStatus()
String	debug()
void	debugWait()
void	forceMoveNextFile()	Force the usage of a new JournalFile.
JournalFile	getCurrentFile()
JournalFile[]	getDataFiles()	Returns array with all JournalFiles in use.
int	getDataFilesCount()
String	getFileExtension()
String	getFilePrefix()
int	getFileSize()
int	getFreeFilesCount()
int	getIDMapSize()
int	getMaxAIO()
int	getMinFiles()
int	getOpenedFilesCount()
boolean	isAutoReclaim()
void	setAutoReclaim(boolean autoReclaim)
void	testCompact()

Methods inherited from interface org.apache.activemq.artemis.core.server.ActiveMQComponent

asyncStop, isStarted, start, stop

Methods inherited from interface org.apache.activemq.artemis.core.journal.Journal

appendAddEvent, appendAddRecord, appendAddRecord, appendAddRecord, appendAddRecord, appendAddRecord, appendAddRecordTransactional, appendAddRecordTransactional, appendAddRecordTransactional, appendCommitRecord, appendCommitRecord, appendCommitRecord, appendDeleteRecord, appendDeleteRecord, appendDeleteRecordTransactional, appendDeleteRecordTransactional, appendDeleteRecordTransactional, appendPrepareRecord, appendPrepareRecord, appendPrepareRecord, appendRollbackRecord, appendRollbackRecord, appendUpdateRecord, appendUpdateRecord, appendUpdateRecord, appendUpdateRecord, appendUpdateRecord, appendUpdateRecordTransactional, appendUpdateRecordTransactional, appendUpdateRecordTransactional, createFilesForBackupSync, flush, forceBackup, getAlignment, getCriticalErrorListener, getFileFactory, getHistoryFolder, getMaxRecordSize, getNumberOfRecords, getUserVersion, getWarningRecordSize, isHistory, isRemoveExtraFilesOnLoad, lineUpContext, load, load, load, load, load, loadInternalOnly, loadSyncOnly, processBackup, processBackupCleanup, replaceableRecord, replicationSyncFinished, replicationSyncPreserveOldFiles, scheduleCompactAndBlock, setCriticalErrorListener, setHistoryFolder, setRemoveExtraFilesOnLoad, synchronizationLock, synchronizationUnlock, tryAppendDeleteRecord, tryAppendDeleteRecord, tryAppendUpdateRecord, tryAppendUpdateRecord, tryAppendUpdateRecord, tryAppendUpdateRecord, tryAppendUpdateRecord

Method Details

getDataFilesCount

int getDataFilesCount()

getFreeFilesCount

int getFreeFilesCount()

getOpenedFilesCount

int getOpenedFilesCount()

getIDMapSize

int getIDMapSize()

debug

String debug()
      throws Exception

Throws:

Exception

debugWait

void debugWait()
        throws Exception

Throws:

Exception

getFileSize

int getFileSize()

Specified by:

getFileSize in interface Journal

getMinFiles

int getMinFiles()

getFilePrefix

String getFilePrefix()

getFileExtension

String getFileExtension()

getMaxAIO

int getMaxAIO()

forceMoveNextFile

void forceMoveNextFile()
                throws Exception

Description copied from interface: Journal

Force the usage of a new JournalFile.

Specified by:

forceMoveNextFile in interface Journal

Throws:

Exception

setAutoReclaim

void setAutoReclaim(boolean autoReclaim)

isAutoReclaim

boolean isAutoReclaim()

testCompact

void testCompact()

getCurrentFile

JournalFile getCurrentFile()

checkReclaimStatus

void checkReclaimStatus()
                 throws Exception

Throws:

Exception

getDataFiles

JournalFile[] getDataFiles()

Description copied from interface: Journal

Returns array with all JournalFiles in use.

Specified by:

getDataFiles in interface Journal

Returns:

array with all JournalFiles in use