A B C D E F G H I J K L M N O P Q R S T U V W 

A

AbstractKahaDBMetaData<T> - Class in org.apache.activemq.store.kahadb
 
AbstractKahaDBMetaData() - Constructor for class org.apache.activemq.store.kahadb.AbstractKahaDBMetaData
 
AbstractKahaDBStore - Class in org.apache.activemq.store.kahadb
 
AbstractKahaDBStore() - Constructor for class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
accessorPool - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
ackedAndPrepared - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
ackMessageFileMap - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
 
ackMessageFileMapLocation - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
 
acquireLocalAsyncLock() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
 
add(Transaction, Key, Value) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
add(Sequence) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
 
add(long) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
 
add(KahaDBTransactionStore.AddMessageCommand) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx
 
add(KahaDBTransactionStore.RemoveMessageCommand) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx
 
addFirst(Transaction, Key, Value) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
addFirst(Transaction, Key, Value) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
 
addFirst(T) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
 
addFirst(LinkedNodeList<T>) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
 
addFirst(String, ByteSequence) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
 
addLast(T) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
 
addLast(LinkedNodeList<T>) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
 
addLast(String, ByteSequence) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
 
addListener(JobListener) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
 
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
 
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
 
addQueueTask(KahaDBStore.KahaDBMessageStore, KahaDBStore.StoreQueueTask) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
addTopicTask(KahaDBStore.KahaDBTopicMessageStore, KahaDBStore.StoreTopicTask) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
afterExecute(Runnable, Throwable) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.StoreTaskExecutor
 
allocate() - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
Allocates a free page that you can write data to.
allocate(int) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
Allocates a block of free pages that you can write data to.
allowIOResumption() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
allowIOResumption() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
allowIOResumption() - Method in class org.apache.activemq.store.kahadb.KahaDBIOExceptionHandler
 
allowIOResumption() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
append(Journal.WriteCommand) - Method in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch
 
appender - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
appendRandomAccessFile - Variable in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
appendRandomAccessFile() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
aquireLocks() - Method in interface org.apache.activemq.store.kahadb.KahaDBStore.StoreTask
 
archive() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
archiveCorruptedIndex - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
archiveDataLogs - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
archiveDataLogs - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
archiveDataLogs - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
asyncAddQueueMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
 
asyncQueueMaps - Variable in class org.apache.activemq.store.kahadb.KahaDBStore
 
asyncTaskMap - Variable in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
 
asyncTopicMaps - Variable in class org.apache.activemq.store.kahadb.KahaDBStore
 
available() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
 

B

BATCH_CONTROL_RECORD_HEADER - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
BATCH_CONTROL_RECORD_MAGIC - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
BATCH_CONTROL_RECORD_SIZE - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
BATCH_CONTROL_RECORD_TYPE - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
beginTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
beginTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
beginTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
beginTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
 
benchmark(File) - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark
 
brokerService - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
BTreeIndex<Key,Value> - Class in org.apache.activemq.store.kahadb.disk.index
BTreeIndex represents a Variable Magnitude B+Tree in a Page File.
BTreeIndex() - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
BTreeIndex(long) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
BTreeIndex(Page) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
BTreeIndex(PageFile, long) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
BTreeIndex(PageFile, Page) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
BTreeIndex.Prefixer<Key> - Interface in org.apache.activemq.store.kahadb.disk.index
Interface used to determine the simple prefix of two keys.
BTreeIndex.StringPrefixer - Class in org.apache.activemq.store.kahadb.disk.index
StringPrefixer is a Prefixer implementation that works on strings.
BTreeIndex.StringPrefixer() - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeIndex.StringPrefixer
 
BTreeNode<Key,Value> - Class in org.apache.activemq.store.kahadb.disk.index
The BTreeNode class represents a node in the BTree object graph.
BTreeNode(BTreeIndex<Key, Value>) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeNode
 
BTreeNode.Marshaller<Key,Value> - Class in org.apache.activemq.store.kahadb.disk.index
The Marshaller is used to store and load the data in the BTreeNode into a Page.
BTreeNode.Marshaller(BTreeIndex<Key, Value>) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeNode.Marshaller
 
BTreeVisitor<Key,Value> - Interface in org.apache.activemq.store.kahadb.disk.index
Interface used to selectively visit the entries in a BTree.
BTreeVisitor.AndVisitor<Key,Value> - Class in org.apache.activemq.store.kahadb.disk.index
 
BTreeVisitor.AndVisitor(List<BTreeVisitor.Predicate<Key>>) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.AndVisitor
 
BTreeVisitor.BetweenVisitor<Key extends Comparable<Key>,Value> - Class in org.apache.activemq.store.kahadb.disk.index
 
BTreeVisitor.BetweenVisitor(Key, Key) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.BetweenVisitor
 
BTreeVisitor.GTEVisitor<Key extends Comparable<Key>,Value> - Class in org.apache.activemq.store.kahadb.disk.index
 
BTreeVisitor.GTEVisitor(Key) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.GTEVisitor
 
BTreeVisitor.GTVisitor<Key extends Comparable<Key>,Value> - Class in org.apache.activemq.store.kahadb.disk.index
 
BTreeVisitor.GTVisitor(Key) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.GTVisitor
 
BTreeVisitor.LTEVisitor<Key extends Comparable<Key>,Value> - Class in org.apache.activemq.store.kahadb.disk.index
 
BTreeVisitor.LTEVisitor(Key) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.LTEVisitor
 
BTreeVisitor.LTVisitor<Key extends Comparable<Key>,Value> - Class in org.apache.activemq.store.kahadb.disk.index
 
BTreeVisitor.LTVisitor(Key) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.LTVisitor
 
BTreeVisitor.OrVisitor<Key,Value> - Class in org.apache.activemq.store.kahadb.disk.index
 
BTreeVisitor.OrVisitor(List<BTreeVisitor.Predicate<Key>>) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.OrVisitor
 
BTreeVisitor.Predicate<Key> - Interface in org.apache.activemq.store.kahadb.disk.index
 
BTreeVisitor.PredicateVisitor<Key,Value> - Class in org.apache.activemq.store.kahadb.disk.index
 
BTreeVisitor.PredicateVisitor() - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.PredicateVisitor
 
buf - Variable in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
BytesMarshaller - Class in org.apache.activemq.store.kahadb.disk.util
Implementation of a Marshaller for byte arrays
BytesMarshaller() - Constructor for class org.apache.activemq.store.kahadb.disk.util.BytesMarshaller
 

C

CALLER_BUFFER_APPENDER - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
callerBufferAppender - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
canAppend(Journal.WriteCommand) - Method in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch
 
cancel(Runnable) - Static method in class org.apache.activemq.store.kahadb.disk.util.Scheduler
 
cancel() - Method in interface org.apache.activemq.store.kahadb.KahaDBStore.StoreTask
 
