Skip navigation links
ActiveMQ Artemis Journal 1.5.5.012-redhat-1
A B C D E F G H I J L M N O P R S T U V W 

A

AbstractJournalUpdateTask - Class in org.apache.activemq.artemis.core.journal.impl
Super class for Journal maintenances such as clean up and Compactor
AbstractJournalUpdateTask(SequentialFileFactory, JournalImpl, JournalFilesRepository, Set<Long>, long) - Constructor for class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
AbstractSequentialFile - Class in org.apache.activemq.artemis.core.io
 
AbstractSequentialFile(File, String, SequentialFileFactory, Executor) - Constructor for class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
AbstractSequentialFile.LocalBufferObserver - Class in org.apache.activemq.artemis.core.io
 
AbstractSequentialFileFactory - Class in org.apache.activemq.artemis.core.io
An abstract SequentialFileFactory containing basic functionality for both AIO and NIO SequentialFactories
AbstractSequentialFileFactory(File, boolean, int, int, int, boolean, IOCriticalErrorListener) - Constructor for class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
activateBuffer(SequentialFile) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
activateBuffer(SequentialFile) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
activateBuffer(SequentialFile) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
ActiveMQFileLock - Class in org.apache.activemq.artemis.core.io.aio
 
ActiveMQFileLock(LibaioFile) - Constructor for class org.apache.activemq.artemis.core.io.aio.ActiveMQFileLock
 
ActiveMQJournalBundle - Interface in org.apache.activemq.artemis.journal
Logger Code 14 each message id must be 6 digits long starting with 14, the 3rd digit should be 9 so 149000 to 149999
ActiveMQJournalLogger - Interface in org.apache.activemq.artemis.journal
Logger Code 14 each message id must be 6 digits long starting with 14, the 3rd digit donates the level so INF0 1 WARN 2 DEBUG 3 ERROR 4 TRACE 5 FATAL 6 so an INFO message would be 141000 to 141999
add - Variable in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalAddRecord
 
ADD_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
ADD_RECORD_TX - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
addBytes(ActiveMQBuffer, boolean, IOCallback) - Method in class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
 
addBytes(EncodingSupport, boolean, IOCallback) - Method in class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
 
