- get(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- get(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- get(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- get(Transaction, Key) - Method in interface org.apache.activemq.store.kahadb.disk.index.Index
-
- get(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- get(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- get() - Method in class org.apache.activemq.store.kahadb.disk.page.Page
-
- get(int) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
-
- get(long) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
-
- get(Object) - Method in class org.apache.activemq.util.LFUCache
-
- getAccessorPool() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getAcks() - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx
-
- getActiveBins() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- getAdapters() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- getAllJobs() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- getAllJobs(long, long) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- getAllScheduledJobs(Transaction) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
Walks the Scheduled Job Tree and collects the add location and last update location
for all scheduled jobs.
- getBinCapacity() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- getBinPageId() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- getBinsActive() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- getBs() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark
-
- getByteSequence() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
-
- getChannel() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- getCheckpointInterval() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getCheckpointInterval() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Get the checkpointInterval
- getCheckpointInterval() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getChecksum() - Method in class org.apache.activemq.store.kahadb.disk.page.Page
-
- getCleanupInterval() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getCleanupInterval() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getCleanupInterval() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Get the cleanupInterval
- getCleanupInterval() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getCleanupInterval() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getCleanupOnStop() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getCleanupOnStop() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getCleanupOnStop() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getCompactAcksAfterNoGC() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getCompactAcksAfterNoGC() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getContainingList() - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- getCorruptedBlocks() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
-
- getCronEntry() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl
-
- getCurrentDataFile(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getCurrentDataFileId() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getData() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
-
- getDataFileById(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getDataFileId() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
-
- getDataFileId() - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- getDefaultDataDirectory() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getDefaultDataDirectory() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
-
- getDelay() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl
-
- getDestination() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- getDestination() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- getDestinations() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getDestinations() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- getDestinations() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- getDestinations() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
-
- getDirectory() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getDirectory() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getDirectory() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getDirectory() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Get the directory
- getDirectory() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getDirectory() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- getDirectory() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getDirectory() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- getDirectoryArchive() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getDirectoryArchive() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getDirectoryArchive() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getDirectoryArchive() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getDiskSize() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getDiskSize() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getException() - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- getExecutionCount() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl
-
- getExistingStoredDestination(KahaDestination, Transaction) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getFailoverProducersAuditDepth() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getFailoverProducersAuditDepth() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getFD() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- getFile() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
-
- getFile(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getFile() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getFileMap() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getFilePrefix() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getFiles() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
Get a set of files - only valid after start()
- getFileSuffix() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getFileType() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- getFileTypeVersion() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- getFirst(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- getFirst(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- getFirst(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- getFirst(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- getFirst() - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence
-
- getFirst() - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
-
- getFirstLeafNode(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- getFirstLocation() - Method in class org.apache.activemq.store.kahadb.disk.journal.ReadOnlyJournal
-
- getFixedSize() - Method in class org.apache.activemq.store.kahadb.disk.util.BytesMarshaller
-
- getFixedSize() - Method in class org.apache.activemq.store.kahadb.disk.util.IntegerMarshaller
-
- getFixedSize() - Method in class org.apache.activemq.store.kahadb.disk.util.LocationMarshaller
-
- getFixedSize() - Method in class org.apache.activemq.store.kahadb.disk.util.LongMarshaller
-
- getFixedSize() - Method in interface org.apache.activemq.store.kahadb.disk.util.Marshaller
-
- getFixedSize() - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet.Marshaller
-
- getFixedSize() - Method in class org.apache.activemq.store.kahadb.disk.util.StringMarshaller
-
- getFixedSize() - Method in class org.apache.activemq.store.kahadb.disk.util.VariableMarshaller
-
- getFixedSize() - Method in class org.apache.activemq.store.kahadb.MessageDatabase.LastAckMarshaller
-
- getForceRecoverIndex() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getForceRecoverIndex() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- getFreeFile() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getFreePageCount() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getFreePages() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- getHead(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- getHead() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
-
- getHeadNode() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- getHeadPageId() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- getIndexCacheSize() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getIndexCacheSize() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Get the indexCacheSize
- getIndexCacheSize() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getIndexCacheSize() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getIndexDirectory() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getIndexDirectory() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getIndexDirectory() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getIndexEnablePageCaching() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getIndexLFUEvictionFactor() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getIndexLFUEvictionFactor() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getIndexLFUEvictionFactor() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getIndexLock() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getIndexPageSize() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getIndexWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getIndexWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Get the indexWriteBatchSize
- getIndexWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getIndexWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getIndexWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- getInflightWrites() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getInProgressTxLocationRange() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getJobId() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl
-
- getJobScheduler(String) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
-
- getJobSchedulers() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData
-
Gets the index of JobScheduler instances that have been created and stored
in the JobSchedulerStore instance.
- getJournal() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getJournal() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getJournal() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getJournalCleanupInterval() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- getJournalCleanupInterval() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- getJournalDiskSyncInterval() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getJournalDiskSyncInterval() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getJournalDiskSyncStrategy() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getJournalDiskSyncStrategy() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getJournalDiskSyncStrategy() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getJournalDiskSyncStrategyEnum() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getJournalDiskSyncStrategyEnum() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getJournalFilesBeingReplicated() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getJournalFilesBeingReplicated() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Get the journalMaxFileLength
- getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getJournalMaxWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getJournalMaxWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Get the journalMaxWriteBatchSize
- getJournalMaxWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getJournalMaxWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- getJournalMaxWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getJournalRC() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData
-
Gets the index used to track the number of reference to a Journal log file.
- getJournalWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- getKeyMarshaller() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- getKeyMarshaller() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- getKeyMarshaller() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- getLast(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- getLast(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- getLast(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- getLast(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- getLast() - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence
-
- getLast() - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
-
- getLastAck(Transaction, MessageDatabase.StoredDestination, String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getLastAppendLocation() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getLastMessageBrokerSequenceId() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getLastMessageBrokerSequenceId() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- getLastMessageBrokerSequenceId() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- getLastMessageBrokerSequenceId() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
-
- getLastProducerSequenceId(ProducerId) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getLastProducerSequenceId(ProducerId) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- getLastProducerSequenceId(ProducerId) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- getLastProducerSequenceId(ProducerId) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
-
- getLastTxId() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- getLastUpdateLocation() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBMetaData
-
- getLastUpdateLocation() - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData
-
Returns the Journal Location value that indicates that last recorded update
that was successfully performed for this KahaDB store implementation.
- getLastUpdatePosition() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getLatch() - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- getLegacyStoreArchiveDirectory() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
-
Gets the directory where the legacy Scheduler Store files will be archived if the
broker is started and an existing Job Scheduler Store from an old version is detected.
- getLength() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
-
- getLength() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- getLFUEvictionFactor() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getList() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- getLoadFactor() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- getMaxAsyncJobs() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getMaxAsyncJobs() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- getMaxFailoverProducersToTrack() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getMaxFailoverProducersToTrack() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getMaxFileLength() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getMaxLeafDepth(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- getMaxLeafDepth(Transaction, int) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- getMessage(MessageId) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- getMessage(MessageId) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- getMessageCount() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- getMessageCount() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- getMessages() - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx
-
- getMetadata() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getMetaDataTxId() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- getMinLeafDepth(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- getMinLeafDepth(Transaction, int) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- getMissing(long, long) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
-
- getName() - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
-
- getName() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- getNext() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- getNext() - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- getNext() - Method in class org.apache.activemq.store.kahadb.disk.page.Page
-
- getNext() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- getNextCircular() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- getNextExecutionTime() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl
-
- getNextLocation(Location) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getNextLocation(Location, Location) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getNextScheduleJobs() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- getNextScheduleTime() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- getNumber() - Method in enum org.apache.activemq.store.kahadb.data.KahaDestination.DestinationType
-
- getNumber() - Method in enum org.apache.activemq.store.kahadb.data.KahaEntryType
-
- getOffset() - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- getPage() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBMetaData
-
- getPage() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- getPage() - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- getPage() - Method in exception org.apache.activemq.store.kahadb.disk.page.Transaction.InvalidPageIOException
-
- getPage() - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData
-
Gets the Page in the store PageFile where the KahaDBMetaData instance is stored.
- getPageCacheSize() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getPageContentSize() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getPageCount() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getPageFile() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getPageFile() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- getPageFile() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- getPageFile() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- getPageFile() - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
-
- getPageFile() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getPageFile() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- getPageFileName() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- getPageFileName() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
-
- getPageId() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- getPageId() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- getPageId() - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- getPageId() - Method in class org.apache.activemq.store.kahadb.disk.page.Page
-
- getPageSize() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getPageSize() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- getParent() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- getPayload() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl
-
- getPayload(Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
-
Retrieve the scheduled Job's byte blob from the journal.
- getPeriod() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl
-
- getPersistenceAdapter() - Method in class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter
-
- getPList(String) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- getPos() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- getPreallocationScope() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getPreallocationScope() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getPreallocationScope() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getPreallocationStrategy() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getPreallocationStrategy() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getPreallocationStrategy() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getPrefixer() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- getPreparedLocationId() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore.Tx
-
- getPrevious() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- getPreviousCircular() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- getRaf() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- getRawData() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- getReadDuration() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- getReads() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- getReceived() - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
-
- getRecoveryFile() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getRecoveryFileMaxPageCount() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getRecoveryFileMinPageCount() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getRemoveLocationTracker() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData
-
Gets the index that contains the location tracking information for Jobs
that have been removed from the index but whose add operation has yet
to be removed from the Journal.
- getRepeat() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl
-
- getReplicationTarget() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getSampleInterval() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark
-
- getSequenceSet(Transaction, MessageDatabase.StoredDestination, String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getSimplePrefix(Key, Key) - Method in interface org.apache.activemq.store.kahadb.disk.index.BTreeIndex.Prefixer
-
This methods should return shortest prefix of value2 where the following still holds:
value1 <= prefix <= value2.
When this method is called, the following is guaranteed:
value1 < value2
- getSimplePrefix(String, String) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex.StringPrefixer
-
Example:
If value1 is "Hello World"
and value 2 is "Help Me"
then the result will be: "Help"
- getSize() - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- getSize() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark
-
- getSize() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- getStart() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl
-
- getStartTime() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl
-
- getState() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBMetaData
-
- getState() - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData
-
Gets the state flag of this meta data instance.
- getStore() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- getStoredDestination(KahaDestination, Transaction) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getStoredDestination(KahaDestination, Transaction) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- getStoredMessageCount(Transaction, MessageDatabase.StoredDestination, String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getStores() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore.Tx
-
- getStoresMap() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore.Tx
-
- getSyncWriteDuration() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- getSyncWrites() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- getTail(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- getTail() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
-
- getTailNode() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- getTailPageId() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- getTempFile() - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
-
- getToken() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData
-
- getToken() - Method in exception org.apache.activemq.store.kahadb.scheduler.UnknownStoreVersionException
-
- getTransactionIdTransformer() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- getTransactions() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- getTx(Object) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore
-
- getTx(TransactionId) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- getTxId() - Method in class org.apache.activemq.store.kahadb.disk.page.Page
-
- getType() - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- getType() - Method in class org.apache.activemq.store.kahadb.disk.page.Page
-
- getType() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestinationMarshaller
-
- getTypeCode() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
-
- getUsage() - Method in class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter
-
- getUsageManager() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- getValueMarshaller() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- getValueMarshaller() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- getValueMarshaller() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- getVersion() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData
-
- getWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- getWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- getWriteDuration() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- getWrites() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- lastAppendLocation - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- lastAsyncJournalUpdate - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
-
- lastUpdate - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
-
- LegacyStoreReplayer - Class in org.apache.activemq.store.kahadb.scheduler.legacy
-
Used to upgrade a Legacy Job Scheduler store to the latest version this class
loads a found legacy scheduler store and generates new add commands for all
jobs currently in the store.
- LegacyStoreReplayer(File) - Constructor for class org.apache.activemq.store.kahadb.scheduler.legacy.LegacyStoreReplayer
-
Creates a new Legacy Store Replayer with the given target store
- length - Variable in class org.apache.activemq.store.kahadb.disk.journal.DataFile
-
- length() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- length() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- LFUCache<Key,Value> - Class in org.apache.activemq.util
-
LFU cache implementation based on http://dhruvbird.com/lfu.pdf, with some notable differences:
Frequency list is stored as an array with no next/prev pointers between nodes: looping over the array should be faster and more CPU-cache friendly than
using an ad-hoc linked-pointers structure.
- LFUCache(int, float) - Constructor for class org.apache.activemq.util.LFUCache
-
- linkAfter(T) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- linkAfter(LinkedNodeList<T>) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- linkBefore(T) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- linkBefore(LinkedNodeList<T>) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- LinkedNode<T extends LinkedNode<T>> - Class in org.apache.activemq.store.kahadb.disk.util
-
Provides a base class for you to extend when you want object to maintain a
doubly linked list to other objects without using a collection class.
- LinkedNode() - Constructor for class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- LinkedNodeList<T extends LinkedNode<T>> - Class in org.apache.activemq.store.kahadb.disk.util
-
Provides a list of LinkedNode objects.
- LinkedNodeList() - Constructor for class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
-
- linkToHead(LinkedNodeList<T>) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- linkToTail(LinkedNodeList<T>) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- list - Variable in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
- ListIndex<Key,Value> - Class in org.apache.activemq.store.kahadb.disk.index
-
- ListIndex() - Constructor for class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- ListIndex(PageFile, long) - Constructor for class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- ListIndex(PageFile, Page) - Constructor for class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- ListNode<Key,Value> - Class in org.apache.activemq.store.kahadb.disk.index
-
The ListNode class represents a node in the List object graph.
- ListNode() - Constructor for class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- ListNode.NodeMarshaller<Key,Value> - Class in org.apache.activemq.store.kahadb.disk.index
-
The Marshaller is used to store and load the data in the ListNode into a Page.
- ListNode.NodeMarshaller(Marshaller<Key>, Marshaller<Value>) - Constructor for class org.apache.activemq.store.kahadb.disk.index.ListNode.NodeMarshaller
-
- listNodeIterator(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- load() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
Loads the store from disk.
- load(Location) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
Loads a previously stored JournalMessage
- load(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- load(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- load(Transaction) - Method in interface org.apache.activemq.store.kahadb.disk.index.Index
-
load indexes
- load(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- load() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
Loads the page file so that it can be accessed for read/write purposes.
- load(long, Marshaller<T>) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
-
Loads a page from disk.
- load(Page<T>, Marshaller<T>) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
-
Loads a page from disk.
- load(Transaction) - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData
-
Instructs this object to load its internal data structures from the KahaDB PageFile
and prepare itself for use.
- load() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- load(Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
Loads a previously stored JournalMessage
- load(Location) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- load(Transaction) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData
-
- load() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
-
- load() - Method in class org.apache.activemq.store.kahadb.scheduler.legacy.LegacyStoreReplayer
-
Loads the legacy store and prepares it for replay into a newer Store instance.
- load() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
-
- load() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- loaded - Variable in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- loadScheduler(Transaction, Map<String, JobSchedulerImpl>) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData
-
Loads all the stored JobScheduler instances into the provided map.
- location - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal.WriteCommand
-
- Location - Class in org.apache.activemq.store.kahadb.disk.journal
-
Used as a location in the data store.
- Location() - Constructor for class org.apache.activemq.store.kahadb.disk.journal.Location
-
- Location(Location) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.Location
-
- Location(int, int) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.Location
-
- LocationMarshaller - Class in org.apache.activemq.store.kahadb.disk.util
-
- LocationMarshaller() - Constructor for class org.apache.activemq.store.kahadb.disk.util.LocationMarshaller
-
- lockAsyncJobQueue() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- LOG_SLOW_ACCESS_TIME - Static variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- LOG_SLOW_ACCESS_TIME - Static variable in class org.apache.activemq.store.kahadb.MessageDatabase
-
- LongMarshaller - Class in org.apache.activemq.store.kahadb.disk.util
-
Implementation of a Marshaller for a Long
- LongMarshaller() - Constructor for class org.apache.activemq.store.kahadb.disk.util.LongMarshaller
-
- range() - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence
-
- rangeSize() - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
-
Computes the size of this Sequence by summing the values of all
the contained sequences.
- read(Location) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- read() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
Reads the next byte of data from this input stream.
- read(byte[], int, int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
Reads up to len
bytes of data into an array of bytes from
this input stream.
- read(DataInput) - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData
-
Reads the serialized for of this object from the KadaDB PageFile and prepares it
for use.
- read(DataInput) - Method in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
-
- read(DataInput) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl.MetaData
-
- read(DataInput) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData
-
- read(byte[], int, int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- read(byte[]) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readBoolean() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readBoolean() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readByte() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readByte() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readChar() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readChar() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readDouble() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readDouble() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readDuration - Variable in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- readExternal(DataInput) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- readFloat() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readFloat() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readFully(byte[]) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readFully(byte[], int, int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readFully(byte[]) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readFully(byte[], int, int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readInt() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readInt() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readLine() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readLine() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readLockIndex() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
-
- readLong() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readLong() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- ReadOnlyDataFile - Class in org.apache.activemq.store.kahadb.disk.journal
-
Allows you to open a data file in read only mode.
- ReadOnlyJournal - Class in org.apache.activemq.store.kahadb.disk.journal
-
An AsyncDataManager that works in read only mode against multiple data directories.
- ReadOnlyJournal(ArrayList<File>) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.ReadOnlyJournal
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode.Marshaller
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode.NodeMarshaller
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.disk.util.BytesMarshaller
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.disk.util.IntegerMarshaller
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.disk.util.LocationMarshaller
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.disk.util.LongMarshaller
-
- readPayload(DataInput) - Method in interface org.apache.activemq.store.kahadb.disk.util.Marshaller
-
Read the payload of the object from the DataInput stream.
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.disk.util.ObjectMarshaller
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet.Marshaller
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.disk.util.StringMarshaller
-
Read the entry from the RawContainer
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.MessageDatabase.LastAckMarshaller
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.MessageDatabase.MessageKeysMarshaller
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.MessageDatabase.StoredDestinationMarshaller
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase.MessageKeysMarshaller
-
- readPayload(DataInput) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestinationMarshaller
-
- reads - Variable in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- readShort() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readShort() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readUnlockIndex() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
-
- readUnsignedByte() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readUnsignedByte() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readUnsignedShort() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readUnsignedShort() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- readUTF() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- readUTF() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- RECORD_HEAD_SPACE - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- recover(MessageRecoveryListener) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- recover(TransactionRecoveryListener) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore
-
- recover(TransactionRecoveryListener) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- recover(MessageRecoveryListener) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- RecoverableRandomAccessFile - Class in org.apache.activemq.util
-
- RecoverableRandomAccessFile(File, String, boolean) - Constructor for class org.apache.activemq.util.RecoverableRandomAccessFile
-
- RecoverableRandomAccessFile(File, String) - Constructor for class org.apache.activemq.util.RecoverableRandomAccessFile
-
- RecoverableRandomAccessFile(String, String) - Constructor for class org.apache.activemq.util.RecoverableRandomAccessFile
-
- recoverIndex(Transaction) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- recoverNextMessages(int, MessageRecoveryListener) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- recoverNextMessages(int, MessageRecoveryListener) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- recoverRolledBackAcks(String, MessageDatabase.StoredDestination, Transaction, int, MessageRecoveryListener) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- recoveryCheck(DataFile) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- referenceRemovedLocation(Transaction, Location, JobLocation) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
-
Updates the Job removal tracking index with the location of a remove command and the
original JobLocation entry.
- releaseLocalAsyncLock() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- releaseLocks() - Method in interface org.apache.activemq.store.kahadb.KahaDBStore.StoreTask
-
- remove(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- remove(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- remove(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- remove(Transaction, Key) - Method in interface org.apache.activemq.store.kahadb.disk.index.Index
-
remove the index key
- remove(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- remove(SequenceSet) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
-
- remove(Sequence) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
-
- remove(long) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
-
Removes the given value from the Sequence set, splitting a
contained sequence if necessary.
- remove(Object) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
-
- remove(String) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
-
- remove(long) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
-
- remove(long) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- remove(String) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- remove(Object) - Method in class org.apache.activemq.util.LFUCache
-
- removeAll(Transaction) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
Removes all jobs from the schedulers index.
- removeAllJobs() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- removeAllJobs(long, long) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- removeAllMessages(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- removeAllMessages(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- removeAsyncMessage(ConnectionContext, MessageAck) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- removeDataFiles(Set<Integer>) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- removeFirst() - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
-
Removes and returns the first element from this list.
- removeFirstSequence(long) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
-
Removes and returns the first sequence that is count range large.
- removeInRange(Transaction, long, long, Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
Removes all scheduled jobs within the target range.
- removeJobAtTime(Transaction, String, long) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
Removes a Job from the index using it's Id value and the time it is currently set to
be executed.
- removeJobScheduler(String) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
-
- removeLastSequence() - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
-
Removes and returns the last sequence from this list.
- removeListener(JobListener) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- removeMessage(ConnectionContext, MessageAck) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- removeMessage(ConnectionContext, MessageAck) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- removePList(String) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- removeQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- removeQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
Cleanup method to remove any state associated with the given destination.
- removeQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- removeQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
-
Cleanup method to remove any state associated with the given destination.
- removeQueueTask(KahaDBStore.KahaDBMessageStore, MessageId) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- removeTmpFile(File) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- removeTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- removeTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
Cleanup method to remove any state associated with the given destination
This method does not stop the message store (it might not be cached).
- removeTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- removeTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
-
Cleanup method to remove any state associated with the given destination
This method does not stop the message store (it might not be cached).
- removeTopicTask(KahaDBStore.KahaDBTopicMessageStore, MessageId) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- removeTx(TransactionId) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- reparent(LinkedNodeList<T>) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
-
- replicate(Location, ByteSequence, boolean) - Method in interface org.apache.activemq.store.kahadb.disk.journal.ReplicationTarget
-
- ReplicationTarget - Interface in org.apache.activemq.store.kahadb.disk.journal
-
- reserveDataFile() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- reset() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
-
reset the output stream
- resetBatching() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- resetBatching() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- restart(byte[]) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
reset the StoreByteArrayInputStream
to use an new byte
array
- restart() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- restart(ByteSequence) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
reset the StoreByteArrayInputStream
to use an new
ByteSequence
- restart(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
re-start the input stream - reusing the current buffer
- restart(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
-
start using a fresh byte array
- restart() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
-
start using a fresh byte array
- rollback() - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
-
Rolls back the transaction.
- rollback(TransactionId) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore
-
- rollback(TransactionId) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- rollbackTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- rollbackTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- rollbackTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- rollbackTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
-
- rolledBackAcksMap - Variable in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- rotate() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
-
Move the head to the tail and returns the new head node.
- rotateTo(T) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
-
Move the head to the tail and returns the new head node.
- run() - Method in class org.apache.activemq.store.kahadb.disk.util.SchedulerTimerTask
-
- run() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- run() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- schedule(String, ByteSequence, long) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- schedule(String, ByteSequence, String) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- schedule(String, ByteSequence, String, long, long, int) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- Scheduler - Class in org.apache.activemq.store.kahadb.disk.util
-
- scheduler - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
-
- SchedulerTimerTask - Class in org.apache.activemq.store.kahadb.disk.util
-
A TimeTask for a Runnable object
- SchedulerTimerTask(Runnable) - Constructor for class org.apache.activemq.store.kahadb.disk.util.SchedulerTimerTask
-
- seek(long) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- Sequence - Class in org.apache.activemq.store.kahadb.disk.util
-
Represents a range of numbers.
- Sequence(long) - Constructor for class org.apache.activemq.store.kahadb.disk.util.Sequence
-
- Sequence(long, long) - Constructor for class org.apache.activemq.store.kahadb.disk.util.Sequence
-
- Sequence.Closure<T extends Throwable> - Interface in org.apache.activemq.store.kahadb.disk.util
-
- SequenceSet - Class in org.apache.activemq.store.kahadb.disk.util
-
Keeps track of a added long values.
- SequenceSet() - Constructor for class org.apache.activemq.store.kahadb.disk.util.SequenceSet
-
- SequenceSet.Marshaller - Class in org.apache.activemq.store.kahadb.disk.util
-
- SequenceSet.Marshaller() - Constructor for class org.apache.activemq.store.kahadb.disk.util.SequenceSet.Marshaller
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
-
- serializedSizeUnframed() - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
-
- set(T) - Method in class org.apache.activemq.store.kahadb.disk.page.Page
-
- setArchiveCorruptedIndex(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setArchiveCorruptedIndex(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setArchiveCorruptedIndex(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setArchiveDataLogs(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setArchiveDataLogs(boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setArchiveDataLogs(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setArchiveDataLogs(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setBatch(DataFileAppender.WriteBatch) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- setBatch(MessageId) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- setBatch(MessageId) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- setBinCapacity(int) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- setBrokerName(String) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setBrokerName(String) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- setBrokerName(String) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- setBrokerName(String) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
-
- setBrokerService(BrokerService) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setBrokerService(BrokerService) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setBrokerService(BrokerService) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- setBrokerService(BrokerService) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setBrokerService(BrokerService) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
-
- setBs(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark
-
- setCheckForCorruptionOnStartup(boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setCheckForCorruptJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setCheckForCorruptJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setCheckForCorruptJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setCheckpointInterval(long) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setCheckpointInterval(long) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Set the checkpointInterval
- setCheckpointInterval(long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setChecksum(boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setChecksum(int) - Method in class org.apache.activemq.store.kahadb.disk.page.Page
-
- setChecksumJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setChecksumJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setChecksumJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setCleanShutdown(boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- setCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Set the cleanupInterval
- setCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setCleanupOnStop(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setCleanupOnStop(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setCleanupOnStop(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setCompactAcksAfterNoGC(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Sets the number of GC cycles where no journal logs were removed before an attempt to
move forward all the acks in the last log that contains them and is otherwise unreferenced.
- setCompactAcksAfterNoGC(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
Sets the number of GC cycles where no journal logs were removed before an attempt to
move forward all the acks in the last log that contains them and is otherwise unreferenced.
- setCompactAcksIgnoresStoreGrowth(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Configure if Ack compaction will occur regardless of continued growth of the
journal logs meaning that the store has not run out of space yet.
- setCompactAcksIgnoresStoreGrowth(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
Configure if Ack compaction will occur regardless of continued growth of the
journal logs meaning that the store has not run out of space yet.
- setConcurrentStoreAndDispatchQueues(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setConcurrentStoreAndDispatchQueues(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- setConcurrentStoreAndDispatchTopics(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setConcurrentStoreAndDispatchTopics(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- setContainingList(ListIndex<Key, Value>) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- setDatabaseLockedWaitDelay(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setDataFileId(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- setDataFileRemovedListener(Journal.DataFileRemovedListener) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setDeleteAllJobs(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setDeleteAllMessages(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setDirectory(File) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setDirectory(File) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setDirectory(File) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setDirectory(File) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setDirectory(File) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- setDirectory(File) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setDirectory(File) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- setDirectoryArchive(File) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setDirectoryArchive(File) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setDirectoryArchive(File) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setDirectoryArchive(File) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setEmpty() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- setEnableAckCompaction(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Configure if the Ack compaction task should be enabled to run
- setEnableAckCompaction(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
Configure if the Ack compaction task should be enabled to run
- setEnableAsyncDiskSync(boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setEnableDiskSyncs(boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
Allows you enable syncing writes to disk.
- setEnableIndexDiskSyncs(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setEnableIndexDiskSyncs(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setEnableIndexDiskSyncs(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setEnableIndexPageCaching(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setEnableIndexPageCaching(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setEnableIndexPageCaching(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setEnableIndexRecoveryFile(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setEnableIndexRecoveryFile(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setEnableIndexRecoveryFile(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setEnableIndexWriteAsync(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setEnableIndexWriteAsync(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Set the enableIndexWriteAsync
- setEnableIndexWriteAsync(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setEnableIndexWriteAsync(boolean) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setEnableIndexWriteAsync(boolean) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- setEnableJournalDiskSyncs(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setEnableJournalDiskSyncs(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setEnableJournalDiskSyncs(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setEnablePageCaching(boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- setEnableRecoveryFile(boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
Sets if the recovery buffer uses to double buffer page writes.
- setEnableWriteThread(boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- setFailIfDatabaseIsLocked(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setFailIfDatabaseIsLocked(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setFailIfDatabaseIsLocked(boolean) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setFailoverProducersAuditDepth(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
set the audit window depth for duplicate suppression (should exceed the max transaction
batch)
- setFailoverProducersAuditDepth(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setFilePrefix(String) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setFileSuffix(String) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setFileType(String) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- setFileTypeVersion(String) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- setFilteredPersistenceAdapters(List) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
Sets the FilteredKahaDBPersistenceAdapter entries
- setFirst(long) - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence
-
- setForceRecoverIndex(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setForceRecoverIndex(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setForceRecoverIndex(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- setFreePages(long) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- setHeadPageId(long) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- setIgnoreMissingJournalfiles(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setIgnoreMissingJournalfiles(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Set the ignoreMissingJournalfiles
- setIgnoreMissingJournalfiles(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setIndexCacheSize(int) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setIndexCacheSize(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Set the indexCacheSize
When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used
- setIndexCacheSize(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setIndexCacheSize(int) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setIndexDirectory(File) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Sets the directory where KahaDB index files should be written.
- setIndexDirectory(File) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setIndexDirectory(File) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setIndexEnablePageCaching(boolean) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setIndexLFUEvictionFactor(float) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setIndexLFUEvictionFactor(float) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setIndexLFUEvictionFactor(float) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setIndexPageSize(int) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setIndexWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setIndexWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Set the indexWriteBatchSize
When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used
- setIndexWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setIndexWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setIndexWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- setJournalCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- setJournalCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- setJournalDiskSyncInterval(long) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setJournalDiskSyncInterval(long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setJournalDiskSyncStrategy(Journal.JournalDiskSyncStrategy) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setJournalDiskSyncStrategy(String) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setJournalDiskSyncStrategy(String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can
be used
- setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
Set the max file length of the transaction journal
When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can
be used
- setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setJournalMaxWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setJournalMaxWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Set the journalMaxWriteBatchSize
* When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used
- setJournalMaxWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setJournalMaxWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- setJournalMaxWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setJournalWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
Set the max write batch size of the transaction journal
When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can
be used
- setKeyMarshaller(Marshaller<Key>) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- setKeyMarshaller(Marshaller<Key>) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
Set the marshaller for key objects
- setKeyMarshaller(Marshaller<Key>) - Method in interface org.apache.activemq.store.kahadb.disk.index.Index
-
Set the marshaller for key objects
- setKeyMarshaller(Marshaller<Key>) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- setLast(long) - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence
-
- setLastAppendLocation(Location) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setLastTxId(long) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- setLastUpdateLocation(Location) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBMetaData
-
- setLastUpdateLocation(Location) - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData
-
Updates the value of the last successful update.
- setLazyInit(boolean) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- setLegacyStoreArchiveDirectory(File) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
-
Sets the directory where the legacy scheduler store files are archived before an
update attempt is made.
- setLength(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
-
- setLength(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- setLength(long) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- setLFUEvictionFactor(float) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- setLoadFactor(int) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- setMaxAsyncJobs(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setMaxAsyncJobs(int) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- setMaxFailoverProducersToTrack(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
Set the max number of producers (LRU cache) to track for duplicate sends
- setMaxFailoverProducersToTrack(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setMaximumBinCapacity() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- setMaximumBinCapacity(int) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- setMemoryUsage(MemoryUsage) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- setMemoryUsage(MemoryUsage) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- setMetaDataTxId(long) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- setName(String) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
-
- setName(String) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- setNext(long) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- setNext(long) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- setOffset(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- setOptions(Object, String[]) - Static method in class org.apache.activemq.store.kahadb.disk.util.CommandLineSupport
-
Sets the properties of an object given the command line args.
- setPage(Page<T>) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBMetaData
-
- setPage(Page<BTreeNode<Key, Value>>) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- setPage(Page<ListNode<Key, Value>>) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- setPage(Page<T>) - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData
-
Sets the Page instance used to load and store the KahaDBMetaData instance.
- setPageCacheSize(int) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- setPageFile(PageFile) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- setPageFile(PageFile) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- setPageId(long) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- setPageSize(int) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
-
- setPageSize(int) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
Configures the page size used by the page file.
- setParent(BTreeNode<Key, Value>) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- setPerDestination(boolean) - Method in class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter
-
- setPersistenceAdapter(PersistenceAdapter) - Method in class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter
-
- setPos(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- setPreallocate(boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender
-
- setPreallocationScope(Journal.PreallocationScope) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setPreallocationScope(String) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setPreallocationScope(String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setPreallocationStrategy(Journal.PreallocationStrategy) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setPreallocationStrategy(String) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setPreallocationStrategy(String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setPrefixer(BTreeIndex.Prefixer<Key>) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- setPurgeStoreOnStartup(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setReadDuration(long) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- setReads(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- setRecoveryFileMaxPageCount(int) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- setRecoveryFileMinPageCount(int) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- setReplicationTarget(ReplicationTarget) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setSampleInterval(long) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark
-
- setSize(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- setSize(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- setSize(long) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark
-
- setSizeAccumulator(AtomicLong) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setState(int) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBMetaData
-
- setState(int) - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData
-
Sets the current value of the state flag.
- setSyncWriteDuration(long) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- setSyncWrites(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- setTailPageId(long) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- setTransactionIdTransformer(TransactionIdTransformer) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setTransactionIdTransformer(TransactionIdTransformer) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- setTransactionStore(MultiKahaDBTransactionStore) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- setType(byte) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
-
- setTypeCode(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
-
- setUsage(StoreUsage) - Method in class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter
-
- setUsageManager(SystemUsage) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setUsageManager(SystemUsage) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- setUsageManager(SystemUsage) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- setUsageManager(SystemUsage) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
-
- setUseIndexLFRUEviction(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- setUseIndexLFRUEviction(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- setUseIndexLFRUEviction(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- setUseLFRUEviction(boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- setValueMarshaller(Marshaller<Value>) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- setValueMarshaller(Marshaller<Value>) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
Set the marshaller for value objects
- setValueMarshaller(Marshaller<Value>) - Method in interface org.apache.activemq.store.kahadb.disk.index.Index
-
Set the marshaller for key objects
- setValueMarshaller(Marshaller<Value>) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- setVerbose(boolean) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark
-
- setWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- setWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
-
- setWriteDuration(long) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- setWrites(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- shutdown() - Static method in class org.apache.activemq.store.kahadb.disk.util.Scheduler
-
- size() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
- size(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- size() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- size(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- size() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool
-
- size - Variable in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch
-
- size() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- size() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
-
- size - Variable in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- size() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
-
- size() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
-
- size() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
-
- size() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
-
- size() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- size() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
-
- size() - Method in class org.apache.activemq.util.LFUCache
-
- skip(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
-
- skipBytes(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
-
- skipBytes(int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- splitAfter() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
Splits the list into 2 lists.
- splitBefore() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
-
Splits the list into 2 lists.
- STANDARD_LOG_FILE - Static variable in class org.apache.activemq.store.kahadb.disk.journal.DataFile
-
- start() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- start() - Method in class org.apache.activemq.store.kahadb.disk.journal.ReadOnlyJournal
-
- start() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- start() - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore
-
- start() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- start() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- start() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- startCheckpoint() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
Starts the checkpoint Thread instance if not already running and not disabled
by configuration.
- startDispatching() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- started - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
-
- started - Variable in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- startReplay(JobSchedulerStoreImpl) - Method in class org.apache.activemq.store.kahadb.scheduler.legacy.LegacyStoreReplayer
-
Performs a replay of scheduled jobs into the target JobSchedulerStore.
- state - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
-
- stop() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
-
- stop() - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore
-
- stop() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
-
- stop() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
-
- stop() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
-
- stopDispatching() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
-
- store(JournalCommand<?>) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
Store a command in the Journal and process to update the Store index.
- store(JournalCommand<?>, boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
Store a command in the Journal and process to update the Store index.
- store(JournalCommand<?>, Runnable) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
Store a command in the Journal and process to update the Store index.
- store(JournalCommand<?>, boolean, Runnable, Runnable) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
Store a command in the Journal and process to update the Store index.
- store(JournalCommand<?>, boolean, Runnable, Runnable, Runnable) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
-
All updated are are funneled through this method.
- store(Transaction, HashBin<Key, Value>) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
-
- store(Page<T>, Marshaller<T>, boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
-
- store(JournalCommand<?>) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- store(JournalCommand<?>, Runnable) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- store(JournalCommand<?>, boolean, MessageDatabase.IndexAware, Runnable) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
- store(JournalCommand<?>, boolean, MessageDatabase.IndexAware, Runnable, Runnable) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
-
All updated are are funneled through this method.
- storeCache - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
-
This is a map to cache MessageStores for a specific
KahaDestination key
- storedDestinations - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
-
- storeItem(ByteSequence, byte, boolean) - Method in interface org.apache.activemq.store.kahadb.disk.journal.FileAppender
-
- storeItem(ByteSequence, byte, Runnable) - Method in interface org.apache.activemq.store.kahadb.disk.journal.FileAppender
-
- storeItem(ByteSequence, byte, boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender
-
- storeItem(ByteSequence, byte, Runnable) - Method in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender
-
- storeNode(Transaction, ListNode<Key, Value>, boolean) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
-
- storeUpdate(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
-
- StringMarshaller - Class in org.apache.activemq.store.kahadb.disk.util
-
Implementation of a Marshaller for Strings
- StringMarshaller() - Constructor for class org.apache.activemq.store.kahadb.disk.util.StringMarshaller
-
- sync() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
-
- syncWriteDuration - Variable in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- syncWrites - Variable in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
-
- valueOf(String) - Static method in enum org.apache.activemq.store.kahadb.data.KahaDestination.DestinationType
-
Returns the enum constant of this type with the specified name.
- valueOf(int) - Static method in enum org.apache.activemq.store.kahadb.data.KahaDestination.DestinationType
-
- valueOf(String) - Static method in enum org.apache.activemq.store.kahadb.data.KahaEntryType
-
Returns the enum constant of this type with the specified name.
- valueOf(int) - Static method in enum org.apache.activemq.store.kahadb.data.KahaEntryType
-
- valueOf(String) - Static method in enum org.apache.activemq.store.kahadb.disk.journal.Journal.JournalDiskSyncStrategy
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.activemq.store.kahadb.disk.journal.Journal.PreallocationScope
-
Returns the enum constant of this type with the specified name.
- valueOf(String) - Static method in enum org.apache.activemq.store.kahadb.disk.journal.Journal.PreallocationStrategy
-
Returns the enum constant of this type with the specified name.
- values() - Static method in enum org.apache.activemq.store.kahadb.data.KahaDestination.DestinationType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.activemq.store.kahadb.data.KahaEntryType
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.activemq.store.kahadb.disk.journal.Journal.JournalDiskSyncStrategy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.activemq.store.kahadb.disk.journal.Journal.PreallocationScope
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Static method in enum org.apache.activemq.store.kahadb.disk.journal.Journal.PreallocationStrategy
-
Returns an array containing the constants of this enum type, in
the order they are declared.
- values() - Method in class org.apache.activemq.util.LFUCache
-
- VariableMarshaller<T> - Class in org.apache.activemq.store.kahadb.disk.util
-
Convenience base class for Marshaller implementations which do not deepCopy and
which use variable size encodings.
- VariableMarshaller() - Constructor for class org.apache.activemq.store.kahadb.disk.util.VariableMarshaller
-
- version - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
-
- visit(Visitor) - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
-
- visit(Transaction, BTreeVisitor<Key, Value>) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
-
- visit(Transaction, BTreeVisitor<Key, Value>) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
-
- visit(List<Key>, List<Value>) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.PredicateVisitor
-
- visit(List<Key>, List<Value>) - Method in interface org.apache.activemq.store.kahadb.disk.index.BTreeVisitor
-
The keys and values of a BTree leaf node.
- visit(Visitor) - Method in interface org.apache.activemq.store.kahadb.JournalCommand
-
- visit(KahaTraceCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaRollbackCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaRemoveMessageCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaPrepareCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaCommitCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaAddMessageCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaRemoveDestinationCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaSubscriptionCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaProducerAuditCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaAckMessageFileMapCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaAddScheduledJobCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaRescheduleJobCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaRemoveScheduledJobCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaRemoveScheduledJobsCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaDestroySchedulerCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaUpdateMessageCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- visit(KahaRewrittenDataFileCommand) - Method in class org.apache.activemq.store.kahadb.Visitor
-
- Visitor - Class in org.apache.activemq.store.kahadb
-
- Visitor() - Constructor for class org.apache.activemq.store.kahadb.Visitor
-