cancelledTaskModMetric - Static variable in class org.apache.activemq.store.kahadb.KahaDBStore
 
checkBatchRecord(DataFileAccessor, int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
checkForCorruptionOnStartup - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
checkForCorruptJournalFiles - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
checkpoint(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
checkpoint(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
checkpoint(boolean) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
checkpoint(boolean) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
 
checkpointCleanup(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
Called from the worker thread to start a checkpoint.
checkpointCleanup(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
checkpointInterval - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
checkpointLock - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
checkpointThread - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
checkpointThreadLock - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
checkpointUpdate(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
Perform a checkpoint operation with optional cleanup.
checkpointUpdate(Transaction, boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
Perform the checkpoint update operation.
checkpointUpdate(Transaction, boolean) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
 
checksum - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
checksumJournalFiles - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
claimFileLocations(Set<Integer>) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
 
cleanup() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
cleanupInterval - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
cleanupTask - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
clear() - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
clear(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
clear(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
 
clear(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
clear(Transaction) - Method in interface org.apache.activemq.store.kahadb.disk.index.Index
clear the index
clear(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
clear(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
 
clear() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
 
clear() - Method in class org.apache.activemq.util.LFUCache
 
CLOCK_DAEMON - Static variable in class org.apache.activemq.store.kahadb.disk.util.Scheduler
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
clone() - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
close() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool
 
close() - Method in interface org.apache.activemq.store.kahadb.disk.journal.FileAppender
 
close() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
close() - Method in class org.apache.activemq.store.kahadb.disk.journal.ReadOnlyJournal
 
close() - Method in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender
 
close() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
close() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
close() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
CLOSED_STATE - Static variable in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
CLOSED_STATE - Static variable in interface org.apache.activemq.store.kahadb.KahaDBMetaData
Indicates that this meta data instance has been closed and is no longer active.
CLOSED_STATE - Static variable in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
closeRandomAccessFile(RecoverableRandomAccessFile) - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
closeRandomAccessFile(RandomAccessFile) - Method in class org.apache.activemq.store.kahadb.disk.journal.ReadOnlyDataFile
 
CommandLineSupport - Class in org.apache.activemq.store.kahadb.disk.util
Support utility that can be used to set the properties on any object using command line arguments.
CommandLineSupport() - Constructor for class org.apache.activemq.store.kahadb.disk.util.CommandLineSupport
 
commit() - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
Commits the transaction to the PageFile as a single 'Unit of Work'.
commit(TransactionId, boolean, Runnable, Runnable) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore
 
commit() - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx
 
commit(TransactionId, boolean, Runnable, Runnable) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
 
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
 
compareTo(DataFile) - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
compareTo(Location) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
 
compareTo(Object) - Method in class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter
 
contains(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
 
contains(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
 
contains(long) - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence
 
contains(long) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
Returns true if the value given is contained within one of the sequences held in this set.
contains(int, int) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
 
containsKey(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
containsKey(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
containsKey(Transaction, Key) - Method in interface org.apache.activemq.store.kahadb.disk.index.Index
 
containsKey(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
containsKey(Object) - Method in class org.apache.activemq.util.LFUCache
 
containsValue(Object) - Method in class org.apache.activemq.util.LFUCache
 
copy(Page<T>) - Method in class org.apache.activemq.store.kahadb.disk.page.Page
 
corruptedBlocks - Variable in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
corruptRecoveryLocation(Location) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
createDefaultLocker() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
createDefaultLocker() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
createDefaultLocker() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
createJobSchedulerStore() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
createJobSchedulerStore() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
createJobSchedulerStore() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
createJobSchedulerStore() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
 
createJournal() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
Create a new Journal instance and configure it using the currently set configuration options.
createMessage() - Method in enum org.apache.activemq.store.kahadb.data.KahaEntryType
 
createNode(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
createPageFile() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
Create the PageFile instance and configure it using the configuration options currently set.
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
 
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
 
createTransactionInfo(TransactionId) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
createTransactionStore() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
createTransactionStore() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
createTransactionStore() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
createTransactionStore() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
 

D

data - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal.WriteCommand
 
DataByteArrayInputStream - Class in org.apache.activemq.store.kahadb.disk.util
Optimized ByteArrayInputStream that can be used more than once
DataByteArrayInputStream(byte[]) - Constructor for class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
Creates a StoreByteArrayInputStream.
DataByteArrayInputStream(ByteSequence) - Constructor for class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
Creates a StoreByteArrayInputStream.
DataByteArrayInputStream() - Constructor for class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream
Creates WireByteArrayInputStream with a minmalist byte array
DataByteArrayOutputStream - Class in org.apache.activemq.store.kahadb.disk.util
Optimized ByteArrayOutputStream
DataByteArrayOutputStream(int) - Constructor for class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
Creates a new byte array output stream, with a buffer capacity of the specified size, in bytes.
DataByteArrayOutputStream() - Constructor for class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
Creates a new byte array output stream.
DataFile - Class in org.apache.activemq.store.kahadb.disk.journal
DataFile
dataFile - Variable in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch
 
DataFileAccessorPool - Class in org.apache.activemq.store.kahadb.disk.journal
Used to pool DataFileAccessors.
DataFileAccessorPool(Journal) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool
 
dataFileId - Variable in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
dataFiles - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
decrementJournalCount(Transaction, Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
Removes one reference for the Journal log file indicated in the given Location value.
decrementLength(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
deepCopy(byte[]) - Method in class org.apache.activemq.store.kahadb.disk.util.BytesMarshaller
 
deepCopy(Integer) - Method in class org.apache.activemq.store.kahadb.disk.util.IntegerMarshaller
 
deepCopy(Location) - Method in class org.apache.activemq.store.kahadb.disk.util.LocationMarshaller
 
deepCopy(Long) - Method in class org.apache.activemq.store.kahadb.disk.util.LongMarshaller
 
deepCopy(T) - Method in interface org.apache.activemq.store.kahadb.disk.util.Marshaller
 
deepCopy(SequenceSet) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet.Marshaller
 
deepCopy(String) - Method in class org.apache.activemq.store.kahadb.disk.util.StringMarshaller
 
deepCopy(T) - Method in class org.apache.activemq.store.kahadb.disk.util.VariableMarshaller
 
deepCopy(MessageDatabase.LastAck) - Method in class org.apache.activemq.store.kahadb.MessageDatabase.LastAckMarshaller
 
DEFAULT_ARCHIVE_DIRECTORY - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
DEFAULT_BIN_CAPACITY - Static variable in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
DEFAULT_CLEANUP_INTERVAL - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
DEFAULT_DIRECTORY - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
DEFAULT_DIRECTORY - Static variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
DEFAULT_FILE_PREFIX - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
DEFAULT_FILE_SUFFIX - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
DEFAULT_LOAD_FACTOR - Static variable in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
DEFAULT_MAX_FILE_LENGTH - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
DEFAULT_MAX_WRITE_BATCH_SIZE - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
DEFAULT_MAXIMUM_BIN_CAPACITY - Static variable in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
DEFAULT_MINIMUM_BIN_CAPACITY - Static variable in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
DEFAULT_PAGE_CACHE_SIZE - Static variable in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
DEFAULT_PAGE_SIZE - Static variable in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
DEFAULT_WRITE_BATCH_SIZE - Static variable in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
delete() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
delete() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
delete() - Method in class org.apache.activemq.store.kahadb.disk.journal.ReadOnlyDataFile
 
delete() - Method in class org.apache.activemq.store.kahadb.disk.journal.ReadOnlyJournal
 
delete() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
Deletes the files used by the PageFile object.
deleteAllJobs - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
deleteAllMessages() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
deleteAllMessages() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
deleteAllMessages - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
deleteAllMessages() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
deleteAllMessages() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
 
deleteAllMessages() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore
 
dest - Variable in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
 
dest - Variable in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
 
destinations - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
 
destinations - Variable in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
destroy() - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
 
directory - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
directory - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
directory - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
directory - Variable in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
directoryArchive - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
directoryArchive - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
directoryArchive - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
DiskBenchmark - Class in org.apache.activemq.store.kahadb.disk.util
This class is used to get a benchmark the raw disk performance.
DiskBenchmark() - Constructor for class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark
 
DiskBenchmark.Report - Class in org.apache.activemq.store.kahadb.disk.util
 
DiskBenchmark.Report() - Constructor for class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
 
disposeUnused() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool
 
doRecover(JournalCommand<?>, Location, Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
Called during index recovery to rebuild the index from the last known good location.
doStart() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
doStart() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
doStart() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
doStart() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
doStart() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
doStart() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
 
doStart() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
 
doStop(ServiceStopper) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
doStop(ServiceStopper) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
doStop(ServiceStopper) - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
doStop(ServiceStopper) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
doStop(ServiceStopper) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
doStop(ServiceStopper) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
 
doStop(ServiceStopper) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
 

E

each(Sequence.Closure<T>) - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence
 
EMPTY_BATCH_CONTROL_RECORD - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
enableAsyncDiskSync - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
enableIndexDiskSyncs - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
enableIndexPageCaching - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
enableIndexRecoveryFile - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
enableIndexWriteAsync - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
enableJournalDiskSyncs - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
entrySet() - Method in class org.apache.activemq.util.LFUCache
 
EOF_EOT - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
EOF_INT - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
EOF_RECORD - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
equals(KahaAckMessageFileMapCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
equals(KahaAddMessageCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
equals(KahaAddScheduledJobCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
equals(KahaCommitCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
equals(KahaDestination) - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
equals(KahaDestroySchedulerCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
equals(KahaLocalTransactionId) - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
equals(KahaLocation) - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
equals(KahaPrepareCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
equals(KahaProducerAuditCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
equals(KahaRemoveDestinationCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
equals(KahaRemoveMessageCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
equals(KahaRemoveScheduledJobCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
equals(KahaRemoveScheduledJobsCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
equals(KahaRescheduleJobCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
equals(KahaRewrittenDataFileCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
equals(KahaRollbackCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
equals(KahaSubscriptionCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
equals(KahaTraceCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
equals(KahaTransactionInfo) - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
equals(KahaUpdateMessageCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
equals(KahaXATransactionId) - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal.WriteKey
 
equals(Object) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
 
exception - Variable in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch
 
execute(Transaction) - Method in interface org.apache.activemq.store.kahadb.disk.page.Transaction.CallableClosure
 
execute(Transaction) - Method in interface org.apache.activemq.store.kahadb.disk.page.Transaction.Closure
 
execute(Transaction.Closure<T>) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
Executes a closure and if it does not throw any exceptions, then it commits the transaction.
execute(Transaction.CallableClosure<R, T>) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
Executes a closure and if it does not throw any exceptions, then it commits the transaction.
execute(long) - Method in interface org.apache.activemq.store.kahadb.disk.util.Sequence.Closure
 
executeAfterDelay(Runnable, long) - Static method in class org.apache.activemq.store.kahadb.disk.util.Scheduler
 
executePeriodically(Runnable, long) - Static method in class org.apache.activemq.store.kahadb.disk.util.Scheduler
 

F

failIfDatabaseIsLocked - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
failIfDatabaseIsLocked - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
file - Variable in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
FileAppender - Interface in org.apache.activemq.store.kahadb.disk.journal
 
fileByFileMap - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
fileMap - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
filePrefix - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
fileRemoved(DataFile) - Method in interface org.apache.activemq.store.kahadb.disk.journal.Journal.DataFileRemovedListener
 
fileSuffix - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
FilteredKahaDBPersistenceAdapter - Class in org.apache.activemq.store.kahadb
 
FilteredKahaDBPersistenceAdapter() - Constructor for class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter
 
FilteredKahaDBPersistenceAdapter(FilteredKahaDBPersistenceAdapter, ActiveMQDestination, PersistenceAdapter) - Constructor for class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter
 
firstInProgressTransactionLocation - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
 
flush() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
Flush and sync all write buffers to disk.
forceRecoverIndex - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
forceRecoverIndex - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
forgetRecoveredAcks(TransactionId, boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore
 
forgetRecoveredAcks(ArrayList<MessageAck>, boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
free(long) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
Frees up a previously allocated page so that it can be re-allocated again.
free(long, int) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
Frees up a previously allocated sequence of pages so that it can be re-allocated again.
free(Page<T>, int) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
Frees up a previously allocated sequence of pages so that it can be re-allocated again.
free(Page<T>) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
Frees up a previously allocated page so that it can be re-allocated again.
freePage(long) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
frequencyOf(Key) - Method in class org.apache.activemq.util.LFUCache
 

G

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

H

handleException() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
hashCode() - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
hashCode() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
hashCode() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal.WriteKey
 
hashCode() - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
 
HashIndex<Key,Value> - Class in org.apache.activemq.store.kahadb.disk.index
BTree implementation
HashIndex(PageFile, long) - Constructor for class org.apache.activemq.store.kahadb.disk.index.HashIndex
Constructor
headPageId - Variable in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 

I

ignoreMissingJournalfiles - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
incrementalRecover() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
incrementJournalCount(Transaction, Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
Adds a reference for the journal log file pointed to by the given Location value.
incrementLength(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
Index<Key,Value> - Interface in org.apache.activemq.store.kahadb.disk.index
Simpler than a Map
indexCacheSize - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
indexDirectory - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
indexLFUEvictionFactor - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
indexLock - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
indexLock - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
indexMutex - Variable in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
indexWriteBatchSize - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
inflightTransactions - Variable in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
inflightWrites - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
init() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
init() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
init() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
initialize(Transaction) - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData
For a newly created KahaDBMetaData instance this method is called to allow the instance to create all of it's internal indices and other state data.
initialize(Transaction) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData
 
INSTANCE - Static variable in class org.apache.activemq.store.kahadb.disk.util.IntegerMarshaller
 
INSTANCE - Static variable in class org.apache.activemq.store.kahadb.disk.util.LocationMarshaller
 
INSTANCE - Static variable in class org.apache.activemq.store.kahadb.disk.util.LongMarshaller
 
INSTANCE - Static variable in class org.apache.activemq.store.kahadb.disk.util.SequenceSet.Marshaller
 
INSTANCE - Static variable in class org.apache.activemq.store.kahadb.disk.util.StringMarshaller
 
IntegerMarshaller - Class in org.apache.activemq.store.kahadb.disk.util
Implementation of a Marshaller for a Integer
IntegerMarshaller() - Constructor for class org.apache.activemq.store.kahadb.disk.util.IntegerMarshaller
 
intialize() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
 
isAdjacentToFirst(long) - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence
 
isAdjacentToLast(long) - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence
 
isArchiveCorruptedIndex() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isArchiveCorruptedIndex() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
isArchiveCorruptedIndex() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
isArchiveDataLogs() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isArchiveDataLogs() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
isArchiveDataLogs() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
isArchiveDataLogs() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
isCheckForCorruptionOnStartup() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
isCheckForCorruptJournalFiles() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isCheckForCorruptJournalFiles() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
isCheckForCorruptJournalFiles() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
isChecksum() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
isChecksumJournalFiles() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isChecksumJournalFiles() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
isChecksumJournalFiles() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
isCleanShutdown() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
 
isCompactAcksIgnoresStoreGrowth() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
isCompactAcksIgnoresStoreGrowth() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
Returns whether Ack compaction will ignore that the store is still growing and run more often.
isConcurrentStoreAndDispatchQueues() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
isConcurrentStoreAndDispatchQueues() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
isConcurrentStoreAndDispatchTopics() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
isConcurrentStoreAndDispatchTopics() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
isConcurrentStoreAndDispatchTransactions() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
isDeepCopySupported() - Method in class org.apache.activemq.store.kahadb.disk.util.BytesMarshaller
 
isDeepCopySupported() - Method in class org.apache.activemq.store.kahadb.disk.util.IntegerMarshaller
 
isDeepCopySupported() - Method in class org.apache.activemq.store.kahadb.disk.util.LocationMarshaller
 
isDeepCopySupported() - Method in class org.apache.activemq.store.kahadb.disk.util.LongMarshaller
 
isDeepCopySupported() - Method in interface org.apache.activemq.store.kahadb.disk.util.Marshaller
 
isDeepCopySupported() - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet.Marshaller
 
isDeepCopySupported() - Method in class org.apache.activemq.store.kahadb.disk.util.StringMarshaller
 
isDeepCopySupported() - Method in class org.apache.activemq.store.kahadb.disk.util.VariableMarshaller
 
isDeepCopySupported() - Method in class org.apache.activemq.store.kahadb.MessageDatabase.LastAckMarshaller
 
isDeleteAllJobs() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isDeleteAllMessages() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
isEmpty(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
isEmpty(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
 
isEmpty(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
isEmpty(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
 
isEmpty() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
 
isEmpty() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
 
isEmpty() - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
 
isEmpty() - Method in class org.apache.activemq.util.LFUCache
 
isEnableAckCompaction() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
Returns whether Ack compaction is enabled
isEnableAckCompaction() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
Returns whether Ack compaction is enabled
isEnableAsyncDiskSync() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
isEnableDiskSyncs() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
isEnabledWriteThread() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
isEnableIndexDiskSyncs() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isEnableIndexDiskSyncs() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
isEnableIndexDiskSyncs() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
isEnableIndexPageCaching() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isEnableIndexPageCaching() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
isEnableIndexPageCaching() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
isEnableIndexRecoveryFile() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isEnableIndexRecoveryFile() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
isEnableIndexRecoveryFile() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
isEnableIndexWriteAsync() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isEnableIndexWriteAsync() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
Get the enableIndexWriteAsync
isEnableIndexWriteAsync() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
 
isEnableJournalDiskSyncs() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isEnableJournalDiskSyncs() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
isEnableJournalDiskSyncs() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
isEnablePageCaching() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
isEnableRecoveryFile() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
Is the recovery buffer used to double buffer page writes.
isFailIfDatabaseIsLocked() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isFailIfDatabaseIsLocked() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
isFailIfDatabaseIsLocked() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
 
isForceRecoverIndex() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isHead() - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
 
isHeadNode() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
 
isIgnoreMissingJournalfiles() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isIgnoreMissingJournalfiles() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
Get the ignoreMissingJournalfiles
isIgnoreMissingJournalfiles() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
isInterestedInKey(Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.AndVisitor
 
isInterestedInKey(Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.BetweenVisitor
 
isInterestedInKey(Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.GTEVisitor
 
isInterestedInKey(Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.GTVisitor
 
isInterestedInKey(Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.LTEVisitor
 
isInterestedInKey(Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.LTVisitor
 
isInterestedInKey(Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.OrVisitor
 
isInterestedInKey(Key) - Method in interface org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.Predicate
 
isInterestedInKeysBetween(Key, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.AndVisitor
 
isInterestedInKeysBetween(Key, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.BetweenVisitor
 
isInterestedInKeysBetween(Key, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.GTEVisitor
 
isInterestedInKeysBetween(Key, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.GTVisitor
 
isInterestedInKeysBetween(Key, Key) - Method in interface org.apache.activemq.store.kahadb.disk.index.BTreeVisitor
Do you want to visit the range of BTree entries between the first and and second key?
isInterestedInKeysBetween(Key, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.LTEVisitor
 
isInterestedInKeysBetween(Key, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.LTVisitor
 
isInterestedInKeysBetween(Key, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.OrVisitor
 
isInterestedInKeysBetween(Key, Key) - Method in interface org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.Predicate
 
isJournalDiskSyncPeriodic() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
isLazyInit() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
 
isLinked() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
 
isLoaded() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
isLocalXid(TransactionId) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
isPerDestination() - Method in class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter
 
isPreallocate() - Method in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender
 
isPurgeStoreOnStartup() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isReadOnly() - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
 
isTail() - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
 
isTailNode() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
 
isTransient() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
isTransient() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
isTransient() - Method in interface org.apache.activemq.store.kahadb.disk.index.Index
 
isTransient() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
isUnusedPreallocated(DataFile) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
isUseIndexLFRUEviction() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
isUseIndexLFRUEviction() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
isUseIndexLFRUEviction() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
isUseLFRUEviction() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
isVerbose() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark
 
iterator(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
iterator(Transaction, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
iterator(Transaction, Key, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
iterator(Transaction, Key, Key) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
 
iterator(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
 
iterator(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
iterator(Transaction) - Method in interface org.apache.activemq.store.kahadb.disk.index.Index
 
iterator(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
iterator(Transaction, long) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
iterator(Transaction, long) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
 
iterator(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
 
iterator() - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
Allows you to iterate through all active Pages in this object.
iterator(boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
Allows you to iterate through all active Pages in this object.
iterator() - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet
 
iterator() - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
 

J

JobImpl - Class in org.apache.activemq.store.kahadb.scheduler
 
JobImpl(JobLocation, ByteSequence) - Constructor for class org.apache.activemq.store.kahadb.scheduler.JobImpl
 
JobSchedulerImpl - Class in org.apache.activemq.store.kahadb.scheduler
 
JobSchedulerKahaDBMetaData - Class in org.apache.activemq.store.kahadb.scheduler
The KahaDB MetaData used to house the Index data for the KahaDB implementation of a JobSchedulerStore.
JobSchedulerKahaDBMetaData(JobSchedulerStoreImpl) - Constructor for class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData
Creates a new instance of this meta data object with the assigned parent JobSchedulerStore instance.
JobSchedulerStoreImpl - Class in org.apache.activemq.store.kahadb.scheduler
 
JobSchedulerStoreImpl() - Constructor for class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
 
journal - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
Journal - Class in org.apache.activemq.store.kahadb.disk.journal
Manages DataFiles
Journal() - Constructor for class org.apache.activemq.store.kahadb.disk.journal.Journal
 
journal - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
Journal.DataFileRemovedListener - Interface in org.apache.activemq.store.kahadb.disk.journal
 
Journal.JournalDiskSyncStrategy - Enum in org.apache.activemq.store.kahadb.disk.journal
 
Journal.PreallocationScope - Enum in org.apache.activemq.store.kahadb.disk.journal
 
Journal.PreallocationStrategy - Enum in org.apache.activemq.store.kahadb.disk.journal
 
Journal.WriteCommand - Class in org.apache.activemq.store.kahadb.disk.journal
 
Journal.WriteCommand(Location, ByteSequence, boolean) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.Journal.WriteCommand
 
Journal.WriteCommand(Location, ByteSequence, Runnable) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.Journal.WriteCommand
 
Journal.WriteKey - Class in org.apache.activemq.store.kahadb.disk.journal
 
Journal.WriteKey(Location) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.Journal.WriteKey
 
JournalCommand<T> - Interface in org.apache.activemq.store.kahadb
 
journalDiskSyncStrategy - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
journalDiskSyncStrategy - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
journalMaxFileLength - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
journalMaxWriteBatchSize - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
journalSize - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
journalSize - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 

K

KahaAckMessageFileMapCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaAckMessageFileMapCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
KahaAddMessageCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaAddMessageCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
KahaAddScheduledJobCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaAddScheduledJobCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
KahaCommitCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaCommitCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
KahaDBIOExceptionHandler - Class in org.apache.activemq.store.kahadb
 
KahaDBIOExceptionHandler() - Constructor for class org.apache.activemq.store.kahadb.KahaDBIOExceptionHandler
 
KahaDBMetaData<T> - Interface in org.apache.activemq.store.kahadb
Interface for the store meta data used to hold the index value and other needed information to manage a KahaDB store instance.
KahaDBPersistenceAdapter - Class in org.apache.activemq.store.kahadb
An implementation of PersistenceAdapter designed for use with KahaDB - Embedded Lightweight Non-Relational Database
KahaDBPersistenceAdapter() - Constructor for class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
KahaDBStore - Class in org.apache.activemq.store.kahadb
 
KahaDBStore() - Constructor for class org.apache.activemq.store.kahadb.KahaDBStore
 
KahaDBStore.KahaDBMessageStore - Class in org.apache.activemq.store.kahadb
 
KahaDBStore.KahaDBMessageStore(ActiveMQDestination) - Constructor for class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
 
KahaDBStore.StoreTask - Interface in org.apache.activemq.store.kahadb
 
KahaDBStore.StoreTaskExecutor - Class in org.apache.activemq.store.kahadb
 
KahaDBStore.StoreTaskExecutor(int, int, long, TimeUnit, BlockingQueue<Runnable>, ThreadFactory) - Constructor for class org.apache.activemq.store.kahadb.KahaDBStore.StoreTaskExecutor
 
KahaDBTransactionStore - Class in org.apache.activemq.store.kahadb
Provides a TransactionStore implementation that can create transaction aware MessageStore objects from non transaction aware MessageStore objects.
KahaDBTransactionStore(KahaDBStore) - Constructor for class org.apache.activemq.store.kahadb.KahaDBTransactionStore
 
KahaDBTransactionStore.AddMessageCommand - Class in org.apache.activemq.store.kahadb
 
KahaDBTransactionStore.RemoveMessageCommand - Class in org.apache.activemq.store.kahadb
 
KahaDBTransactionStore.Tx - Class in org.apache.activemq.store.kahadb
 
KahaDBTransactionStore.Tx() - Constructor for class org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx
 
KahaDestination - Class in org.apache.activemq.store.kahadb.data
 
KahaDestination() - Constructor for class org.apache.activemq.store.kahadb.data.KahaDestination
 
KahaDestination.DestinationType - Enum in org.apache.activemq.store.kahadb.data
 
KahaDestroySchedulerCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaDestroySchedulerCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
KahaEntryType - Enum in org.apache.activemq.store.kahadb.data
 
KahaLocalTransactionId - Class in org.apache.activemq.store.kahadb.data
 
KahaLocalTransactionId() - Constructor for class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
KahaLocation - Class in org.apache.activemq.store.kahadb.data
 
KahaLocation() - Constructor for class org.apache.activemq.store.kahadb.data.KahaLocation
 
KahaPrepareCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaPrepareCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
KahaProducerAuditCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaProducerAuditCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
KahaRemoveDestinationCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaRemoveDestinationCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
KahaRemoveMessageCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaRemoveMessageCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
KahaRemoveScheduledJobCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaRemoveScheduledJobCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
KahaRemoveScheduledJobsCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaRemoveScheduledJobsCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
KahaRescheduleJobCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaRescheduleJobCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
KahaRewrittenDataFileCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaRewrittenDataFileCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
KahaRollbackCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaRollbackCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
KahaSubscriptionCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaSubscriptionCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
KahaTraceCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaTraceCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
KahaTransactionInfo - Class in org.apache.activemq.store.kahadb.data
 
KahaTransactionInfo() - Constructor for class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
KahaUpdateMessageCommand - Class in org.apache.activemq.store.kahadb.data
 
KahaUpdateMessageCommand() - Constructor for class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
KahaXATransactionId - Class in org.apache.activemq.store.kahadb.data
 
KahaXATransactionId() - Constructor for class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
key(KahaDestination) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
keySet() - Method in class org.apache.activemq.util.LFUCache
 

L

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
 

M

main(String[]) - Static method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark
 
mainLoop() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
 
makePageEnd(long, long) - Method in class org.apache.activemq.store.kahadb.disk.page.Page
 
makePagePart(long, long) - Method in class org.apache.activemq.store.kahadb.disk.page.Page
 
Marshaller<T> - Interface in org.apache.activemq.store.kahadb.disk.util
 
matched(Key, Value) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.PredicateVisitor
 
maxFileLength - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
maxStat - Static variable in interface org.apache.activemq.store.kahadb.disk.journal.FileAppender
 
mergeFrom(KahaAckMessageFileMapCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
mergeFrom(KahaAddMessageCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
mergeFrom(KahaAddScheduledJobCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
mergeFrom(KahaCommitCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
mergeFrom(KahaDestination) - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
mergeFrom(KahaDestroySchedulerCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
mergeFrom(KahaLocalTransactionId) - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
mergeFrom(KahaLocation) - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
mergeFrom(KahaPrepareCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
mergeFrom(KahaProducerAuditCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
mergeFrom(KahaRemoveDestinationCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
mergeFrom(KahaRemoveMessageCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
mergeFrom(KahaRemoveScheduledJobCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
mergeFrom(KahaRemoveScheduledJobsCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
mergeFrom(KahaRescheduleJobCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
mergeFrom(KahaRewrittenDataFileCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
mergeFrom(KahaRollbackCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
mergeFrom(KahaSubscriptionCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
mergeFrom(KahaTraceCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
mergeFrom(KahaTransactionInfo) - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
mergeFrom(KahaUpdateMessageCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
mergeFrom(KahaXATransactionId) - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
mergeUnframed(CodedInputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
MessageDatabase - Class in org.apache.activemq.store.kahadb
 
MessageDatabase() - Constructor for class org.apache.activemq.store.kahadb.MessageDatabase
 
MessageDatabase.LastAckMarshaller - Class in org.apache.activemq.store.kahadb
 
MessageDatabase.LastAckMarshaller() - Constructor for class org.apache.activemq.store.kahadb.MessageDatabase.LastAckMarshaller
 
MessageDatabase.MessageKeysMarshaller - Class in org.apache.activemq.store.kahadb
 
MessageDatabase.MessageKeysMarshaller() - Constructor for class org.apache.activemq.store.kahadb.MessageDatabase.MessageKeysMarshaller
 
MessageDatabase.Metadata - Class in org.apache.activemq.store.kahadb
 
MessageDatabase.Metadata() - Constructor for class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
 
MessageDatabase.StoredDestinationMarshaller - Class in org.apache.activemq.store.kahadb
 
MessageDatabase.StoredDestinationMarshaller() - Constructor for class org.apache.activemq.store.kahadb.MessageDatabase.StoredDestinationMarshaller
 
metadata - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
metadataMarshaller - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
missingFields() - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
move(File) - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
move(File) - Method in class org.apache.activemq.store.kahadb.disk.journal.ReadOnlyDataFile
 
MultiKahaDBPersistenceAdapter - Class in org.apache.activemq.store.kahadb
An implementation of PersistenceAdapter that supports distribution of destinations across multiple kahaDB persistence adapters
MultiKahaDBPersistenceAdapter() - Constructor for class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
MultiKahaDBTransactionStore - Class in org.apache.activemq.store.kahadb
 
MultiKahaDBTransactionStore(MultiKahaDBPersistenceAdapter) - Constructor for class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
 
MultiKahaDBTransactionStore.Tx - Class in org.apache.activemq.store.kahadb
 
MultiKahaDBTransactionStore.Tx() - Constructor for class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore.Tx
 

N

nameFromDestinationFilter(ActiveMQDestination) - Static method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
next - Variable in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
 
NOT_SET - Static variable in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
NOT_SET - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Location
 
NOT_SET_TYPE - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Location
 

O

ObjectMarshaller - Class in org.apache.activemq.store.kahadb.disk.util
Implementation of a Marshaller for Objects
ObjectMarshaller() - Constructor for class org.apache.activemq.store.kahadb.disk.util.ObjectMarshaller
 
offset - Variable in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch
 
onComplete - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal.WriteCommand
 
onRemove() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
onWrite() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
This method is called after each write to the buffer.
open() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
open() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
OPEN_STATE - Static variable in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
OPEN_STATE - Static variable in interface org.apache.activemq.store.kahadb.KahaDBMetaData
Indicates that this meta data instance has been opened and is active.
OPEN_STATE - Static variable in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
opened - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
opened - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
opened - Variable in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
openInputStream(Page) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
 
openOutputStream(Page, boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction
 
openRandomAccessFile() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
openRandomAccessFile(boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.ReadOnlyDataFile
 
openwireVersion - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
 
org.apache.activemq.store.kahadb - package org.apache.activemq.store.kahadb
 
org.apache.activemq.store.kahadb.data - package org.apache.activemq.store.kahadb.data
 
org.apache.activemq.store.kahadb.disk.index - package org.apache.activemq.store.kahadb.disk.index
 
org.apache.activemq.store.kahadb.disk.journal - package org.apache.activemq.store.kahadb.disk.journal
journal based data storage - scalable and fast
org.apache.activemq.store.kahadb.disk.page - package org.apache.activemq.store.kahadb.disk.page
 
org.apache.activemq.store.kahadb.disk.util - package org.apache.activemq.store.kahadb.disk.util
 
org.apache.activemq.store.kahadb.plist - package org.apache.activemq.store.kahadb.plist
 
org.apache.activemq.store.kahadb.scheduler - package org.apache.activemq.store.kahadb.scheduler
 
org.apache.activemq.store.kahadb.scheduler.legacy - package org.apache.activemq.store.kahadb.scheduler.legacy
 
org.apache.activemq.util - package org.apache.activemq.util
 

P

Page<T> - Class in org.apache.activemq.store.kahadb.disk.page
A Page within a file.
Page() - Constructor for class org.apache.activemq.store.kahadb.disk.page.Page
 
Page(long) - Constructor for class org.apache.activemq.store.kahadb.disk.page.Page
 
page - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
 
PAGE_END_TYPE - Static variable in class org.apache.activemq.store.kahadb.disk.page.Page
 
PAGE_FREE_TYPE - Static variable in class org.apache.activemq.store.kahadb.disk.page.Page
 
PAGE_HEADER_SIZE - Static variable in class org.apache.activemq.store.kahadb.disk.page.Page
 
PAGE_PART_TYPE - Static variable in class org.apache.activemq.store.kahadb.disk.page.Page
 
pageFile - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
pageFile - Variable in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
PageFile - Class in org.apache.activemq.store.kahadb.disk.page
A PageFile provides you random access to fixed sized disk pages.
PageFile(File, String) - Constructor for class org.apache.activemq.store.kahadb.disk.page.PageFile
Creates a PageFile in the specified directory who's data files are named by name.
pageFile - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
pageFile - Variable in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
PageFile.MetaData - Class in org.apache.activemq.store.kahadb.disk.page
The MetaData object hold the persistent data associated with a PageFile object.
PageFile.MetaData() - Constructor for class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
parseUnframed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
persistCompletion(TransactionId) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
 
persistOutcome(MultiKahaDBTransactionStore.Tx, TransactionId) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
 
PListImpl - Class in org.apache.activemq.store.kahadb.plist
 
PListStoreImpl - Class in org.apache.activemq.store.kahadb.plist
 
PListStoreImpl() - Constructor for class org.apache.activemq.store.kahadb.plist.PListStoreImpl
 
PListStoreImpl.MetaData - Class in org.apache.activemq.store.kahadb.plist
 
PListStoreImpl.MetaData(PListStoreImpl) - Constructor for class org.apache.activemq.store.kahadb.plist.PListStoreImpl.MetaData
 
pos - Variable in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
position(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
Set the current position for writing
preallocateEntireJournalDataFile(RecoverableRandomAccessFile) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
preallocationScope - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
preallocationStrategy - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
prepare(TransactionId) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore
 
prepare(TransactionId) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
 
preparedTransactions - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
preparedTransactions - Variable in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
prev - Variable in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
 
printStructure(Transaction, PrintWriter) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
printStructure(Transaction, OutputStream) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
printStructure(Transaction, PrintWriter, String) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
 
process(JournalCommand<?>, Location) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
Process a stored or recovered JournalCommand instance and update the DB Index with the state changes that this command produces.
process(KahaAddMessageCommand, Location, MessageDatabase.IndexAware) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
process(KahaUpdateMessageCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
process(KahaRemoveMessageCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
process(KahaRemoveDestinationCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
process(KahaSubscriptionCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
process(KahaCommitCommand, Location, MessageDatabase.IndexAware) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
process(KahaPrepareCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
process(KahaRollbackCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
process(KahaRewrittenDataFileCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
process(JournalCommand<?>) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
 
process(Transaction, KahaAddScheduledJobCommand, Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
Adds a new Scheduled job to the index.
process(Transaction, KahaRescheduleJobCommand, Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
Reschedules a Job after it has be fired.
process(Transaction, KahaRemoveScheduledJobsCommand, Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
Removes all scheduled jobs within a given time range.
process(JournalCommand<?>, Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
Called during recovery to allow the store to rebuild from scratch.
process(KahaRemoveDestinationCommand) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
process(KahaSubscriptionCommand) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
processAdd(KahaAddMessageCommand, TransactionId, ByteSequence) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
processCommit(TransactionId) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
processLocation(Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
processLocation(Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
 
processPrepare(TransactionId) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
processRemove(KahaRemoveMessageCommand, TransactionId) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
processRollback(TransactionId) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
producerSequenceIdTracker - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
 
producerSequenceIdTrackerLocation - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
 
PROPERTY_ASYNC_EXECUTOR_MAX_THREADS - Static variable in class org.apache.activemq.store.kahadb.KahaDBStore
 
PROPERTY_CANCELED_TASK_MOD_METRIC - Static variable in class org.apache.activemq.store.kahadb.KahaDBStore
 
PROPERTY_LOG_SLOW_ACCESS_TIME - Static variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
PROPERTY_LOG_SLOW_ACCESS_TIME - Static variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
PROPERTY_LOG_WRITE_STAT_WINDOW - Static variable in interface org.apache.activemq.store.kahadb.disk.journal.FileAppender
 
proxy(MessageStore) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore
 
proxy(TopicMessageStore) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore
 
proxy(TransactionStore, MessageStore) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
 
proxy(TransactionStore, TopicMessageStore) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore
 
purgeStoreOnStartup - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
put(Transaction, Key, Value) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
put(Transaction, Key, Value) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
 
put(Transaction, Key, Value) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
put(Transaction, Key, Value) - Method in interface org.apache.activemq.store.kahadb.disk.index.Index
store the key, item
put(Transaction, Key, Value) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
Update the value of the item with the given key in the list if ot exists, otherwise it appends the value to the end of the list.
put(Transaction, Key, Value) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
 
put(Key, Value) - Method in class org.apache.activemq.util.LFUCache
 
putAll(Map<? extends Key, ? extends Value>) - Method in class org.apache.activemq.util.LFUCache
 

Q

queueExecutor - Variable in class org.apache.activemq.store.kahadb.KahaDBStore
 

R

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) - 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(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(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
 
rolledBackAcks - Variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
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
 

S

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(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.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
 
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
 
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.
setLatch(CountDownLatch) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
 
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.
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
 

T

tailPageId - Variable in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
TargetedDataFileAppender - Class in org.apache.activemq.store.kahadb.disk.journal
File Appender instance that performs batched writes in the thread where the write is queued.
TargetedDataFileAppender(Journal, DataFile) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender
Construct a Store writer
TargetedDataFileAppender.WriteBatch - Class in org.apache.activemq.store.kahadb.disk.journal
 
TargetedDataFileAppender.WriteBatch(DataFile, int) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch
 
TargetedDataFileAppender.WriteBatch(DataFile, int, Journal.WriteCommand) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch
 
TempKahaDBStore - Class in org.apache.activemq.store.kahadb
 
TempKahaDBStore() - Constructor for class org.apache.activemq.store.kahadb.TempKahaDBStore
 
TempKahaDBStore.KahaDBMessageStore - Class in org.apache.activemq.store.kahadb
 
TempKahaDBStore.KahaDBMessageStore(ActiveMQDestination) - Constructor for class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore
 
TempMessageDatabase - Class in org.apache.activemq.store.kahadb
 
TempMessageDatabase() - Constructor for class org.apache.activemq.store.kahadb.TempMessageDatabase
 
TempMessageDatabase.MessageKeysMarshaller - Class in org.apache.activemq.store.kahadb
 
TempMessageDatabase.MessageKeysMarshaller() - Constructor for class org.apache.activemq.store.kahadb.TempMessageDatabase.MessageKeysMarshaller
 
TempMessageDatabase.StoredDestinationMarshaller - Class in org.apache.activemq.store.kahadb
 
TempMessageDatabase.StoredDestinationMarshaller() - Constructor for class org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestinationMarshaller
 
toArrayList() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
Copies the nodes of the LinkedNodeList to an ArrayList.
toByteSequence(JournalCommand<?>) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
Creates a new ByteSequence that represents the marshaled form of the given Journal Command.
toByteSequence() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
Get a ByteSequence from the stream
toByteSequence(JournalCommand<?>) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
toOffset(long) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
topicExecutor - Variable in class org.apache.activemq.store.kahadb.KahaDBStore
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
toString() - Method in enum org.apache.activemq.store.kahadb.data.KahaDestination.DestinationType
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
toString() - Method in enum org.apache.activemq.store.kahadb.data.KahaEntryType
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
toString() - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.AndVisitor
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.BetweenVisitor
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.GTEVisitor
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.GTVisitor
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.LTEVisitor
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.LTVisitor
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.OrVisitor
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.page.Page
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList
 
toString() - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence
 
toString() - Method in class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter
 
toString() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter
 
toString() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
 
toString() - Method in class org.apache.activemq.store.kahadb.KahaDBStore
 
toString() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter
 
toString() - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
 
toString() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl
 
toString() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl
 
toString() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
 
toString() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
 
totalLength - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
trackPrepareLocation(Location) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore.Tx
 
trackRecoveredAcks(ArrayList<MessageAck>) - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
trackStore(TransactionStore) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore.Tx
 
Transaction - Class in org.apache.activemq.store.kahadb.disk.page
The class used to read/update a PageFile object.
Transaction.CallableClosure<R,T extends Throwable> - Interface in org.apache.activemq.store.kahadb.disk.page
This closure interface is intended for the end user implement callbacks for the Transaction.exectue() method.
Transaction.Closure<T extends Throwable> - Interface in org.apache.activemq.store.kahadb.disk.page
This closure interface is intended for the end user implement callbacks for the Transaction.exectue() method.
Transaction.InvalidPageIOException - Exception in org.apache.activemq.store.kahadb.disk.page
The InvalidPageIOException is thrown if try to load/store a a page with an invalid page id.
Transaction.InvalidPageIOException(String, long) - Constructor for exception org.apache.activemq.store.kahadb.disk.page.Transaction.InvalidPageIOException
 
Transaction.PageOverflowIOException - Exception in org.apache.activemq.store.kahadb.disk.page
The PageOverflowIOException occurs when a page write is requested and it's data is larger than what would fit into a single page.
Transaction.PageOverflowIOException(String) - Constructor for exception org.apache.activemq.store.kahadb.disk.page.Transaction.PageOverflowIOException
 
TransactionIdConversion - Class in org.apache.activemq.store.kahadb
 
TransactionIdConversion() - Constructor for class org.apache.activemq.store.kahadb.TransactionIdConversion
 
tx() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
type() - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
type() - Method in interface org.apache.activemq.store.kahadb.JournalCommand
 
typeCode - Variable in class org.apache.activemq.store.kahadb.disk.journal.DataFile
 

U

UnknownStoreVersionException - Exception in org.apache.activemq.store.kahadb.scheduler
 
UnknownStoreVersionException(Throwable) - Constructor for exception org.apache.activemq.store.kahadb.scheduler.UnknownStoreVersionException
 
UnknownStoreVersionException(String) - Constructor for exception org.apache.activemq.store.kahadb.scheduler.UnknownStoreVersionException
 
unlink() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode
Removes this node out of the linked list it is chained in.
unload() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
Unload the state of the Store to disk and shuts down all resources assigned to this KahaDB store implementation.
unload(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex
 
unload(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex
 
unload(Transaction) - Method in interface org.apache.activemq.store.kahadb.disk.index.Index
unload indexes
unload(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex
 
unload() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile
Unloads a previously loaded PageFile.
unload() - Method in class org.apache.activemq.store.kahadb.MessageDatabase
 
unload() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
 
unload() - Method in class org.apache.activemq.store.kahadb.scheduler.legacy.LegacyStoreReplayer
Unloads a previously loaded legacy store to release any resources associated with it.
unload() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase
 
unlockAsyncJobQueue() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
 
UNMATCHED - Static variable in class org.apache.activemq.store.kahadb.MessageDatabase
 
update(Location, ByteSequence, boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
updateMessage(Message) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore
 
useIndexLFRUEviction - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore
 
USER_RECORD_TYPE - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
USER_TYPE - Static variable in class org.apache.activemq.store.kahadb.disk.journal.Location
 

V

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
 

W

write(ByteSequence, boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
write(ByteSequence, Runnable) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
write(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
Writes the specified byte to this byte array output stream.
write(byte[], int, int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
Writes len bytes from the specified byte array starting at offset off to this byte array output stream.
write(DataOutput) - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData
Writes the object into a serialized form which can be read back in again using the read method.
write(DataOutput) - Method in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata
 
write(DataOutput) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl
 
write(DataOutput) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl.MetaData
 
write(DataOutput) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl
 
write(DataOutput) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData
 
write(int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
write(byte[]) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
write(byte[], int, int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
writeBatchSize - Variable in class org.apache.activemq.store.kahadb.disk.journal.Journal
 
writeBoolean(boolean) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
writeBoolean(boolean) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
writeByte(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
writeByte(int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
writeBytes(String) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
writeBytes(String) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
writeChar(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
writeChar(int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
writeChars(String) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
writeChars(String) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
writeDouble(double) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
writeDouble(double) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
writeDuration - Variable in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
 
writeExternal(DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location
 
writeFloat(float) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
writeFloat(float) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
writeInt(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
writeInt(int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
writeLockIndex() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
 
writeLong(long) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
writeLong(long) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
writePayload(BTreeNode<Key, Value>, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode.Marshaller
 
writePayload(ListNode<Key, Value>, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode.NodeMarshaller
 
writePayload(byte[], DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.util.BytesMarshaller
 
writePayload(Integer, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.util.IntegerMarshaller
 
writePayload(Location, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.util.LocationMarshaller
 
writePayload(Long, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.util.LongMarshaller
 
writePayload(T, DataOutput) - Method in interface org.apache.activemq.store.kahadb.disk.util.Marshaller
Write the payload of the object to the DataOutput stream.
writePayload(Object, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.util.ObjectMarshaller
 
writePayload(SequenceSet, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet.Marshaller
 
writePayload(String, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.util.StringMarshaller
Write the payload of this entry to the RawContainer
writePayload(MessageDatabase.LastAck, DataOutput) - Method in class org.apache.activemq.store.kahadb.MessageDatabase.LastAckMarshaller
 
writePayload(MessageDatabase.MessageKeys, DataOutput) - Method in class org.apache.activemq.store.kahadb.MessageDatabase.MessageKeysMarshaller
 
writePayload(MessageDatabase.StoredDestination, DataOutput) - Method in class org.apache.activemq.store.kahadb.MessageDatabase.StoredDestinationMarshaller
 
writePayload(TempMessageDatabase.MessageRecord, DataOutput) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase.MessageKeysMarshaller
 
writePayload(TempMessageDatabase.StoredDestination, DataOutput) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestinationMarshaller
 
writes - Variable in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch
 
writes - Variable in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report
 
writeShort(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
writeShort(int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaDestination
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaLocation
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand
 
writeUnframed(CodedOutputStream) - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId
 
writeUnlockIndex() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl
 
writeUTF(String) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream
 
writeUTF(String) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile
 
A B C D E F G H I J K L M N O P Q R S T U V W 

Copyright © 2005–2017 FuseSource, Corp.. All rights reserved.