org.apache.activemq.artemis.core.journal.impl

Class AbstractJournalUpdateTask

java.lang.Object

org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask

All Implemented Interfaces:

JournalReaderCallback

Direct Known Subclasses:

JournalCompactor

public abstract class AbstractJournalUpdateTask
extends Object
implements JournalReaderCallback

Super class for Journal maintenances such as clean up and Compactor

Field Summary

Fields

Modifier and Type	Field and Description
protected JournalFile	currentFile
static String	FILE_COMPACT_CONTROL
protected SequentialFileFactory	fileFactory
protected JournalFilesRepository	filesRepository
protected JournalImpl	journal
protected List<JournalFile>	newDataFiles
protected long	nextOrderingID
protected SequentialFile	sequentialFile

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractJournalUpdateTask(SequentialFileFactory fileFactory, JournalImpl journal, JournalFilesRepository filesRepository, Set<Long> recordsSnapshot, long nextOrderingID)

Method Summary

Modifier and Type	Method and Description
protected void	addToRecordsSnaptshot(long id)
void	flush() Write pending output into file
protected ActiveMQBuffer	getWritingChannel()
boolean	lookupRecord(long id)
protected void	openFile()
static SequentialFile	readControlFile(SequentialFileFactory fileFactory, List<String> dataFiles, List<String> newFiles, List<Pair<String,String>> renameFile)
static SequentialFile	writeControlFile(SequentialFileFactory fileFactory, List<JournalFile> files, List<JournalFile> newFiles, List<Pair<String,String>> renames)
protected void	writeEncoder(JournalInternalRecord record)
protected void	writeEncoder(JournalInternalRecord record, int txcounter)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.core.journal.impl.JournalReaderCallback

markAsDataFile, onReadAddRecord, onReadAddRecordTX, onReadCommitRecord, onReadDeleteRecord, onReadDeleteRecordTX, onReadPrepareRecord, onReadRollbackRecord, onReadUpdateRecord, onReadUpdateRecordTX

Field Detail

FILE_COMPACT_CONTROL

public static final String FILE_COMPACT_CONTROL

See Also:

Constant Field Values

journal

protected final JournalImpl journal

fileFactory

protected final SequentialFileFactory fileFactory

currentFile

protected JournalFile currentFile

sequentialFile

protected SequentialFile sequentialFile

filesRepository

protected final JournalFilesRepository filesRepository

nextOrderingID

protected long nextOrderingID

newDataFiles

protected final List<JournalFile> newDataFiles

Constructor Detail

AbstractJournalUpdateTask

protected AbstractJournalUpdateTask(SequentialFileFactory fileFactory,
                                    JournalImpl journal,
                                    JournalFilesRepository filesRepository,
                                    Set<Long> recordsSnapshot,
                                    long nextOrderingID)

Method Detail

writeControlFile

public static SequentialFile writeControlFile(SequentialFileFactory fileFactory,
                                              List<JournalFile> files,
                                              List<JournalFile> newFiles,
                                              List<Pair<String,String>> renames)
                                       throws Exception

Throws:

Exception

readControlFile

public static SequentialFile readControlFile(SequentialFileFactory fileFactory,
                                             List<String> dataFiles,
                                             List<String> newFiles,
                                             List<Pair<String,String>> renameFile)
                                      throws Exception

Throws:

Exception

flush

public void flush()
           throws Exception

Write pending output into file

Throws:

Exception

lookupRecord

public boolean lookupRecord(long id)

openFile

protected void openFile()
                 throws Exception

Throws:

Exception

addToRecordsSnaptshot

protected void addToRecordsSnaptshot(long id)

getWritingChannel

protected ActiveMQBuffer getWritingChannel()

Returns:

the writingChannel

writeEncoder

protected void writeEncoder(JournalInternalRecord record)
                     throws Exception

Throws:

Exception

writeEncoder

protected void writeEncoder(JournalInternalRecord record,
                            int txcounter)
                     throws Exception

Throws:

Exception