- 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
-