addCommandCommit(JournalTransaction, JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
addCommandDelete(long, JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
addCommandRollback(JournalTransaction, JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
addCommandUpdate(long, JournalFile, int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
addDataFileOnBottom(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
addDataFileOnTop(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
addFreeFile(JournalFile, boolean) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
addFreeFile(JournalFile, boolean, boolean) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
addNegative(JournalFile, long) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
addPendingTransaction(long, long[]) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
This methods informs the Compactor about the existence of a pending (non committed) transaction
addPositive(JournalFile, long, int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
addPreparedTransaction(PreparedTransactionInfo) - Method in interface org.apache.activemq.artemis.core.journal.LoaderCallback
 
addRecord(RecordInfo) - Method in interface org.apache.activemq.artemis.core.journal.LoaderCallback
 
addSize(int) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
addSize(int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
addToRecordsSnaptshot(long) - Method in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
AIOSequentialCallback() - Constructor for class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory.AIOSequentialCallback
 
AIOSequentialFile - Class in org.apache.activemq.artemis.core.io.aio
 
AIOSequentialFile(AIOSequentialFileFactory, int, long, File, String, Executor) - Constructor for class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
AIOSequentialFileFactory - Class in org.apache.activemq.artemis.core.io.aio
 
AIOSequentialFileFactory(File, int) - Constructor for class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
AIOSequentialFileFactory(File, IOCriticalErrorListener, int) - Constructor for class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
AIOSequentialFileFactory(File, int, int, int, boolean) - Constructor for class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
AIOSequentialFileFactory(File, int, int, int, boolean, IOCriticalErrorListener) - Constructor for class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
AIOSequentialFileFactory.AIOSequentialCallback - Class in org.apache.activemq.artemis.core.io.aio
The same callback is used for Runnable executor.
alignment - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
allocateDirectBuffer(int) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
allocateDirectBuffer(int) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
allocateDirectBuffer(int) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
allocateDirectBuffer(int) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
used for cases where you need direct buffer outside of the journal context.
allocateDirectByteBuffer(int) - Static method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
appendAddRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
appendAddRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
appendAddRecord(long, byte, byte[], boolean) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendAddRecord(long, byte, EncodingSupport, boolean) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendAddRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendAddRecordTransactional(long, long, byte, EncodingSupport) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
appendAddRecordTransactional(long, long, byte, EncodingSupport) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
appendAddRecordTransactional(long, long, byte, byte[]) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendAddRecordTransactional(long, long, byte, EncodingSupport) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendCommitRecord(long, boolean, IOCompletion, boolean) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
appendCommitRecord(long, boolean, IOCompletion, boolean) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
Regarding the number of operations in a given file see JournalCompleteRecordTX.
appendCommitRecord(long, boolean) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendCommitRecord(long, boolean, IOCompletion) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendCommitRecord(long, boolean, IOCompletion, boolean) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendDeleteRecord(long, boolean, IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
appendDeleteRecord(long, boolean, IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
appendDeleteRecord(long, boolean) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendDeleteRecord(long, boolean, IOCompletion) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendDeleteRecordTransactional(long, long, EncodingSupport) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
appendDeleteRecordTransactional(long, long, EncodingSupport) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
appendDeleteRecordTransactional(long, long, byte[]) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendDeleteRecordTransactional(long, long, EncodingSupport) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendDeleteRecordTransactional(long, long) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendPrepareRecord(long, EncodingSupport, boolean, IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
appendPrepareRecord(long, EncodingSupport, boolean, IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
If the system crashed after a prepare was called, it should store information that is required to bring the transaction back to a state it could be committed.
appendPrepareRecord(long, EncodingSupport, boolean) - Method in interface org.apache.activemq.artemis.core.journal.Journal
If the system crashed after a prepare was called, it should store information that is required to bring the transaction back to a state it could be committed.
appendPrepareRecord(long, EncodingSupport, boolean, IOCompletion) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendPrepareRecord(long, byte[], boolean) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendRollbackRecord(long, boolean, IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
appendRollbackRecord(long, boolean, IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
appendRollbackRecord(long, boolean) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendRollbackRecord(long, boolean, IOCompletion) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendUpdateRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
appendUpdateRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
appendUpdateRecord(long, byte, byte[], boolean) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendUpdateRecord(long, byte, EncodingSupport, boolean) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendUpdateRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendUpdateRecordTransactional(long, long, byte, EncodingSupport) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
appendUpdateRecordTransactional(long, long, byte, EncodingSupport) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
appendUpdateRecordTransactional(long, long, byte, byte[]) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
appendUpdateRecordTransactional(long, long, byte, EncodingSupport) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 

B

bufferSize - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
bufferTimeout - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
BUNDLE - Static variable in interface org.apache.activemq.artemis.journal.ActiveMQJournalBundle
 
ByteArrayEncoding - Class in org.apache.activemq.artemis.core.journal.impl.dataformat
 
ByteArrayEncoding(byte[]) - Constructor for class org.apache.activemq.artemis.core.journal.impl.dataformat.ByteArrayEncoding
 

C

calculateBlockSize(int) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
calculateBlockSize(int) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
calculateBlockSize(int) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
calculateBlockSize(int) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
calculateBlockStart(int) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
calculateBlockStart(int) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
calculateBlockStart(int) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
calculateNextfileID(List<JournalFile>) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
callbackError(String) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
checkDataFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
checkErrorCondition() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
checkFiles() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
checkReclaimStatus() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
checkReclaimStatus() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
This method is called automatically when a new file is opened.
checkSize(int) - Method in class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
Verify if the size fits the buffer
chunkBytes() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
chunkBytes(long) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
clear() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
clear() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
clearBuffer(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
clearBuffer(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
clearBuffer(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
clearBuffer(ByteBuffer) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
clearDataFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
cloneFile() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
cloneFile() - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
cloneFile() - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
close() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
close() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
close() - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
close() - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
closeFile(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
commit(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
The caller of this method needs to guarantee appendLock.lock at the journal.
COMMIT_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
compact() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
Note: This method can't be called from the main executor, as it will invoke other methods depending on it.
compactCount - Variable in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord
 
compactCount - Variable in class org.apache.activemq.artemis.core.journal.RecordInfo
How many times this record was compacted (up to 7 times) After the record has reached 7 times, it will always be 7 As we only store up to 0x7 binary, as part of the recordID (binary 111)
compactingWithNoAddRecord(Long) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
compactMergeError(Long) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
compactReadError(JournalFile) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
compareTo(AIOSequentialFileFactory.AIOSequentialCallback) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory.AIOSequentialCallback
 
copyData(SequentialFile, SequentialFile, ByteBuffer) - Static method in class org.apache.activemq.artemis.core.io.util.FileIOUtil
 
copyTo(SequentialFile) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
copyTo(SequentialFile) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
copyTo(SequentialFile) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
couldNotCompleteTask(Exception, String) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
couldNotGetLock(String) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
couldNotRemoveFile(JournalFile) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
couldNotStopCompactor() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
couldNotStopJournalAppendExecutor() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
couldNotStopJournalExecutor() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
countUp() - Method in class org.apache.activemq.artemis.core.journal.impl.TransactionCallback
 
createControlFile(List<JournalFile>, List<JournalFile>, Pair<String, String>) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
createDirs() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
Create the directory if it doesn't exist yet
createDirs() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
createDirs() - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
Creates the directory if it does not exist yet.
createFilesForBackupSync(long[]) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
createFilesForBackupSync(long[]) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
Returns Map with a JournalFile for all existing files.
createFilesForBackupSync(long[]) - Method in interface org.apache.activemq.artemis.core.journal.Journal
Reserves journal file IDs, creates the necessary files for synchronization, and places references to these (reserved for sync) files in the map.
createRemoteBackupSyncFile(long) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
Creates files for journal synchronization of a replicated backup.
createSequentialFile(String) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
createSequentialFile(String) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
createSequentialFile(String) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
createSequentialFile(String) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
currentFile - Variable in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
currentFile - Variable in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
currentFile(Long, Long, Long, Boolean) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 

D

data - Variable in class org.apache.activemq.artemis.core.journal.RecordInfo
 
dataSync - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
deactivateBuffer() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
deactivateBuffer() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
deactivateBuffer() - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
debug() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
Receive debug information about the journal
debug() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
debug() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
debugFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
debugWait() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
Method for use on testcases.
debugWait() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
decode(ActiveMQBuffer) - Method in interface org.apache.activemq.artemis.core.journal.EncodingSupport
 
decode(ActiveMQBuffer) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.ByteArrayEncoding
 
decode(ActiveMQBuffer) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord
 
decPosCount() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
decPosCount() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
decSize(int) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
decSize(int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
delete() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
delete() - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
DELETE_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
DELETE_RECORD_TX - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
deleteControlFile(SequentialFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
deleteRecord(long) - Method in interface org.apache.activemq.artemis.core.journal.LoaderCallback
 
deletingFile(JournalFile) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
deletingOrphanedFile(String) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
directory - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
disableBufferReuse() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
disableBufferReuse() - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
done() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory.AIOSequentialCallback
this is called by libaio.
done() - Method in class org.apache.activemq.artemis.core.io.DummyCallback
 
done() - Method in interface org.apache.activemq.artemis.core.io.IOCallback
Method for sync notifications.
done() - Method in class org.apache.activemq.artemis.core.journal.impl.SimpleWaitIOCallback
 
done() - Method in class org.apache.activemq.artemis.core.journal.impl.TransactionCallback
 
DummyCallback - Class in org.apache.activemq.artemis.core.io
 
DummyCallback() - Constructor for class org.apache.activemq.artemis.core.io.DummyCallback
 

E

enableBufferReuse() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
enableBufferReuse() - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
encode(ActiveMQBuffer) - Method in interface org.apache.activemq.artemis.core.journal.EncodingSupport
 
encode(ActiveMQBuffer) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.ByteArrayEncoding
 
encode(ActiveMQBuffer) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalAddRecord
 
encode(ActiveMQBuffer) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalAddRecordTX
 
encode(ActiveMQBuffer) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalCompleteRecordTX
 
encode(ActiveMQBuffer) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalDeleteRecord
 
encode(ActiveMQBuffer) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalDeleteRecordTX
 
encode(ActiveMQBuffer) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalRollbackRecordTX
 
EncodingSupport - Interface in org.apache.activemq.artemis.core.journal
This interface provides encoding support for the Journal.
ensureMinFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
equals(Object) - Method in class org.apache.activemq.artemis.core.journal.JournalLoadInformation
 
equals(Object) - Method in class org.apache.activemq.artemis.core.journal.RecordInfo
 
errorCallingErrorCallback(Throwable) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorClosingFile(String) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorClosingFile(Throwable) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorCompacting(Throwable) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorCompletingCallback(Throwable) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorDeletingFile(Object) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorOnIOCallback(String) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorOpeningFile(Throwable) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorPushingFile(Exception) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorReadingFile(Throwable) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorReinitializingFile(Throwable, JournalFile) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorReplayingCommands(Throwable) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorRetrievingID(Throwable, String) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorSchedulingCompacting(Throwable) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorStartingPoller(Exception) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorSubmittingWrite(Throwable) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
errorWritingData(Throwable, String, Integer) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
EXECUTOR_TIMEOUT - Static variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
exists() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
exists() - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 

F

factory - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
failedToAddFile(JournalFile) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
failedToPerfBlast(Throwable) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
failedTransaction(long, List<RecordInfo>, List<RecordInfo>) - Method in interface org.apache.activemq.artemis.core.journal.TransactionFailureCallback
To be used to inform about transactions without commit records.
FILE_COMPACT_CONTROL - Static variable in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
fileFactory - Variable in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
fileFinalizedWhileOpen(String) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
fileID - Variable in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord
 
fileIdOutOfOrder() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
FileIOUtil - Class in org.apache.activemq.artemis.core.io.util
 
FileIOUtil() - Constructor for class org.apache.activemq.artemis.core.io.util.FileIOUtil
 
fileNotOpened() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalBundle
 
fileSize - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
filesRepository - Variable in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
fileTooSmall() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
FileWrapperJournal - Class in org.apache.activemq.artemis.core.journal.impl
Journal used at a replicating backup server during the synchronization of data with the 'live' server.
FileWrapperJournal(Journal) - Constructor for class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
fill(int) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
fill(int) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
fill(int) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
FILL_CHARACTER - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
fillNumberOfRecords(JournalFile, JournalInternalRecord) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
fits(int) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
fits(int) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
flush() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
flush() - Method in class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
 
flush(boolean) - Method in class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
force means the Journal is moving to a new file.
flush() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
flush() - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
flush() - Method in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
Write pending output into file
flush() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
flush() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
flush() - Method in interface org.apache.activemq.artemis.core.journal.Journal
It will make sure there are no more pending operations on the Executors.
flushBuffer(ByteBuffer, boolean, List<IOCallback>) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile.LocalBufferObserver
 
flushBuffer(ByteBuffer, boolean, List<IOCallback>) - Method in interface org.apache.activemq.artemis.core.io.buffer.TimedBufferObserver
 
flushRate(Double) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
forceMoveNextFile() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
forceMoveNextFile() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
forceMoveNextFile() - Method in interface org.apache.activemq.artemis.core.journal.Journal
Force the usage of a new JournalFile.
forceMoveNextFile() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
forget() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
Used by load, when the transaction was not loaded correctly
FORMAT_VERSION - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 

G

getAlignment() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
getAlignment() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
getAlignment() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
getAlignment() - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
getAlignment() - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
getAlignment() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
getAlignment() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getAlignment() - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
getCallback() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
getCallback(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
getCompactCount() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord
 
getCompactCount() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
For tests only
getCompactor() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
getCompactor() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getCompactor() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalRecordProvider
 
getCounter(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
getCurrentCallback() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
getCurrentFile() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getCurrentFile() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
getDataFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
getDataFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
getDataFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getDataFiles() - Method in interface org.apache.activemq.artemis.core.journal.Journal
Returns the JournalFiles in use.
getDataFiles() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
getDataFilesArray() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
getDataFilesCount() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
getDataFilesCount() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getDataFilesCount() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
getDelegateCompletion() - Method in class org.apache.activemq.artemis.core.journal.impl.TransactionCallback
 
getDirectory() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
getDirectory() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
getDirectory() - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
getEncodeSize() - Method in interface org.apache.activemq.artemis.core.journal.EncodingSupport
 
getEncodeSize() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.ByteArrayEncoding
 
getEncodeSize() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalAddRecord
 
getEncodeSize() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalAddRecordTX
 
getEncodeSize() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalCompleteRecordTX
 
getEncodeSize() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalDeleteRecord
 
getEncodeSize() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalDeleteRecordTX
 
getEncodeSize() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord
 
getEncodeSize() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalRollbackRecordTX
 
getErrorCode() - Method in class org.apache.activemq.artemis.core.journal.impl.TransactionCallback
 
getErrorMessage() - Method in class org.apache.activemq.artemis.core.journal.impl.TransactionCallback
 
getExtraData() - Method in class org.apache.activemq.artemis.core.journal.PreparedTransactionInfo
 
getFile() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
getFile() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
getFile() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
getFileExtension() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
getFileExtension() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getFileExtension() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
getFileFactory() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
getFileFactory() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getFileFactory() - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
getFileID() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord
 
getFileID() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
getFileID() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
getFileName() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
getFileName() - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
getFilePrefix() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
getFilePrefix() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getFilePrefix() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
getFileSize() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getFileSize() - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
getFileSize() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
getFreeFile() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
getFreeFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
getFreeFilesCount() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
getFreeFilesCount() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getFreeFilesCount() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
getId() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
getId() - Method in class org.apache.activemq.artemis.core.journal.PreparedTransactionInfo
 
getIDMapSize() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getIDMapSize() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
getInstance() - Static method in class org.apache.activemq.artemis.core.io.DummyCallback
 
getJavaFile() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
getJavaFile() - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
Returns a native File of the file underlying this sequential file.
getJournalVersion() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
getJournalVersion() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
getLiveSize() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
getLiveSize() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
getMaxAIO() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
getMaxAIO() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getMaxAIO() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
getMaxID() - Method in class org.apache.activemq.artemis.core.journal.JournalLoadInformation
 
getMaxIO() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
getMaxIO() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
getMaxIO() - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
getMinFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getMinFiles() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
getNegCount(JournalFile) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
getNegCount(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
getNewDataFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
getNewRecords() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
getNewTransactions() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
getNumberOfRecords() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalCompleteRecordTX
 
getNumberOfRecords() - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord
 
getNumberOfRecords() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
getNumberOfRecords() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getNumberOfRecords() - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
getNumberOfRecords() - Method in class org.apache.activemq.artemis.core.journal.JournalLoadInformation
 
getOffset() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
getOpenedFilesCount() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
getOpenedFilesCount() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getOpenedFilesCount() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
getPosCount() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
getPosCount() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
getPositiveArray() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
getRecordID() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
This is a field to identify that records on this file actually belong to the current file.
getRecordID() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
getRecords() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
getRecords() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getRecords() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalRecordProvider
 
getRecords() - Method in class org.apache.activemq.artemis.core.journal.PreparedTransactionInfo
 
getRecordsToDelete() - Method in class org.apache.activemq.artemis.core.journal.PreparedTransactionInfo
 
getRemainingBytes() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile.LocalBufferObserver
 
getRemainingBytes() - Method in interface org.apache.activemq.artemis.core.io.buffer.TimedBufferObserver
Return the number of remaining bytes that still fit on the observer (file)
getTotalNegativeToOthers() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
The total number of deletes this file has
getTotalNegativeToOthers() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
getUserRecordType() - Method in class org.apache.activemq.artemis.core.journal.RecordInfo
 
getUserVersion() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
getUserVersion() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
getUserVersion() - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
getWritingChannel() - Method in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 

H

hashCode() - Method in class org.apache.activemq.artemis.core.journal.JournalLoadInformation
 
hashCode() - Method in class org.apache.activemq.artemis.core.journal.RecordInfo
 

I

id - Variable in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalAddRecord
 
id - Variable in class org.apache.activemq.artemis.core.journal.RecordInfo
 
ignoringShortFile(String) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
incCounter(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
incNegCount(JournalFile) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
incNegCount(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
incompatibleNativeLibrary() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
inconsistencyDuringCompacting(Long) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
inconsistencyDuringCompactingDelete(Long) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
incPosCount() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
incPosCount() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
init(long, IOCallback, LibaioFile, AIOSequentialFile, ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory.AIOSequentialCallback
 
initFileHeader(SequentialFileFactory, SequentialFile, int, long) - Static method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
initWrite(long, int) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory.AIOSequentialCallback
 
IOCallback - Interface in org.apache.activemq.artemis.core.io
The interface used for AIO Callbacks.
IOCompletion - Interface in org.apache.activemq.artemis.core.journal
 
IOCriticalErrorListener - Interface in org.apache.activemq.artemis.core.io
TODO Merge this with IOExceptionListener
ioError(int, String) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
IOExceptionListener - Interface in org.apache.activemq.artemis.core.io
 
ioExecutorFactory - Variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
ioRenameFileError(String, String) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalBundle
 
isAutoReclaim() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
isAutoReclaim() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
isCanReclaim() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
Whether this file's contents can deleted and the file reused.
isCanReclaim() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
isDatasync() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
isDatasync() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
isDatasync() - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
isNegReclaimCriteria() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
Whether this file deletes are on files that are either marked for reclaim or have already been reclaimed
isNegReclaimCriteria() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
isOpen() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
isOpen() - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
isOpen() - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
isPosReclaimCriteria() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
Whether this file additions all have a delete in some other file
isPosReclaimCriteria() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
isStarted() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
isStarted() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
isSupported() - Static method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
isSupported(File) - Static method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
isSupportsCallbacks() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
isSupportsCallbacks() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
isSupportsCallbacks() - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
isSupportsCallbacks() - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
isUpdate - Variable in class org.apache.activemq.artemis.core.journal.RecordInfo
 
isValid() - Method in class org.apache.activemq.artemis.core.io.aio.ActiveMQFileLock
 

J

journal - Variable in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
Journal - Interface in org.apache.activemq.artemis.core.journal
Most methods on the journal provide a blocking version where you select the sync mode and a non blocking mode where you pass a completion callback as a parameter.
Journal.JournalState - Enum in org.apache.activemq.artemis.core.journal
 
JournalAddRecord - Class in org.apache.activemq.artemis.core.journal.impl.dataformat
 
JournalAddRecord(boolean, long, byte, EncodingSupport) - Constructor for class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalAddRecord
 
JournalAddRecordTX - Class in org.apache.activemq.artemis.core.journal.impl.dataformat
 
JournalAddRecordTX(boolean, long, long, byte, EncodingSupport) - Constructor for class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalAddRecordTX
 
JournalCompactor - Class in org.apache.activemq.artemis.core.journal.impl
 
JournalCompactor(SequentialFileFactory, JournalImpl, JournalFilesRepository, Set<Long>, long) - Constructor for class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
JournalCompleteRecordTX - Class in org.apache.activemq.artemis.core.journal.impl.dataformat
A transaction record (Commit or Prepare), will hold the number of elements the transaction has in the current file.
JournalCompleteRecordTX(JournalCompleteRecordTX.TX_RECORD_TYPE, long, EncodingSupport) - Constructor for class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalCompleteRecordTX
 
JournalCompleteRecordTX.TX_RECORD_TYPE - Enum in org.apache.activemq.artemis.core.journal.impl.dataformat
 
JournalConstants - Class in org.apache.activemq.artemis.core.journal.impl
Deprecated.
JournalConstants() - Constructor for class org.apache.activemq.artemis.core.journal.impl.JournalConstants
Deprecated.
 
JournalDeleteRecord - Class in org.apache.activemq.artemis.core.journal.impl.dataformat
 
JournalDeleteRecord(long) - Constructor for class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalDeleteRecord
 
JournalDeleteRecordTX - Class in org.apache.activemq.artemis.core.journal.impl.dataformat
 
JournalDeleteRecordTX(long, long, EncodingSupport) - Constructor for class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalDeleteRecordTX
 
journalDifferentVersion() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalBundle
 
journalDir - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
JournalFile - Interface in org.apache.activemq.artemis.core.journal.impl
 
JournalFileImpl - Class in org.apache.activemq.artemis.core.journal.impl
 
JournalFileImpl(SequentialFile, long, int) - Constructor for class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
journalFileMisMatch() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalBundle
 
JournalFilesRepository - Class in org.apache.activemq.artemis.core.journal.impl
This is a helper class for the Journal, which will control access to dataFiles, openedFiles and freeFiles Guaranteeing that they will be delivered in order to the Journal
JournalFilesRepository(SequentialFileFactory, JournalImpl, String, String, int, int, int, int, int) - Constructor for class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
JournalImpl - Class in org.apache.activemq.artemis.core.journal.impl
A circular log implementation.
JournalImpl(int, int, int, int, int, SequentialFileFactory, String, String, int) - Constructor for class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
JournalImpl(int, int, int, int, int, SequentialFileFactory, String, String, int, int) - Constructor for class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
JournalImpl(ExecutorFactory, int, int, int, int, int, SequentialFileFactory, String, String, int, int) - Constructor for class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
JournalInternalRecord - Class in org.apache.activemq.artemis.core.journal.impl.dataformat
 
JournalInternalRecord() - Constructor for class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord
 
JournalLoadInformation - Class in org.apache.activemq.artemis.core.journal
This is a POJO containing information about the journal during load time.
JournalLoadInformation() - Constructor for class org.apache.activemq.artemis.core.journal.JournalLoadInformation
 
JournalLoadInformation(int, long) - Constructor for class org.apache.activemq.artemis.core.journal.JournalLoadInformation
 
JournalReaderCallback - Interface in org.apache.activemq.artemis.core.journal.impl
 
JournalReaderCallbackAbstract - Class in org.apache.activemq.artemis.core.journal.impl
 
JournalReaderCallbackAbstract() - Constructor for class org.apache.activemq.artemis.core.journal.impl.JournalReaderCallbackAbstract
 
JournalRecord - Class in org.apache.activemq.artemis.core.journal.impl
This holds the relationship a record has with other files in regard to reference counting.
JournalRecord(JournalFile, int) - Constructor for class org.apache.activemq.artemis.core.journal.impl.JournalRecord
 
JournalRecordProvider - Interface in org.apache.activemq.artemis.core.journal.impl
This is an interface used only internally.
JournalRollbackRecordTX - Class in org.apache.activemq.artemis.core.journal.impl.dataformat
 
JournalRollbackRecordTX(long) - Constructor for class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalRollbackRecordTX
 
JournalTransaction - Class in org.apache.activemq.artemis.core.journal.impl
 
JournalTransaction(long, JournalRecordProvider) - Constructor for class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 

L

lineUpContext(IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
lineUpContext(IOCompletion) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
lineUpContext(IOCompletion) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
listFiles(String) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
listFiles(String) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
listFiles(String) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
Lists files that end with the given extension.
load(LoaderCallback) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
load(List<RecordInfo>, List<PreparedTransactionInfo>, TransactionFailureCallback) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
load(List<RecordInfo>, List<PreparedTransactionInfo>, TransactionFailureCallback) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
load(List<RecordInfo>, List<PreparedTransactionInfo>, TransactionFailureCallback, boolean) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
load(LoaderCallback) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
Load data accordingly to the record layouts
load(LoaderCallback) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
load(List<RecordInfo>, List<PreparedTransactionInfo>, TransactionFailureCallback) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
LoaderCallback - Interface in org.apache.activemq.artemis.core.journal
 
loadInternalOnly() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
loadInternalOnly() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
loadInternalOnly() - Method in interface org.apache.activemq.artemis.core.journal.Journal
Load internal data structures and not expose any data.
loadSyncOnly(Journal.JournalState) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
loadSyncOnly(Journal.JournalState) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
loadSyncOnly(Journal.JournalState) - Method in interface org.apache.activemq.artemis.core.journal.Journal
Load internal data structures, and remain waiting for synchronization to complete.
LocalBufferObserver() - Constructor for class org.apache.activemq.artemis.core.io.AbstractSequentialFile.LocalBufferObserver
 
LOGGER - Static variable in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
The journal logger.
lookupRecord(long) - Method in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 

M

MappedSequentialFileFactory - Class in org.apache.activemq.artemis.core.io.mapped
 
MappedSequentialFileFactory(File, IOCriticalErrorListener) - Constructor for class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
MappedSequentialFileFactory(File) - Constructor for class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
markAsDataFile(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
markAsDataFile(JournalFile) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalReaderCallback
 
markAsDataFile(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalReaderCallbackAbstract
 
maxIO - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
merge(JournalTransaction) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
This is used to merge transactions from compacting
MIN_FILE_SIZE - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 

N

newBuffer(int, int) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile.LocalBufferObserver
 
newBuffer(int, int) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
newBuffer(int, int) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
newBuffer(int) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
newBuffer(int, int) - Method in interface org.apache.activemq.artemis.core.io.buffer.TimedBufferObserver
 
newBuffer(int) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
newBuffer(int, int) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
newBuffer(int) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
newBuffer(int) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
Note: You need to release the buffer if is used for reading operations.
newDataFiles - Variable in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
nextOrderingID - Variable in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
NIOSequentialFile - Class in org.apache.activemq.artemis.core.io.nio
 
NIOSequentialFile(SequentialFileFactory, File, String, int, Executor) - Constructor for class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
NIOSequentialFileFactory - Class in org.apache.activemq.artemis.core.io.nio
 
NIOSequentialFileFactory(File, int) - Constructor for class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
NIOSequentialFileFactory(File, IOCriticalErrorListener, int) - Constructor for class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
NIOSequentialFileFactory(File, boolean, int) - Constructor for class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
NIOSequentialFileFactory(File, boolean, IOCriticalErrorListener, int) - Constructor for class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
NIOSequentialFileFactory(File, boolean, int, int, int, boolean) - Constructor for class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
NIOSequentialFileFactory(File, boolean, int, int, int, boolean, IOCriticalErrorListener) - Constructor for class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
noRecordDuringCompactReplay(Long) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 

O

onCompactDone() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
This is an interception point for testcases, when the compacted files are written, before replacing the data structures
onCompactLockingTheJournal() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
This is an interception point for testcases, when the compacted files are written, to be called as soon as the compactor gets a writeLock
onCompactStart() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
This is an interception point for testcases, when the compacted files are written, before replacing the data structures
onError(int, String) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory.AIOSequentialCallback
 
onError(int, String) - Method in class org.apache.activemq.artemis.core.io.DummyCallback
 
onError(int, String) - Method in interface org.apache.activemq.artemis.core.io.IOCallback
Method for error notifications.
onError(int, String) - Method in class org.apache.activemq.artemis.core.journal.impl.SimpleWaitIOCallback
 
onError(int, String) - Method in class org.apache.activemq.artemis.core.journal.impl.TransactionCallback
 
onIOError(Exception, String, SequentialFile) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
onIOError(Exception, String, SequentialFile) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
onIOError(Exception, String, SequentialFile) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
The SequentialFile will call this method when a disk IO Error happens during the live phase.
onIOException(Throwable, String, SequentialFile) - Method in interface org.apache.activemq.artemis.core.io.IOCriticalErrorListener
 
onIOException(Exception, String) - Method in interface org.apache.activemq.artemis.core.io.IOExceptionListener
 
onReadAddRecord(RecordInfo) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
onReadAddRecord(RecordInfo) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalReaderCallback
 
onReadAddRecord(RecordInfo) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalReaderCallbackAbstract
 
onReadAddRecordTX(long, RecordInfo) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
onReadAddRecordTX(long, RecordInfo) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalReaderCallback
 
onReadAddRecordTX(long, RecordInfo) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalReaderCallbackAbstract
 
onReadCommitRecord(long, int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
onReadCommitRecord(long, int) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalReaderCallback
 
onReadCommitRecord(long, int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalReaderCallbackAbstract
 
onReadDeleteRecord(long) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
onReadDeleteRecord(long) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalReaderCallback
 
onReadDeleteRecord(long) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalReaderCallbackAbstract
 
onReadDeleteRecordTX(long, RecordInfo) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
onReadDeleteRecordTX(long, RecordInfo) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalReaderCallback
 
onReadDeleteRecordTX(long, RecordInfo) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalReaderCallbackAbstract
 
onReadPrepareRecord(long, byte[], int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
onReadPrepareRecord(long, byte[], int) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalReaderCallback
 
onReadPrepareRecord(long, byte[], int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalReaderCallbackAbstract
 
onReadRollbackRecord(long) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
onReadRollbackRecord(long) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalReaderCallback
 
onReadRollbackRecord(long) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalReaderCallbackAbstract
 
onReadUpdateRecord(RecordInfo) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
onReadUpdateRecord(RecordInfo) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalReaderCallback
 
onReadUpdateRecord(RecordInfo) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalReaderCallbackAbstract
 
onReadUpdateRecordTX(long, RecordInfo) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
 
onReadUpdateRecordTX(long, RecordInfo) - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalReaderCallback
 
onReadUpdateRecordTX(long, RecordInfo) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalReaderCallbackAbstract
 
open() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
open(int, boolean) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
open() - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
this.maxIO represents the default maxIO.
open(int, boolean) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
open() - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
open(int, boolean) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
The maximum number of simultaneous writes accepted
openFile() - Method in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
openFile(JournalFile, boolean) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
openFile() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
This method will instantly return the opened file, and schedule opening and reclaiming.
orderFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
this method is used internally only however tools may use it to maintenance.
org.apache.activemq.artemis.core.io - package org.apache.activemq.artemis.core.io
 
org.apache.activemq.artemis.core.io.aio - package org.apache.activemq.artemis.core.io.aio
 
org.apache.activemq.artemis.core.io.buffer - package org.apache.activemq.artemis.core.io.buffer
 
org.apache.activemq.artemis.core.io.mapped - package org.apache.activemq.artemis.core.io.mapped
 
org.apache.activemq.artemis.core.io.nio - package org.apache.activemq.artemis.core.io.nio
 
org.apache.activemq.artemis.core.io.util - package org.apache.activemq.artemis.core.io.util
 
org.apache.activemq.artemis.core.journal - package org.apache.activemq.artemis.core.journal
 
org.apache.activemq.artemis.core.journal.impl - package org.apache.activemq.artemis.core.journal.impl
 
org.apache.activemq.artemis.core.journal.impl.dataformat - package org.apache.activemq.artemis.core.journal.impl.dataformat
 
org.apache.activemq.artemis.journal - package org.apache.activemq.artemis.journal
 
overlapBytes() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
overlapBytes(long) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 

P

perfBlast(int) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
perfBlast(int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
perfBlast(int) - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
pollLastDataFile() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
position - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
position(long) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
position() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
position(long) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
position(long) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
position() - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
prepare(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
The caller of this method needs to guarantee appendLock.lock before calling this method if being used outside of the lock context.
PREPARE_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
PreparedTransactionInfo - Class in org.apache.activemq.artemis.core.journal
 
PreparedTransactionInfo(long, byte[]) - Constructor for class org.apache.activemq.artemis.core.journal.PreparedTransactionInfo
 
preparedTXIncomplete(Long) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
pushOpenedFile() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
Open a file and place it into the openedFiles queue

R

read(ByteBuffer, IOCallback) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
read(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
read(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
read(ByteBuffer, IOCallback) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
read(ByteBuffer, IOCallback) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
read(ByteBuffer) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
readControlFile(SequentialFileFactory, List<String>, List<String>, List<Pair<String, String>>) - Static method in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
readJournalFile(SequentialFileFactory, JournalFile, JournalReaderCallback) - Static method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
this method is used internally only however tools may use it to maintenance.
Reclaimer - Class in org.apache.activemq.artemis.core.journal.impl
The journal consists of an ordered list of journal files Fn where 0 <= n <= N
Reclaimer() - Constructor for class org.apache.activemq.artemis.core.journal.impl.Reclaimer
 
record - Variable in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalAddRecord
 
RecordInfo - Class in org.apache.activemq.artemis.core.journal
 
RecordInfo(long, byte, byte[], boolean, short) - Constructor for class org.apache.activemq.artemis.core.journal.RecordInfo
 
recordType - Variable in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalAddRecord
 
release() - Method in class org.apache.activemq.artemis.core.io.aio.ActiveMQFileLock
 
releaseBuffer(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
releaseBuffer(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
releaseBuffer(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
releaseBuffer(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
releaseBuffer(ByteBuffer) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
releaseDirectBuffer(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
releaseDirectBuffer(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
releaseDirectBuffer(ByteBuffer) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
releaseDirectBuffer(ByteBuffer) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
used for cases where you need direct buffer outside of the journal context.
removeDataFile(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
renameExtensionFile(String, String) - Static method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
renameFiles(List<JournalFile>, List<JournalFile>) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
being protected as testcases can override this method
renameTo(String) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
renameTo(String) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
replaceRecordProvider(JournalRecordProvider) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
replayPendingCommands() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalCompactor
Replay pending counts that happened during compacting
replicationSyncFinished() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
replicationSyncFinished() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
replicationSyncFinished() - Method in interface org.apache.activemq.artemis.core.journal.Journal
Restarts file reclaim and compacting on the journal.
replicationSyncPreserveOldFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
replicationSyncPreserveOldFiles() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
replicationSyncPreserveOldFiles() - Method in interface org.apache.activemq.artemis.core.journal.Journal
Stops any operation that may delete or modify old (stale) data.
rollback(JournalFile) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
The caller of this method needs to guarantee appendLock.lock before calling this method if being used outside of the lock context.
ROLLBACK_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
run() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory.AIOSequentialCallback
 
runDirectJournalBlast() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
runDirectJournalBlast() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
runDirectJournalBlast() - Method in interface org.apache.activemq.artemis.core.journal.Journal
 
runningJournalBlast(Integer) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 

S

scan(JournalFile[]) - Method in class org.apache.activemq.artemis.core.journal.impl.Reclaimer
 
scheduleCompactAndBlock(int) - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
scheduleCompactAndBlock(int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
scheduleCompactAndBlock(int) - Method in interface org.apache.activemq.artemis.core.journal.Journal
This method will start compact using the compactorExecutor and block up to timeout seconds
seqOutOfOrder() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
sequentialDone() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory.AIOSequentialCallback
This is callbed by the AIOSequentialFile, after determined the callbacks were returned in sequence
SequentialFile - Interface in org.apache.activemq.artemis.core.io
 
sequentialFile - Variable in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
SequentialFileFactory - Interface in org.apache.activemq.artemis.core.io
A SequentialFileFactory
setAlignment(int) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
setAlignment(int) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
setAlignment(int) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
setAutoReclaim(boolean) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
setAutoReclaim(boolean) - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
setCompactCount(short) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord
 
setCompacting() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
setDatasync(boolean) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
setDatasync(boolean) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
setDatasync(boolean) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
setDelegateCompletion(IOCallback) - Method in class org.apache.activemq.artemis.core.journal.impl.TransactionCallback
 
setExecutor(Executor) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
setFileID(int) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord
 
setMaxID(long) - Method in class org.apache.activemq.artemis.core.journal.JournalLoadInformation
 
setNegReclaimCriteria() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
setNegReclaimCriteria() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
setNextFileID(long) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
Set the {link #nextFileID} value to targetUpdate if the current value is less than targetUpdate.
setNumberOfRecords(int) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalCompleteRecordTX
 
setNumberOfRecords(int) - Method in class org.apache.activemq.artemis.core.journal.impl.dataformat.JournalInternalRecord
 
setNumberOfRecords(int) - Method in class org.apache.activemq.artemis.core.journal.JournalLoadInformation
 
setObserver(TimedBufferObserver) - Method in class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
 
setOffset(long) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
setPosReclaimCriteria() - Method in interface org.apache.activemq.artemis.core.journal.impl.JournalFile
 
setPosReclaimCriteria() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
setTimedBuffer(TimedBuffer) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
setTimedBuffer(TimedBuffer) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
setUpCurrentFile(int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
SimpleWaitIOCallback - Class in org.apache.activemq.artemis.core.journal.impl
 
SimpleWaitIOCallback() - Constructor for class org.apache.activemq.artemis.core.journal.impl.SimpleWaitIOCallback
 
size() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
size() - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
size() - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
SIZE_ADD_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
SIZE_ADD_RECORD_TX - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
SIZE_COMMIT_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
SIZE_COMPLETE_TRANSACTION_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
SIZE_DELETE_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
SIZE_DELETE_RECORD_TX - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
SIZE_HEADER - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
SIZE_PREPARE_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
SIZE_ROLLBACK_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
sleep(int, int) - Method in class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
Sub classes (tests basically) can use this to override how the sleep is being done
start() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
start() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
start() - Method in class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
 
start() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
start() - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
start() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
start() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
startingThread() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
startSpin() - Method in class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
Sub classes (tests basically) can use this to override disabling spinning
stop() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
stop() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
stop() - Method in class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
 
stop() - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
stop() - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
stop() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
stop() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
stopSpin() - Method in class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
Sub classes (tests basically) can use this to override disabling spinning
storeLineUp() - Method in class org.apache.activemq.artemis.core.io.DummyCallback
 
storeLineUp() - Method in class org.apache.activemq.artemis.core.journal.impl.SimpleWaitIOCallback
 
storeLineUp() - Method in interface org.apache.activemq.artemis.core.journal.IOCompletion
 
switchFileIfNecessary(int) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
sync() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
sync() - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
sync() - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
synchronizationLock() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
synchronizationLock() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
synchronizationLock() - Method in interface org.apache.activemq.artemis.core.journal.Journal
Write lock the Journal and write lock the compacting process.
synchronizationUnlock() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
synchronizationUnlock() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
synchronizationUnlock() - Method in interface org.apache.activemq.artemis.core.journal.Journal
Unlock the Journal and the compacting process.
SyncIOCompletion - Class in org.apache.activemq.artemis.core.journal.impl
Internal class used to manage explicit syncs on the Journal through callbacks.
SyncIOCompletion() - Constructor for class org.apache.activemq.artemis.core.journal.impl.SyncIOCompletion
 

T

takeFile(boolean, boolean, boolean, boolean) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
This will get a File from freeFile without initializing it
tempFilesLeftOpen() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
TestableJournal - Interface in org.apache.activemq.artemis.core.journal
 
testCompact() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
testCompact() - Method in interface org.apache.activemq.artemis.core.journal.TestableJournal
 
timedBuffer - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
timedBuffer - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
 
TimedBuffer - Class in org.apache.activemq.artemis.core.io.buffer
 
TimedBuffer(int, int, boolean) - Constructor for class org.apache.activemq.artemis.core.io.buffer.TimedBuffer
 
timedBufferObserver - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
Instead of having AIOSequentialFile implementing the Observer, I have done it on an inner class.
TimedBufferObserver - Interface in org.apache.activemq.artemis.core.io.buffer
 
timeoutOnPollerShutdown(Exception) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
timeoutOnWriterShutdown(Throwable) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
toString() - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile.LocalBufferObserver
 
toString() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
toString() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory.AIOSequentialCallback
 
toString() - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
toString() - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
toString() - Method in class org.apache.activemq.artemis.core.journal.impl.FileWrapperJournal
 
toString() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFileImpl
 
toString() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalFilesRepository
 
toString() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
toString() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalRecord
 
toString() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
toString() - Method in class org.apache.activemq.artemis.core.journal.impl.SimpleWaitIOCallback
 
toString() - Method in class org.apache.activemq.artemis.core.journal.JournalLoadInformation
 
toString() - Method in class org.apache.activemq.artemis.core.journal.RecordInfo
 
TransactionCallback - Class in org.apache.activemq.artemis.core.journal.impl
 
TransactionCallback() - Constructor for class org.apache.activemq.artemis.core.journal.impl.TransactionCallback
 
TransactionFailureCallback - Interface in org.apache.activemq.artemis.core.journal
A Callback to receive information about bad transactions for extra cleanup required for broken transactions such as large messages.
txMissingElements(Long) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 

U

unableToOpenFile() - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalBundle
 
uncomittedTxFound(Long) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
UPDATE_RECORD - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
UPDATE_RECORD_TX - Static variable in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
updateRecord(RecordInfo) - Method in interface org.apache.activemq.artemis.core.journal.LoaderCallback
 
userRecordType - Variable in class org.apache.activemq.artemis.core.journal.RecordInfo
 

V

valueOf(String) - Static method in enum org.apache.activemq.artemis.core.journal.impl.dataformat.JournalCompleteRecordTX.TX_RECORD_TYPE
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.activemq.artemis.core.journal.Journal.JournalState
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.activemq.artemis.core.journal.impl.dataformat.JournalCompleteRecordTX.TX_RECORD_TYPE
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.activemq.artemis.core.journal.Journal.JournalState
Returns an array containing the constants of this enum type, in the order they are declared.

W

waitCallbacks() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
 
waitCompletion() - Method in class org.apache.activemq.artemis.core.io.DummyCallback
 
waitCompletion() - Method in class org.apache.activemq.artemis.core.journal.impl.JournalTransaction
Wait completion at the latest file only
waitCompletion() - Method in class org.apache.activemq.artemis.core.journal.impl.SimpleWaitIOCallback
 
waitCompletion(long) - Method in class org.apache.activemq.artemis.core.journal.impl.SimpleWaitIOCallback
 
waitCompletion() - Method in class org.apache.activemq.artemis.core.journal.impl.SyncIOCompletion
 
waitCompletion() - Method in class org.apache.activemq.artemis.core.journal.impl.TransactionCallback
 
wrapBuffer(byte[]) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFileFactory
 
wrapBuffer(byte[]) - Method in class org.apache.activemq.artemis.core.io.mapped.MappedSequentialFileFactory
 
wrapBuffer(byte[]) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFileFactory
 
wrapBuffer(byte[]) - Method in interface org.apache.activemq.artemis.core.io.SequentialFileFactory
 
write(ActiveMQBuffer, boolean, IOCallback) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
write(ActiveMQBuffer, boolean) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
write(EncodingSupport, boolean, IOCallback) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
write(EncodingSupport, boolean) - Method in class org.apache.activemq.artemis.core.io.AbstractSequentialFile
 
write(ActiveMQBuffer, boolean, IOCallback) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
write(ActiveMQBuffer, boolean) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
write(EncodingSupport, boolean, IOCallback) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
write(EncodingSupport, boolean) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
 
writeControlFile(SequentialFileFactory, List<JournalFile>, List<JournalFile>, List<Pair<String, String>>) - Static method in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
writeControlFile(SequentialFileFactory, List<JournalFile>, List<JournalFile>, List<Pair<String, String>>) - Method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
writeDirect(ByteBuffer, boolean) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
 
writeDirect(ByteBuffer, boolean, IOCallback) - Method in class org.apache.activemq.artemis.core.io.aio.AIOSequentialFile
Note: Parameter sync is not used on AIO
writeDirect(ByteBuffer, boolean, IOCallback) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
writeDirect(ByteBuffer, boolean) - Method in class org.apache.activemq.artemis.core.io.nio.NIOSequentialFile
 
writeDirect(ByteBuffer, boolean, IOCallback) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
Write directly to the file without using any buffer
writeDirect(ByteBuffer, boolean) - Method in interface org.apache.activemq.artemis.core.io.SequentialFile
Write directly to the file without using intermediate any buffer
writeEncoder(JournalInternalRecord) - Method in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
writeEncoder(JournalInternalRecord, int) - Method in class org.apache.activemq.artemis.core.journal.impl.AbstractJournalUpdateTask
 
writeExecutor - Variable in class org.apache.activemq.artemis.core.io.AbstractSequentialFileFactory
Asynchronous writes need to be done at another executor.
writeHeader(ActiveMQBuffer, int, long) - Static method in class org.apache.activemq.artemis.core.journal.impl.JournalImpl
 
writeRate(Double, Long) - Method in interface org.apache.activemq.artemis.journal.ActiveMQJournalLogger
 
A B C D E F G H I J L M N O P R S T U V W 
Skip navigation links
ActiveMQ Artemis Journal 1.5.5.012-redhat-1

Copyright © 2018 The Apache Software Foundation. All Rights Reserved.