HornetQ Journal 2.3.25.SP3-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.hornetq.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.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
AbstractSequentialFile - Class in org.hornetq.core.journal.impl
A AbstractSequentialFile
AbstractSequentialFile(String, File, SequentialFileFactory, Executor) - Constructor for class org.hornetq.core.journal.impl.AbstractSequentialFile
 
AbstractSequentialFile.LocalBufferObserver - Class in org.hornetq.core.journal.impl
 
AbstractSequentialFile.LocalBufferObserver() - Constructor for class org.hornetq.core.journal.impl.AbstractSequentialFile.LocalBufferObserver
 
activateBuffer(SequentialFile) - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
ADD_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
ADD_RECORD_TX - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
addBytes(HornetQBuffer, boolean, IOAsyncTask) - Method in class org.hornetq.core.journal.impl.TimedBuffer
 
addBytes(EncodingSupport, boolean, IOAsyncTask) - Method in class org.hornetq.core.journal.impl.TimedBuffer
 
addCommandCommit(JournalTransaction, JournalFile) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
addCommandDelete(long, JournalFile) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
addCommandRollback(JournalTransaction, JournalFile) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
addCommandUpdate(long, JournalFile, int) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
addDataFileOnBottom(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
addDataFileOnTop(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
addFreeFile(JournalFile, boolean) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
addFreeFile(JournalFile, boolean, boolean) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
addMax(int) - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
addNegative(JournalFile, long) - Method in class org.hornetq.core.journal.impl.JournalTransaction
 
addPendingTransaction(long, long[]) - Method in class org.hornetq.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.hornetq.core.journal.impl.JournalTransaction
 
addPreparedTransaction(PreparedTransactionInfo) - Method in interface org.hornetq.core.journal.LoaderCallback
 
addRecord(RecordInfo) - Method in interface org.hornetq.core.journal.LoaderCallback
 
addSize(int) - Method in interface org.hornetq.core.journal.impl.JournalFile
 
addSize(int) - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
addToRecordsSnaptshot(long) - Method in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
AIO - Variable in class org.hornetq.core.journal.impl.SyncSpeedTest
 
AIOCallback - Interface in org.hornetq.core.asyncio
The interface used for AIO Callbacks.
AIOSequentialFile - Class in org.hornetq.core.journal.impl
A AIOSequentialFile
AIOSequentialFile(SequentialFileFactory, int, long, String, String, int, BufferCallback, Executor, Executor) - Constructor for class org.hornetq.core.journal.impl.AIOSequentialFile
 
AIOSequentialFileFactory - Class in org.hornetq.core.journal.impl
A AIOSequentialFileFactory
AIOSequentialFileFactory(String) - Constructor for class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
AIOSequentialFileFactory(String, IOCriticalErrorListener) - Constructor for class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
AIOSequentialFileFactory(String, int, int, boolean) - Constructor for class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
AIOSequentialFileFactory(String, int, int, boolean, IOCriticalErrorListener) - Constructor for class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
allocateDirectBuffer(int) - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
allocateDirectBuffer(int) - Method in class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
allocateDirectBuffer(int) - Method in interface org.hornetq.core.journal.SequentialFileFactory
used for cases where you need direct buffer outside of the journal context.
appendAddRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
appendAddRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
appendAddRecord(long, byte, byte[], boolean) - Method in interface org.hornetq.core.journal.Journal
 
appendAddRecord(long, byte, EncodingSupport, boolean) - Method in interface org.hornetq.core.journal.Journal
 
appendAddRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in interface org.hornetq.core.journal.Journal
 
appendAddRecordTransactional(long, long, byte, EncodingSupport) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
appendAddRecordTransactional(long, long, byte, EncodingSupport) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
appendAddRecordTransactional(long, long, byte, byte[]) - Method in interface org.hornetq.core.journal.Journal
 
appendAddRecordTransactional(long, long, byte, EncodingSupport) - Method in interface org.hornetq.core.journal.Journal
 
appendCommitRecord(long, boolean, IOCompletion, boolean) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
appendCommitRecord(long, boolean, IOCompletion, boolean) - Method in class org.hornetq.core.journal.impl.JournalImpl
Regarding the number of operations in a given file see JournalCompleteRecordTX.
appendCommitRecord(long, boolean) - Method in interface org.hornetq.core.journal.Journal
 
appendCommitRecord(long, boolean, IOCompletion) - Method in interface org.hornetq.core.journal.Journal
 
appendCommitRecord(long, boolean, IOCompletion, boolean) - Method in interface org.hornetq.core.journal.Journal
 
appendDeleteRecord(long, boolean, IOCompletion) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
appendDeleteRecord(long, boolean, IOCompletion) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
appendDeleteRecord(long, boolean) - Method in interface org.hornetq.core.journal.Journal
 
appendDeleteRecord(long, boolean, IOCompletion) - Method in interface org.hornetq.core.journal.Journal
 
appendDeleteRecordTransactional(long, long, EncodingSupport) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
appendDeleteRecordTransactional(long, long, EncodingSupport) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
appendDeleteRecordTransactional(long, long, byte[]) - Method in interface org.hornetq.core.journal.Journal
 
appendDeleteRecordTransactional(long, long, EncodingSupport) - Method in interface org.hornetq.core.journal.Journal
 
appendDeleteRecordTransactional(long, long) - Method in interface org.hornetq.core.journal.Journal
 
appendPrepareRecord(long, EncodingSupport, boolean, IOCompletion) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
appendPrepareRecord(long, EncodingSupport, boolean, IOCompletion) - Method in class org.hornetq.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.hornetq.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.hornetq.core.journal.Journal
 
appendPrepareRecord(long, byte[], boolean) - Method in interface org.hornetq.core.journal.Journal
 
appendRollbackRecord(long, boolean, IOCompletion) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
appendRollbackRecord(long, boolean, IOCompletion) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
appendRollbackRecord(long, boolean) - Method in interface org.hornetq.core.journal.Journal
 
appendRollbackRecord(long, boolean, IOCompletion) - Method in interface org.hornetq.core.journal.Journal
 
appendUpdateRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
appendUpdateRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
appendUpdateRecord(long, byte, byte[], boolean) - Method in interface org.hornetq.core.journal.Journal
 
appendUpdateRecord(long, byte, EncodingSupport, boolean) - Method in interface org.hornetq.core.journal.Journal
 
appendUpdateRecord(long, byte, EncodingSupport, boolean, IOCompletion) - Method in interface org.hornetq.core.journal.Journal
 
appendUpdateRecordTransactional(long, long, byte, EncodingSupport) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
appendUpdateRecordTransactional(long, long, byte, EncodingSupport) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
appendUpdateRecordTransactional(long, long, byte, byte[]) - Method in interface org.hornetq.core.journal.Journal
 
appendUpdateRecordTransactional(long, long, byte, EncodingSupport) - Method in interface org.hornetq.core.journal.Journal
 
AsynchronousFile - Interface in org.hornetq.core.asyncio
 
AsynchronousFileImpl - Class in org.hornetq.core.asyncio.impl
AsynchronousFile implementation
AsynchronousFileImpl(Executor, Executor, IOExceptionListener) - Constructor for class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
AsynchronousFileImpl(Executor, Executor) - Constructor for class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 

B

BufferCallback - Interface in org.hornetq.core.asyncio
Used to receive a notification on completed buffers used by the AIO layer.
bufferDone(ByteBuffer) - Method in interface org.hornetq.core.asyncio.BufferCallback
 
BUNDLE - Static variable in interface org.hornetq.journal.HornetQJournalBundle
 
ByteArrayEncoding - Class in org.hornetq.core.journal.impl.dataformat
A ByteArrayEncoding
ByteArrayEncoding(byte[]) - Constructor for class org.hornetq.core.journal.impl.dataformat.ByteArrayEncoding
 

C

calculateBlockSize(int) - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
calculateBlockSize(int) - Method in class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
calculateBlockSize(int) - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
calculateBlockStart(int) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
calculateBlockStart(int) - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
calculateBlockStart(int) - Method in interface org.hornetq.core.journal.SequentialFile
 
calculateNextfileID(List<JournalFile>) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
callbackError(String) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
checkDataFiles() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
checkFiles() - Method in interface org.hornetq.journal.HornetQJournalLogger
 
checkReclaimStatus() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
checkReclaimStatus() - Method in interface org.hornetq.core.journal.TestableJournal
This method is called automatically when a new file is opened.
checkSize(int) - Method in class org.hornetq.core.journal.impl.TimedBuffer
Verify if the size fits the buffer
clear() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
clear() - Method in class org.hornetq.core.journal.impl.JournalTransaction
 
clearBuffer(ByteBuffer) - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
clearBuffer(ByteBuffer) - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
clearBuffer(ByteBuffer) - Method in class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
clearBuffer(ByteBuffer) - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
clearDataFiles() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
cloneFile() - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
cloneFile() - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
cloneFile() - Method in interface org.hornetq.core.journal.SequentialFile
 
close() - Method in interface org.hornetq.core.asyncio.AsynchronousFile
 
close() - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
close() - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
close() - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
close() - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
close() - Method in interface org.hornetq.core.journal.SequentialFile
 
closeFile(int) - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
closeFile(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
commit(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalTransaction
The caller of this method needs to guarantee appendLock.lock at the journal.
COMMIT_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
compact() - Method in class org.hornetq.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.hornetq.core.journal.impl.dataformat.JournalInternalRecord
 
compactCount - Variable in class org.hornetq.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.hornetq.journal.HornetQJournalLogger
 
CompactJournal - Class in org.hornetq.core.journal.impl
This is an undocumented class, that will open a journal and force compacting on it.
CompactJournal() - Constructor for class org.hornetq.core.journal.impl.CompactJournal
 
compactMergeError(Long) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
compactReadError(JournalFile) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
copyTo(SequentialFile) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
copyTo(SequentialFile) - Method in interface org.hornetq.core.journal.SequentialFile
 
couldNotCompleteTask(Exception, String) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
couldNotGetLock(String) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
couldNotRemoveFile(JournalFile) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
couldNotStopCompactor() - Method in interface org.hornetq.journal.HornetQJournalLogger
 
couldNotStopJournalExecutor() - Method in interface org.hornetq.journal.HornetQJournalLogger
 
countUp() - Method in class org.hornetq.core.journal.impl.TransactionCallback
 
createControlFile(List<JournalFile>, List<JournalFile>, Pair<String, String>) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
createDirs() - Method in interface org.hornetq.core.journal.SequentialFileFactory
Creates the directory if it does not exist yet.
createFilesForBackupSync(long[]) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
createFilesForBackupSync(long[]) - Method in class org.hornetq.core.journal.impl.JournalImpl
Returns Map with a JournalFile for all existing files.
createFilesForBackupSync(long[]) - Method in interface org.hornetq.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.hornetq.core.journal.impl.JournalFilesRepository
Creates files for journal synchronization of a replicated backup.
createSequentialFile(String, int) - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
createSequentialFile(String, int) - Method in class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
createSequentialFile(String) - Method in class org.hornetq.core.journal.impl.SyncSpeedTest
 
createSequentialFile(String, int) - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
currentFile - Variable in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
currentFile - Variable in class org.hornetq.core.journal.impl.FileWrapperJournal
 
currentFile(Long, Long, Long, Boolean) - Method in interface org.hornetq.journal.HornetQJournalLogger
 

D

data - Variable in class org.hornetq.core.journal.RecordInfo
 
deactivateBuffer() - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
debug() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
Receive debug information about the journal
debug() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
debug() - Method in interface org.hornetq.core.journal.TestableJournal
 
debugFiles() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
debugWait() - Method in class org.hornetq.core.journal.impl.JournalImpl
Method for use on testcases.
debugWait() - Method in interface org.hornetq.core.journal.TestableJournal
 
decode(HornetQBuffer) - Method in interface org.hornetq.core.journal.EncodingSupport
 
decode(HornetQBuffer) - Method in class org.hornetq.core.journal.impl.dataformat.ByteArrayEncoding
 
decode(HornetQBuffer) - Method in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
 
decPosCount() - Method in interface org.hornetq.core.journal.impl.JournalFile
 
decPosCount() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
decSize(int) - Method in interface org.hornetq.core.journal.impl.JournalFile
 
decSize(int) - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
DEFAULT_JOURNAL_BUFFER_SIZE_AIO - Static variable in class org.hornetq.core.journal.impl.JournalConstants
 
DEFAULT_JOURNAL_BUFFER_SIZE_NIO - Static variable in class org.hornetq.core.journal.impl.JournalConstants
 
DEFAULT_JOURNAL_BUFFER_TIMEOUT_AIO - Static variable in class org.hornetq.core.journal.impl.JournalConstants
 
DEFAULT_JOURNAL_BUFFER_TIMEOUT_NIO - Static variable in class org.hornetq.core.journal.impl.JournalConstants
 
delete() - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
delete() - Method in interface org.hornetq.core.journal.SequentialFile
 
DELETE_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
DELETE_RECORD_TX - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
deleteControlFile(SequentialFile) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
deleteRecord(long) - Method in interface org.hornetq.core.journal.LoaderCallback
 
deletingFile(JournalFile) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
deletingOrphanedFile(String) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
deletingTooShortFile(String) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
destroyBuffer(ByteBuffer) - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
done() - Method in interface org.hornetq.core.asyncio.AIOCallback
Method for sync notifications.
done() - Method in class org.hornetq.core.journal.impl.SimpleWaitIOCallback
 
done() - Method in class org.hornetq.core.journal.impl.TransactionCallback
 

E

encode(HornetQBuffer) - Method in interface org.hornetq.core.journal.EncodingSupport
 
encode(HornetQBuffer) - Method in class org.hornetq.core.journal.impl.dataformat.ByteArrayEncoding
 
encode(HornetQBuffer) - Method in class org.hornetq.core.journal.impl.dataformat.JournalAddRecord
 
encode(HornetQBuffer) - Method in class org.hornetq.core.journal.impl.dataformat.JournalAddRecordTX
 
encode(HornetQBuffer) - Method in class org.hornetq.core.journal.impl.dataformat.JournalCompleteRecordTX
 
encode(HornetQBuffer) - Method in class org.hornetq.core.journal.impl.dataformat.JournalDeleteRecord
 
encode(HornetQBuffer) - Method in class org.hornetq.core.journal.impl.dataformat.JournalDeleteRecordTX
 
encode(HornetQBuffer) - Method in class org.hornetq.core.journal.impl.dataformat.JournalRollbackRecordTX
 
EncodingSupport - Interface in org.hornetq.core.journal
This interface provides encoding support for the Journal.
ensureMinFiles() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
equals(Object) - Method in class org.hornetq.core.journal.JournalLoadInformation
 
equals(Object) - Method in class org.hornetq.core.journal.RecordInfo
 
errorCallingErrorCallback(Throwable) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorClosingFile(String) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorClosingFile(Throwable) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorCompacting(Throwable) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorCompletingCallback(Throwable) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorDeletingFile(Object) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorOnIOCallback(String) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorOpeningFile(Throwable) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorPushingFile(Exception) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorReadingFile(Throwable) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorReinitializingFile(Throwable, JournalFile) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorReplayingCommands(Throwable) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorRetrievingID(Throwable, String) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorSchedulingCompacting(Throwable) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorStartingPoller(Exception) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorSubmittingWrite(Throwable) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
errorWritingData(Throwable, String, Integer) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
exists() - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
exists() - Method in interface org.hornetq.core.journal.SequentialFile
 
ExportJournal - Class in org.hornetq.core.journal.impl
Use this class to export the journal data.
ExportJournal() - Constructor for class org.hornetq.core.journal.impl.ExportJournal
 
exportJournal(String, String, String, int, int, String) - Static method in class org.hornetq.core.journal.impl.ExportJournal
 
exportJournal(String, String, String, int, int, PrintStream) - Static method in class org.hornetq.core.journal.impl.ExportJournal
 
exportJournalFile(PrintStream, SequentialFileFactory, JournalFile) - Static method in class org.hornetq.core.journal.impl.ExportJournal
 
extraData - Variable in class org.hornetq.core.journal.PreparedTransactionInfo
 

F

factory - Variable in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
failedToAddFile(JournalFile) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
failedToPerfBlast(Throwable) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
failedTransaction(long, List<RecordInfo>, List<RecordInfo>) - Method in interface org.hornetq.core.journal.TransactionFailureCallback
To be used to inform about transactions without commit records.
FILE_COMPACT_CONTROL - Static variable in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
fileFactory - Variable in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
fileFactory - Variable in class org.hornetq.core.journal.impl.SyncSpeedTest
 
fileFinalizedWhileOpen(String) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
fileID - Variable in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
 
fileIdOutOfOrder() - Method in interface org.hornetq.journal.HornetQJournalLogger
 
fileNotOpened() - Method in interface org.hornetq.journal.HornetQJournalBundle
 
fileSize - Variable in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
filesRepository - Variable in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
fileTooSmall() - Method in interface org.hornetq.journal.HornetQJournalLogger
 
FileWrapperJournal - Class in org.hornetq.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.hornetq.core.journal.impl.FileWrapperJournal
 
fill(long, int, long, byte) - Method in interface org.hornetq.core.asyncio.AsynchronousFile
 
fill(long, int, long, byte) - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
fill(int, int, byte) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
fill(int, int, byte) - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
fill(int, int, byte) - Method in interface org.hornetq.core.journal.SequentialFile
 
FILL_CHARACTER - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
fillNumberOfRecords(JournalFile, JournalInternalRecord) - Method in class org.hornetq.core.journal.impl.JournalTransaction
 
finalize() - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
finalize() - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
fits(int) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
fits(int) - Method in interface org.hornetq.core.journal.SequentialFile
 
flush() - Method in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
Write pending output into file
flush() - Method in class org.hornetq.core.journal.impl.TimedBuffer
 
flush(boolean) - Method in class org.hornetq.core.journal.impl.TimedBuffer
force means the Journal is moving to a new file.
flush() - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
flushBuffer(ByteBuffer, boolean, List<IOAsyncTask>) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile.LocalBufferObserver
 
flushBuffer(ByteBuffer, boolean, List<IOAsyncTask>) - Method in interface org.hornetq.core.journal.impl.TimedBufferObserver
 
flushRate(Double) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
forceMoveNextFile() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
forceMoveNextFile() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
forceMoveNextFile() - Method in interface org.hornetq.core.journal.Journal
Force the usage of a new JournalFile.
forceMoveNextFile() - Method in interface org.hornetq.core.journal.TestableJournal
 
forget() - Method in class org.hornetq.core.journal.impl.JournalTransaction
Used by load, when the transaction was not loaded correctly
FORMAT_VERSION - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 

G

getAlignment() - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
getAlignment() - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
getAlignment() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
getAlignment() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getAlignment() - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
getAlignment() - Method in class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
getAlignment() - Method in interface org.hornetq.core.journal.Journal
 
getAlignment() - Method in interface org.hornetq.core.journal.SequentialFile
 
getAlignment() - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
getBlockSize() - Method in interface org.hornetq.core.asyncio.AsynchronousFile
 
getBlockSize() - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
getCallback(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalTransaction
 
getCompactCount() - Method in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
 
getCompactor() - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
getCompactor() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getCompactor() - Method in interface org.hornetq.core.journal.impl.JournalRecordProvider
 
getCounter(Long, Map<Long, AtomicInteger>) - Static method in class org.hornetq.core.journal.impl.ImportJournal
 
getCounter(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalTransaction
 
getCurrentFile() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getCurrentFile() - Method in interface org.hornetq.core.journal.TestableJournal
 
getDataFiles() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
getDataFiles() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
getDataFiles() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getDataFiles() - Method in interface org.hornetq.core.journal.Journal
Returns the JournalFiles in use.
getDataFiles() - Method in interface org.hornetq.core.journal.TestableJournal
 
getDataFilesArray() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
getDataFilesCount() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
getDataFilesCount() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getDataFilesCount() - Method in interface org.hornetq.core.journal.TestableJournal
 
getDelegateCompletion() - Method in class org.hornetq.core.journal.impl.TransactionCallback
 
getDirectory() - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
getEncodeSize() - Method in interface org.hornetq.core.journal.EncodingSupport
 
getEncodeSize() - Method in class org.hornetq.core.journal.impl.dataformat.ByteArrayEncoding
 
getEncodeSize() - Method in class org.hornetq.core.journal.impl.dataformat.JournalAddRecord
 
getEncodeSize() - Method in class org.hornetq.core.journal.impl.dataformat.JournalAddRecordTX
 
getEncodeSize() - Method in class org.hornetq.core.journal.impl.dataformat.JournalCompleteRecordTX
 
getEncodeSize() - Method in class org.hornetq.core.journal.impl.dataformat.JournalDeleteRecord
 
getEncodeSize() - Method in class org.hornetq.core.journal.impl.dataformat.JournalDeleteRecordTX
 
getEncodeSize() - Method in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
 
getEncodeSize() - Method in class org.hornetq.core.journal.impl.dataformat.JournalRollbackRecordTX
 
getErrorCode() - Method in class org.hornetq.core.journal.impl.TransactionCallback
 
getErrorMessage() - Method in class org.hornetq.core.journal.impl.TransactionCallback
 
getFile() - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
getFile() - Method in interface org.hornetq.core.journal.impl.JournalFile
 
getFile() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
getFileExtension() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
getFileExtension() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getFileExtension() - Method in interface org.hornetq.core.journal.TestableJournal
 
getFileFactory() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
getFileFactory() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getFileFactory() - Method in interface org.hornetq.core.journal.Journal
 
getFileID() - Method in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
 
getFileID() - Method in interface org.hornetq.core.journal.impl.JournalFile
 
getFileID() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
getFileName() - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
getFileName() - Method in interface org.hornetq.core.journal.SequentialFile
 
getFilePrefix() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
getFilePrefix() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getFilePrefix() - Method in interface org.hornetq.core.journal.TestableJournal
 
getFileSize() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getFileSize() - Method in interface org.hornetq.core.journal.Journal
 
getFileSize() - Method in interface org.hornetq.core.journal.TestableJournal
 
getFreeFile() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
getFreeFiles() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
getFreeFilesCount() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
getFreeFilesCount() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getFreeFilesCount() - Method in interface org.hornetq.core.journal.TestableJournal
 
getHandler() - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
Return the JNI handler used on C++
getId() - Method in class org.hornetq.core.journal.impl.JournalTransaction
 
getIDMapSize() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getIDMapSize() - Method in interface org.hornetq.core.journal.TestableJournal
 
getJavaFile() - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
getJavaFile() - Method in interface org.hornetq.core.journal.SequentialFile
Returns a native File of the file underlying this sequential file.
getJournalVersion() - Method in interface org.hornetq.core.journal.impl.JournalFile
 
getJournalVersion() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
getLiveSize() - Method in interface org.hornetq.core.journal.impl.JournalFile
 
getLiveSize() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
getMaxAIO() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
getMaxAIO() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getMaxAIO() - Method in interface org.hornetq.core.journal.TestableJournal
 
getMaxID() - Method in class org.hornetq.core.journal.JournalLoadInformation
 
getMinFiles() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getMinFiles() - Method in interface org.hornetq.core.journal.TestableJournal
 
getNegCount(JournalFile) - Method in interface org.hornetq.core.journal.impl.JournalFile
 
getNegCount(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
getNewDataFiles() - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
getNewRecords() - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
getNewTransactions() - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
getNumberOfRecords() - Method in class org.hornetq.core.journal.impl.dataformat.JournalCompleteRecordTX
 
getNumberOfRecords() - Method in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
 
getNumberOfRecords() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
getNumberOfRecords() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getNumberOfRecords() - Method in interface org.hornetq.core.journal.Journal
 
getNumberOfRecords() - Method in class org.hornetq.core.journal.JournalLoadInformation
 
getOffset() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
getOpenedFilesCount() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
getOpenedFilesCount() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getOpenedFilesCount() - Method in interface org.hornetq.core.journal.TestableJournal
 
getPosCount() - Method in interface org.hornetq.core.journal.impl.JournalFile
 
getPosCount() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
getPositiveArray() - Method in class org.hornetq.core.journal.impl.JournalTransaction
 
getRecordID() - Method in interface org.hornetq.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.hornetq.core.journal.impl.JournalFileImpl
 
getRecords() - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
getRecords() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getRecords() - Method in interface org.hornetq.core.journal.impl.JournalRecordProvider
 
getRemainingBytes() - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile.LocalBufferObserver
 
getRemainingBytes() - Method in interface org.hornetq.core.journal.impl.TimedBufferObserver
Return the number of remaining bytes that still fit on the observer (file)
getTotalMaxIO() - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
For test purposes
getTotalNegativeToOthers() - Method in interface org.hornetq.core.journal.impl.JournalFile
The total number of deletes this file has
getTotalNegativeToOthers() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
getUserRecordType() - Method in class org.hornetq.core.journal.RecordInfo
 
getUserVersion() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
getUserVersion() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
getUserVersion() - Method in interface org.hornetq.core.journal.Journal
 
getWritingChannel() - Method in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 

H

hashCode() - Method in class org.hornetq.core.journal.JournalLoadInformation
 
hashCode() - Method in class org.hornetq.core.journal.RecordInfo
 
HornetQFileLock - Class in org.hornetq.core.asyncio.impl
A HornetQFileLock
HornetQFileLock(int) - Constructor for class org.hornetq.core.asyncio.impl.HornetQFileLock
 
HornetQJournalBundle - Interface in org.hornetq.journal
 
HornetQJournalLogger - Interface in org.hornetq.journal
 

I

id - Variable in class org.hornetq.core.journal.PreparedTransactionInfo
 
id - Variable in class org.hornetq.core.journal.RecordInfo
 
ImportJournal - Class in org.hornetq.core.journal.impl
Use this class to import the journal data from a listed file.
ImportJournal() - Constructor for class org.hornetq.core.journal.impl.ImportJournal
 
importJournal(String, String, String, int, int, String) - Static method in class org.hornetq.core.journal.impl.ImportJournal
 
importJournal(String, String, String, int, int, InputStream) - Static method in class org.hornetq.core.journal.impl.ImportJournal
 
importJournal(String, String, String, int, int, Reader) - Static method in class org.hornetq.core.journal.impl.ImportJournal
 
incCounter(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalTransaction
 
incNegCount(JournalFile) - Method in interface org.hornetq.core.journal.impl.JournalFile
 
incNegCount(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
incompatibleNativeLibrary() - Method in interface org.hornetq.journal.HornetQJournalLogger
 
inconsistencyDuringCompacting(Long) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
inconsistencyDuringCompactingDelete(Long) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
incPosCount() - Method in interface org.hornetq.core.journal.impl.JournalFile
 
incPosCount() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
initFileHeader(SequentialFileFactory, SequentialFile, int, long) - Static method in class org.hornetq.core.journal.impl.JournalImpl
 
IOAsyncTask - Interface in org.hornetq.core.journal
This class is just a direct extension of AIOCallback.
IOCompletion - Interface in org.hornetq.core.journal
A IOCompletion
IOCriticalErrorListener - Interface in org.hornetq.core.journal
A IOCriticalErrorListener
ioError(int, String) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
IOExceptionListener - Interface in org.hornetq.core.asyncio
A IOExceptionListener
ioRenameFileError(String, String) - Method in interface org.hornetq.journal.HornetQJournalBundle
 
isAutoReclaim() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
isAutoReclaim() - Method in interface org.hornetq.core.journal.TestableJournal
 
isCanReclaim() - Method in interface org.hornetq.core.journal.impl.JournalFile
Whether this file's contents can deleted and the file reused.
isCanReclaim() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
isLoaded() - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
isOpen() - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
isOpen() - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
isOpen() - Method in interface org.hornetq.core.journal.SequentialFile
 
isStarted() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
isStarted() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
isSupported() - Static method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
isSupportsCallbacks() - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
isSupportsCallbacks() - Method in class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
isSupportsCallbacks() - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
isUpdate - Variable in class org.hornetq.core.journal.RecordInfo
 
isUseSleep() - Method in class org.hornetq.core.journal.impl.TimedBuffer
 
isValid() - Method in class org.hornetq.core.asyncio.impl.HornetQFileLock
 

J

journal - Variable in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
Journal - Interface in org.hornetq.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.hornetq.core.journal
 
JournalAddRecord - Class in org.hornetq.core.journal.impl.dataformat
A JournalAddRecord
JournalAddRecord(boolean, long, byte, EncodingSupport) - Constructor for class org.hornetq.core.journal.impl.dataformat.JournalAddRecord
 
JournalAddRecordTX - Class in org.hornetq.core.journal.impl.dataformat
A JournalAddRecordTX
JournalAddRecordTX(boolean, long, long, byte, EncodingSupport) - Constructor for class org.hornetq.core.journal.impl.dataformat.JournalAddRecordTX
 
JournalCompactor - Class in org.hornetq.core.journal.impl
A JournalCompactor
JournalCompactor(SequentialFileFactory, JournalImpl, JournalFilesRepository, Set<Long>, long) - Constructor for class org.hornetq.core.journal.impl.JournalCompactor
 
JournalCompleteRecordTX - Class in org.hornetq.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.hornetq.core.journal.impl.dataformat.JournalCompleteRecordTX
 
JournalCompleteRecordTX.TX_RECORD_TYPE - Enum in org.hornetq.core.journal.impl.dataformat
 
JournalConstants - Class in org.hornetq.core.journal.impl
 
JournalConstants() - Constructor for class org.hornetq.core.journal.impl.JournalConstants
 
JournalDeleteRecord - Class in org.hornetq.core.journal.impl.dataformat
A JournalDeleteRecord
JournalDeleteRecord(long) - Constructor for class org.hornetq.core.journal.impl.dataformat.JournalDeleteRecord
 
JournalDeleteRecordTX - Class in org.hornetq.core.journal.impl.dataformat
A JournalDeleteRecordTX
JournalDeleteRecordTX(long, long, EncodingSupport) - Constructor for class org.hornetq.core.journal.impl.dataformat.JournalDeleteRecordTX
 
journalDifferentVersion() - Method in interface org.hornetq.journal.HornetQJournalBundle
 
JournalFile - Interface in org.hornetq.core.journal.impl
A JournalFile
JournalFileImpl - Class in org.hornetq.core.journal.impl
A JournalFileImpl
JournalFileImpl(SequentialFile, long, int) - Constructor for class org.hornetq.core.journal.impl.JournalFileImpl
 
journalFileMisMatch() - Method in interface org.hornetq.journal.HornetQJournalBundle
 
JournalFilesRepository - Class in org.hornetq.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) - Constructor for class org.hornetq.core.journal.impl.JournalFilesRepository
 
JournalImpl - Class in org.hornetq.core.journal.impl
A circular log implementation.

JournalImpl(int, int, int, int, SequentialFileFactory, String, String, int) - Constructor for class org.hornetq.core.journal.impl.JournalImpl
 
JournalImpl(int, int, int, int, SequentialFileFactory, String, String, int, int) - Constructor for class org.hornetq.core.journal.impl.JournalImpl
 
JournalInternalRecord - Class in org.hornetq.core.journal.impl.dataformat
A InternalEncoder
JournalInternalRecord() - Constructor for class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
 
JournalLoadInformation - Class in org.hornetq.core.journal
This is a POJO containing information about the journal during load time.
JournalLoadInformation() - Constructor for class org.hornetq.core.journal.JournalLoadInformation
 
JournalLoadInformation(int, long) - Constructor for class org.hornetq.core.journal.JournalLoadInformation
 
JournalReaderCallback - Interface in org.hornetq.core.journal.impl
A JournalReader
JournalReaderCallbackAbstract - Class in org.hornetq.core.journal.impl
A JournalReaderCallbackAbstract
JournalReaderCallbackAbstract() - Constructor for class org.hornetq.core.journal.impl.JournalReaderCallbackAbstract
 
JournalRecord - Class in org.hornetq.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.hornetq.core.journal.impl.JournalRecord
 
JournalRecordProvider - Interface in org.hornetq.core.journal.impl
This is an interface used only internally.
JournalRollbackRecordTX - Class in org.hornetq.core.journal.impl.dataformat
A JournalRollbackRecordTX
JournalRollbackRecordTX(long) - Constructor for class org.hornetq.core.journal.impl.dataformat.JournalRollbackRecordTX
 
JournalTransaction - Class in org.hornetq.core.journal.impl
A JournalTransaction
JournalTransaction(long, JournalRecordProvider) - Constructor for class org.hornetq.core.journal.impl.JournalTransaction
 

L

lineUpContext(IOCompletion) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
lineUpContext(IOCompletion) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
lineUpContext(IOCompletion) - Method in interface org.hornetq.core.journal.Journal
 
listFiles(String) - Method in interface org.hornetq.core.journal.SequentialFileFactory
Lists files that end with the given extension.
load(LoaderCallback) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
load(List<RecordInfo>, List<PreparedTransactionInfo>, TransactionFailureCallback) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
load(List<RecordInfo>, List<PreparedTransactionInfo>, TransactionFailureCallback) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
load(List<RecordInfo>, List<PreparedTransactionInfo>, TransactionFailureCallback, boolean) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
load(LoaderCallback) - Method in class org.hornetq.core.journal.impl.JournalImpl
Load data accordingly to the record layouts
load(LoaderCallback) - Method in interface org.hornetq.core.journal.Journal
 
load(List<RecordInfo>, List<PreparedTransactionInfo>, TransactionFailureCallback) - Method in interface org.hornetq.core.journal.Journal
 
LoaderCallback - Interface in org.hornetq.core.journal
 
loadInternalOnly() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
loadInternalOnly() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
loadInternalOnly() - Method in interface org.hornetq.core.journal.Journal
Load internal data structures and not expose any data.
loadSyncOnly(Journal.JournalState) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
loadSyncOnly(Journal.JournalState) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
loadSyncOnly(Journal.JournalState) - Method in interface org.hornetq.core.journal.Journal
Load internal data structures, and remain waiting for synchronization to complete.
lock(int) - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
LOGGER - Static variable in interface org.hornetq.journal.HornetQJournalLogger
The journal logger.
lookupRecord(long) - Method in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 

M

main(String[]) - Static method in class org.hornetq.core.journal.impl.CompactJournal
 
main(String[]) - Static method in class org.hornetq.core.journal.impl.ExportJournal
 
main(String[]) - Static method in class org.hornetq.core.journal.impl.ImportJournal
 
main(String[]) - Static method in class org.hornetq.core.journal.impl.SyncSpeedTest
 
markAsDataFile(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
markAsDataFile(JournalFile) - Method in interface org.hornetq.core.journal.impl.JournalReaderCallback
 
markAsDataFile(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalReaderCallbackAbstract
 
MAX_CHECKS_ON_SLEEP - Static variable in class org.hornetq.core.journal.impl.TimedBuffer
 
merge(JournalTransaction) - Method in class org.hornetq.core.journal.impl.JournalTransaction
This is used to merge transactions from compacting
MIN_FILE_SIZE - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
movingNextFile(JournalFile) - Method in interface org.hornetq.journal.HornetQJournalLogger
 

N

nanoSleep() - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
newBuffer(int) - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
This needs to be synchronized because of http://bugs.sun.com/view_bug.do?bug_id=6791815 http://mail.openjdk.java.net/pipermail/hotspot-runtime-dev/2009-January/000386.html
newBuffer(int, int) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile.LocalBufferObserver
 
newBuffer(int, int) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
newBuffer(int, int) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
newBuffer(int) - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
newBuffer(int, int) - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
newBuffer(int) - Method in class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
newBuffer(int, int) - Method in interface org.hornetq.core.journal.impl.TimedBufferObserver
 
newBuffer(int) - Method in interface org.hornetq.core.journal.SequentialFileFactory
Note: You need to release the buffer if is used for reading operations.
newDataFiles - Variable in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
nextOrderingID - Variable in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
NIOSequentialFile - Class in org.hornetq.core.journal.impl
A NIOSequentialFile
NIOSequentialFile(SequentialFileFactory, String, String, int, Executor) - Constructor for class org.hornetq.core.journal.impl.NIOSequentialFile
 
NIOSequentialFile(SequentialFileFactory, File, int, Executor) - Constructor for class org.hornetq.core.journal.impl.NIOSequentialFile
 
NIOSequentialFileFactory - Class in org.hornetq.core.journal.impl
A NIOSequentialFileFactory
NIOSequentialFileFactory(String) - Constructor for class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
NIOSequentialFileFactory(String, IOCriticalErrorListener) - Constructor for class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
NIOSequentialFileFactory(String, boolean) - Constructor for class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
NIOSequentialFileFactory(String, boolean, IOCriticalErrorListener) - Constructor for class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
NIOSequentialFileFactory(String, boolean, int, int, boolean) - Constructor for class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
NIOSequentialFileFactory(String, boolean, int, int, boolean, IOCriticalErrorListener) - Constructor for class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
noRecordDuringCompactReplay(Long) - Method in interface org.hornetq.journal.HornetQJournalLogger
 

O

onCompactDone() - Method in class org.hornetq.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.hornetq.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.hornetq.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 interface org.hornetq.core.asyncio.AIOCallback
Method for error notifications.
onError(int, String) - Method in class org.hornetq.core.journal.impl.SimpleWaitIOCallback
 
onError(int, String) - Method in class org.hornetq.core.journal.impl.TransactionCallback
 
onIOError(Exception, String, SequentialFile) - Method in interface org.hornetq.core.journal.SequentialFileFactory
The SequentialFile will call this method when a disk IO Error happens during the live phase.
onIOException(Exception, String) - Method in interface org.hornetq.core.asyncio.IOExceptionListener
 
onIOException(Exception, String) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
onIOException(Exception, String, SequentialFile) - Method in interface org.hornetq.core.journal.IOCriticalErrorListener
 
onReadAddRecord(RecordInfo) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
onReadAddRecord(RecordInfo) - Method in interface org.hornetq.core.journal.impl.JournalReaderCallback
 
onReadAddRecord(RecordInfo) - Method in class org.hornetq.core.journal.impl.JournalReaderCallbackAbstract
 
onReadAddRecordTX(long, RecordInfo) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
onReadAddRecordTX(long, RecordInfo) - Method in interface org.hornetq.core.journal.impl.JournalReaderCallback
 
onReadAddRecordTX(long, RecordInfo) - Method in class org.hornetq.core.journal.impl.JournalReaderCallbackAbstract
 
onReadCommitRecord(long, int) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
onReadCommitRecord(long, int) - Method in interface org.hornetq.core.journal.impl.JournalReaderCallback
 
onReadCommitRecord(long, int) - Method in class org.hornetq.core.journal.impl.JournalReaderCallbackAbstract
 
onReadDeleteRecord(long) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
onReadDeleteRecord(long) - Method in interface org.hornetq.core.journal.impl.JournalReaderCallback
 
onReadDeleteRecord(long) - Method in class org.hornetq.core.journal.impl.JournalReaderCallbackAbstract
 
onReadDeleteRecordTX(long, RecordInfo) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
onReadDeleteRecordTX(long, RecordInfo) - Method in interface org.hornetq.core.journal.impl.JournalReaderCallback
 
onReadDeleteRecordTX(long, RecordInfo) - Method in class org.hornetq.core.journal.impl.JournalReaderCallbackAbstract
 
onReadPrepareRecord(long, byte[], int) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
onReadPrepareRecord(long, byte[], int) - Method in interface org.hornetq.core.journal.impl.JournalReaderCallback
 
onReadPrepareRecord(long, byte[], int) - Method in class org.hornetq.core.journal.impl.JournalReaderCallbackAbstract
 
onReadRollbackRecord(long) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
onReadRollbackRecord(long) - Method in interface org.hornetq.core.journal.impl.JournalReaderCallback
 
onReadRollbackRecord(long) - Method in class org.hornetq.core.journal.impl.JournalReaderCallbackAbstract
 
onReadUpdateRecord(RecordInfo) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
onReadUpdateRecord(RecordInfo) - Method in interface org.hornetq.core.journal.impl.JournalReaderCallback
 
onReadUpdateRecord(RecordInfo) - Method in class org.hornetq.core.journal.impl.JournalReaderCallbackAbstract
 
onReadUpdateRecordTX(long, RecordInfo) - Method in class org.hornetq.core.journal.impl.JournalCompactor
 
onReadUpdateRecordTX(long, RecordInfo) - Method in interface org.hornetq.core.journal.impl.JournalReaderCallback
 
onReadUpdateRecordTX(long, RecordInfo) - Method in class org.hornetq.core.journal.impl.JournalReaderCallbackAbstract
 
open(String, int) - Method in interface org.hornetq.core.asyncio.AsynchronousFile
Note: If you are using a native Linux implementation, maxIO can't be higher than what's defined on /proc/sys/fs/aio-max-nr, or you would get an error
open(String, int) - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
open() - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
open(int, boolean) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
open() - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
this.maxIO represents the default maxIO.
open(int, boolean) - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
open() - Method in interface org.hornetq.core.journal.SequentialFile
 
open(int, boolean) - Method in interface org.hornetq.core.journal.SequentialFile
The maximum number of simultaneous writes accepted
openFile(String) - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
openFile() - Method in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
openFile(JournalFile, boolean) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
openFile() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
This method will instantly return the opened file, and schedule opening and reclaiming.
orderFiles() - Method in class org.hornetq.core.journal.impl.JournalImpl
this method is used internally only however tools may use it to maintenance.
org.hornetq.core.asyncio - package org.hornetq.core.asyncio
 
org.hornetq.core.asyncio.impl - package org.hornetq.core.asyncio.impl
 
org.hornetq.core.journal - package org.hornetq.core.journal
 
org.hornetq.core.journal.impl - package org.hornetq.core.journal.impl
 
org.hornetq.core.journal.impl.dataformat - package org.hornetq.core.journal.impl.dataformat
 
org.hornetq.journal - package org.hornetq.journal
 

P

parseLine(String[]) - Static method in class org.hornetq.core.journal.impl.ImportJournal
 
parseRecord(Properties) - Static method in class org.hornetq.core.journal.impl.ImportJournal
 
perfBlast(int) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
perfBlast(int) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
perfBlast(int) - Method in interface org.hornetq.core.journal.Journal
 
pollLastDataFile() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
position - Variable in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
position(long) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
position() - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
position(long) - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
position(long) - Method in interface org.hornetq.core.journal.SequentialFile
 
position() - Method in interface org.hornetq.core.journal.SequentialFile
 
prepare(JournalFile) - Method in class org.hornetq.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.hornetq.core.journal.impl.JournalImpl
 
PreparedTransactionInfo - Class in org.hornetq.core.journal
A PreparedTransactionInfo
PreparedTransactionInfo(long, byte[]) - Constructor for class org.hornetq.core.journal.PreparedTransactionInfo
 
preparedTXIncomplete(Long) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
pushOpenedFile() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
Open a file and place it into the openedFiles queue

R

read(long, long, ByteBuffer, AIOCallback) - Method in interface org.hornetq.core.asyncio.AsynchronousFile
 
read(long, long, ByteBuffer, AIOCallback) - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
read(ByteBuffer, IOAsyncTask) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
read(ByteBuffer) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
read(ByteBuffer) - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
read(ByteBuffer, IOAsyncTask) - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
read(ByteBuffer, IOAsyncTask) - Method in interface org.hornetq.core.journal.SequentialFile
 
read(ByteBuffer) - Method in interface org.hornetq.core.journal.SequentialFile
 
readControlFile(SequentialFileFactory, List<String>, List<String>, List<Pair<String, String>>) - Static method in class org.hornetq.core.journal.impl.JournalCompactor
 
readJournalFile(SequentialFileFactory, JournalFile, JournalReaderCallback) - Static method in class org.hornetq.core.journal.impl.JournalImpl
this method is used internally only however tools may use it to maintenance.
Reclaimer - Class in org.hornetq.core.journal.impl
The journal consists of an ordered list of journal files Fn where 0 <= n <= N
Reclaimer() - Constructor for class org.hornetq.core.journal.impl.Reclaimer
 
RecordInfo - Class in org.hornetq.core.journal
A RecordInfo
RecordInfo(long, byte, byte[], boolean, short) - Constructor for class org.hornetq.core.journal.RecordInfo
 
records - Variable in class org.hornetq.core.journal.PreparedTransactionInfo
 
recordsToDelete - Variable in class org.hornetq.core.journal.PreparedTransactionInfo
 
release() - Method in class org.hornetq.core.asyncio.impl.HornetQFileLock
 
releaseBuffer(ByteBuffer) - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
releaseBuffer(ByteBuffer) - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
releaseDirectBuffer(ByteBuffer) - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
releaseDirectBuffer(ByteBuffer) - Method in class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
releaseDirectBuffer(ByteBuffer) - Method in interface org.hornetq.core.journal.SequentialFileFactory
used for cases where you need direct buffer outside of the journal context.
removeDataFile(JournalFile) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
renameExtensionFile(String, String) - Static method in class org.hornetq.core.journal.impl.JournalImpl
 
renameFiles(List<JournalFile>, List<JournalFile>) - Method in class org.hornetq.core.journal.impl.JournalImpl
being protected as testcases can override this method
renameTo(String) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
renameTo(String) - Method in interface org.hornetq.core.journal.SequentialFile
 
replaceRecordProvider(JournalRecordProvider) - Method in class org.hornetq.core.journal.impl.JournalTransaction
 
replayPendingCommands() - Method in class org.hornetq.core.journal.impl.JournalCompactor
Replay pending counts that happened during compacting
replicationSyncFinished() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
replicationSyncFinished() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
replicationSyncFinished() - Method in interface org.hornetq.core.journal.Journal
Restarts file reclaim and compacting on the journal.
replicationSyncPreserveOldFiles() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
replicationSyncPreserveOldFiles() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
replicationSyncPreserveOldFiles() - Method in interface org.hornetq.core.journal.Journal
Stops any operation that may delete or modify old (stale) data.
resetMaxAIO() - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
rollback(JournalFile) - Method in class org.hornetq.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.hornetq.core.journal.impl.JournalImpl
 
run() - Method in class org.hornetq.core.journal.impl.SyncSpeedTest
 
run2() - Method in class org.hornetq.core.journal.impl.SyncSpeedTest
 
runDirectJournalBlast() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
runDirectJournalBlast() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
runDirectJournalBlast() - Method in interface org.hornetq.core.journal.Journal
 
runningJournalBlast(Integer) - Method in interface org.hornetq.journal.HornetQJournalLogger
 

S

scan(JournalFile[]) - Method in class org.hornetq.core.journal.impl.Reclaimer
 
scheduleCompactAndBlock(int) - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
scheduleCompactAndBlock(int) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
scheduleCompactAndBlock(int) - Method in interface org.hornetq.core.journal.Journal
This method will start compact using the compactorExecutor and block up to timeout seconds
seqOutOfOrder() - Method in interface org.hornetq.journal.HornetQJournalLogger
 
sequentialFile - Variable in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
SequentialFile - Interface in org.hornetq.core.journal
A SequentialFile
SequentialFileFactory - Interface in org.hornetq.core.journal
A SequentialFileFactory
setAutoReclaim(boolean) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
setAutoReclaim(boolean) - Method in interface org.hornetq.core.journal.TestableJournal
 
setBufferCallback(BufferCallback) - Method in interface org.hornetq.core.asyncio.AsynchronousFile
 
setBufferCallback(BufferCallback) - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
setBufferCallback(BufferCallback) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
setCanReclaim(boolean) - Method in interface org.hornetq.core.journal.impl.JournalFile
Whether this file's contents can deleted and the file reused.
setCanReclaim(boolean) - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
setCompactCount(short) - Method in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
 
setCompacting() - Method in class org.hornetq.core.journal.impl.JournalTransaction
 
setDelegateCompletion(IOAsyncTask) - Method in class org.hornetq.core.journal.impl.TransactionCallback
 
setExecutor(Executor) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
setFileID(int) - Method in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
 
setMaxID(long) - Method in class org.hornetq.core.journal.JournalLoadInformation
 
setNanoSleepInterval(int) - Static method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
Instead of passing the nanoSeconds through the stack call every time, we set it statically inside the native method
setNextFileID(long) - Method in class org.hornetq.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.hornetq.core.journal.impl.dataformat.JournalCompleteRecordTX
 
setNumberOfRecords(int) - Method in class org.hornetq.core.journal.impl.dataformat.JournalInternalRecord
 
setNumberOfRecords(int) - Method in class org.hornetq.core.journal.JournalLoadInformation
 
setObserver(TimedBufferObserver) - Method in class org.hornetq.core.journal.impl.TimedBuffer
 
setOffset(long) - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
setTimedBuffer(TimedBuffer) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
setTimedBuffer(TimedBuffer) - Method in interface org.hornetq.core.journal.SequentialFile
 
setUpCurrentFile(int) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
setupFactory() - Method in class org.hornetq.core.journal.impl.SyncSpeedTest
 
setUseSleep(boolean) - Method in class org.hornetq.core.journal.impl.TimedBuffer
 
SimpleWaitIOCallback - Class in org.hornetq.core.journal.impl
A SimpleWaitIOCallback
SimpleWaitIOCallback() - Constructor for class org.hornetq.core.journal.impl.SimpleWaitIOCallback
 
size() - Method in interface org.hornetq.core.asyncio.AsynchronousFile
Warning: This function will perform a synchronous IO, probably translating to a fstat call
size() - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
size() - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
size() - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
size() - Method in interface org.hornetq.core.journal.SequentialFile
 
SIZE_ADD_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
SIZE_ADD_RECORD_TX - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
SIZE_COMMIT_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
SIZE_COMPLETE_TRANSACTION_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
SIZE_DELETE_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
SIZE_DELETE_RECORD_TX - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
SIZE_HEADER - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
SIZE_PREPARE_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
SIZE_ROLLBACK_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
sleep(int, int) - Method in class org.hornetq.core.journal.impl.TimedBuffer
Sub classes (tests basically) can use this to override how the sleep is being done
start() - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
start() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
start() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
start() - Method in class org.hornetq.core.journal.impl.TimedBuffer
 
start() - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
startingThread() - Method in interface org.hornetq.journal.HornetQJournalLogger
 
startSpin() - Method in class org.hornetq.core.journal.impl.TimedBuffer
Sub classes (tests basically) can use this to override disabling spinning
stop() - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
stop() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
stop() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
stop() - Method in class org.hornetq.core.journal.impl.TimedBuffer
 
stop() - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
stopSpin() - Method in class org.hornetq.core.journal.impl.TimedBuffer
Sub classes (tests basically) can use this to override disabling spinning
storeLineUp() - Method in class org.hornetq.core.journal.impl.SimpleWaitIOCallback
 
storeLineUp() - Method in interface org.hornetq.core.journal.IOCompletion
 
switchFileIfNecessary(int) - Method in class org.hornetq.core.journal.impl.JournalImpl
 
sync() - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
sync() - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
sync() - Method in interface org.hornetq.core.journal.SequentialFile
 
synchronizationLock() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
synchronizationLock() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
synchronizationLock() - Method in interface org.hornetq.core.journal.Journal
Write lock the Journal and write lock the compacting process.
synchronizationUnlock() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
synchronizationUnlock() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
synchronizationUnlock() - Method in interface org.hornetq.core.journal.Journal
Unlock the Journal and the compacting process.
SyncIOCompletion - Class in org.hornetq.core.journal.impl
Internal class used to manage explicit syncs on the Journal through callbacks.
SyncIOCompletion() - Constructor for class org.hornetq.core.journal.impl.SyncIOCompletion
 
SyncSpeedTest - Class in org.hornetq.core.journal.impl
A SyncSpeedTest This class just provides some diagnostics on how fast your disk can sync Useful when determining performance issues
SyncSpeedTest() - Constructor for class org.hornetq.core.journal.impl.SyncSpeedTest
 

T

takeFile(boolean, boolean, boolean, boolean) - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
This will get a File from freeFile without initializing it
tempFilesLeftOpen() - Method in interface org.hornetq.journal.HornetQJournalLogger
 
TestableJournal - Interface in org.hornetq.core.journal
A TestableJournal
testCompact() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
testCompact() - Method in interface org.hornetq.core.journal.TestableJournal
 
testScaleAIO() - Method in class org.hornetq.core.journal.impl.SyncSpeedTest
 
timedBuffer - Variable in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
TimedBuffer - Class in org.hornetq.core.journal.impl
A TimedBuffer
TimedBuffer(int, int, boolean) - Constructor for class org.hornetq.core.journal.impl.TimedBuffer
 
timedBufferObserver - Variable in class org.hornetq.core.journal.impl.AbstractSequentialFile
Instead of having AIOSequentialFile implementing the Observer, I have done it on an inner class.
TimedBufferObserver - Interface in org.hornetq.core.journal.impl
A TimedBufferObserver
timeoutOnPollerShutdown(Exception) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
timeoutOnWriterShutdown(Throwable) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
toString() - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile.LocalBufferObserver
 
toString() - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
toString() - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
toString() - Method in class org.hornetq.core.journal.impl.FileWrapperJournal
 
toString() - Method in class org.hornetq.core.journal.impl.JournalFileImpl
 
toString() - Method in class org.hornetq.core.journal.impl.JournalFilesRepository
 
toString() - Method in class org.hornetq.core.journal.impl.JournalImpl
 
toString() - Method in class org.hornetq.core.journal.impl.JournalRecord
 
toString() - Method in class org.hornetq.core.journal.impl.JournalTransaction
 
toString() - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
toString() - Method in class org.hornetq.core.journal.impl.SimpleWaitIOCallback
 
toString() - Method in class org.hornetq.core.journal.JournalLoadInformation
 
toString() - Method in class org.hornetq.core.journal.RecordInfo
 
TransactionCallback - Class in org.hornetq.core.journal.impl
A TransactionCallback
TransactionCallback() - Constructor for class org.hornetq.core.journal.impl.TransactionCallback
 
TransactionFailureCallback - Interface in org.hornetq.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.hornetq.journal.HornetQJournalLogger
 

U

uncomittedTxFound(Long) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
UPDATE_RECORD - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
UPDATE_RECORD_TX - Static variable in class org.hornetq.core.journal.impl.JournalImpl
 
updateRecord(RecordInfo) - Method in interface org.hornetq.core.journal.LoaderCallback
 
userRecordType - Variable in class org.hornetq.core.journal.RecordInfo
 

V

valueOf(String) - Static method in enum org.hornetq.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.hornetq.core.journal.Journal.JournalState
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.hornetq.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.hornetq.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.hornetq.core.journal.impl.JournalTransaction
 
waitCompletion() - Method in class org.hornetq.core.journal.impl.JournalTransaction
Wait completion at the latest file only
waitCompletion() - Method in class org.hornetq.core.journal.impl.SimpleWaitIOCallback
 
waitCompletion(long) - Method in class org.hornetq.core.journal.impl.SimpleWaitIOCallback
 
waitCompletion() - Method in class org.hornetq.core.journal.impl.SyncIOCompletion
 
waitCompletion() - Method in class org.hornetq.core.journal.impl.TransactionCallback
 
waitForClose() - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
waitForClose() - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
waitForClose() - Method in interface org.hornetq.core.journal.SequentialFile
 
wrapBuffer(byte[]) - Method in class org.hornetq.core.journal.impl.AIOSequentialFileFactory
 
wrapBuffer(byte[]) - Method in class org.hornetq.core.journal.impl.NIOSequentialFileFactory
 
wrapBuffer(byte[]) - Method in interface org.hornetq.core.journal.SequentialFileFactory
 
write(long, long, ByteBuffer, AIOCallback) - Method in interface org.hornetq.core.asyncio.AsynchronousFile
Any error will be reported on the callback interface
write(long, long, ByteBuffer, AIOCallback) - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
write(HornetQBuffer, boolean, IOAsyncTask) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
write(HornetQBuffer, boolean) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
write(EncodingSupport, boolean, IOAsyncTask) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
write(EncodingSupport, boolean) - Method in class org.hornetq.core.journal.impl.AbstractSequentialFile
 
write(HornetQBuffer, boolean, IOAsyncTask) - Method in interface org.hornetq.core.journal.SequentialFile
 
write(HornetQBuffer, boolean) - Method in interface org.hornetq.core.journal.SequentialFile
 
write(EncodingSupport, boolean, IOAsyncTask) - Method in interface org.hornetq.core.journal.SequentialFile
 
write(EncodingSupport, boolean) - Method in interface org.hornetq.core.journal.SequentialFile
 
writeControlFile(SequentialFileFactory, List<JournalFile>, List<JournalFile>, List<Pair<String, String>>) - Static method in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
writeDirect(ByteBuffer, boolean) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
writeDirect(ByteBuffer, boolean, IOAsyncTask) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
writeDirect(ByteBuffer, boolean, IOAsyncTask) - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
writeDirect(ByteBuffer, boolean) - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
writeDirect(ByteBuffer, boolean, IOAsyncTask) - Method in interface org.hornetq.core.journal.SequentialFile
Write directly to the file without using any buffer
writeDirect(ByteBuffer, boolean) - Method in interface org.hornetq.core.journal.SequentialFile
Write directly to the file without using any buffer
writeEncoder(JournalInternalRecord) - Method in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
writeEncoder(JournalInternalRecord, int) - Method in class org.hornetq.core.journal.impl.AbstractJournalUpdateTask
 
writeHeader(HornetQBuffer, int, long) - Static method in class org.hornetq.core.journal.impl.JournalImpl
 
writeInternal(long, long, ByteBuffer) - Method in interface org.hornetq.core.asyncio.AsynchronousFile
Performs an internal direct write.
writeInternal(long, long, ByteBuffer) - Method in class org.hornetq.core.asyncio.impl.AsynchronousFileImpl
 
writeInternal(ByteBuffer) - Method in class org.hornetq.core.journal.impl.AIOSequentialFile
 
writeInternal(ByteBuffer) - Method in class org.hornetq.core.journal.impl.NIOSequentialFile
 
writeInternal(ByteBuffer) - Method in interface org.hornetq.core.journal.SequentialFile
Write directly to the file.
writeRate(Double, Long) - Method in interface org.hornetq.journal.HornetQJournalLogger
 
writerExecutor - Variable in class org.hornetq.core.journal.impl.AbstractSequentialFile
Used for asynchronous writes
A B C D E F G H I J L M N O P R S T U V W 
HornetQ Journal 2.3.25.SP3-redhat-1

Copyright © 2015 JBoss, a division of Red Hat. All Rights Reserved.