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 and Description
boolean	checkReclaimStatus() This method is called automatically when a new file is opened.
String	debug()
void	debugWait()
void	forceMoveNextFile() Force the usage of a new JournalFile.
JournalFile	getCurrentFile()
JournalFile[]	getDataFiles() Returns the 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.journal.Journal

appendAddRecord, appendAddRecord, appendAddRecord, appendAddRecordTransactional, appendAddRecordTransactional, appendCommitRecord, appendCommitRecord, appendCommitRecord, appendDeleteRecord, appendDeleteRecord, appendDeleteRecordTransactional, appendDeleteRecordTransactional, appendDeleteRecordTransactional, appendPrepareRecord, appendPrepareRecord, appendPrepareRecord, appendRollbackRecord, appendRollbackRecord, appendUpdateRecord, appendUpdateRecord, appendUpdateRecord, appendUpdateRecordTransactional, appendUpdateRecordTransactional, createFilesForBackupSync, flush, getAlignment, getFileFactory, getNumberOfRecords, getUserVersion, lineUpContext, load, load, loadInternalOnly, loadSyncOnly, perfBlast, replicationSyncFinished, replicationSyncPreserveOldFiles, runDirectJournalBlast, scheduleCompactAndBlock, synchronizationLock, synchronizationUnlock

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

isStarted, start, stop

Method Detail

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

boolean checkReclaimStatus()
                    throws Exception

This method is called automatically when a new file is opened.

It will among other things, remove stale files and make them available for reuse.

This method locks the journal.

Returns:

true if it needs to re-check due to cleanup or other factors

Throws:

Exception

getDataFiles

JournalFile[] getDataFiles()

Description copied from interface: Journal

Returns the JournalFiles in use.

Specified by:

getDataFiles in interface Journal

Returns:

array with all JournalFiles in use