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(Throwable, 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