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

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

ackedAndPreparedMap - Variable in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore

ackMessageFileMap - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata

ackMessageFileMapDirtyFlag - 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(long) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet

add(Transaction, String, Location) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

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(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(String, ByteSequence) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

addFirst(Transaction, String, Location) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

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(LinkedNodeList<T>) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList

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

addLast(LinkedNodeList<T>) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList

addLast(T) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList

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

allowIOResumption() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

allowIOResumption() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

allowIOResumption() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore

ALWAYS - org.apache.activemq.store.kahadb.disk.journal.Journal.JournalDiskSyncStrategy

AndVisitor(List<BTreeVisitor.Predicate<Key>>) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.AndVisitor

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

BetweenVisitor(Key, Key) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.BetweenVisitor

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.

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.

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.BetweenVisitor<Key extends Comparable<Key>,Value> - Class in org.apache.activemq.store.kahadb.disk.index

BTreeVisitor.GTEVisitor<Key extends Comparable<Key>,Value> - Class in org.apache.activemq.store.kahadb.disk.index

BTreeVisitor.GTVisitor<Key extends Comparable<Key>,Value> - Class in org.apache.activemq.store.kahadb.disk.index

BTreeVisitor.LTEVisitor<Key extends Comparable<Key>,Value> - Class in org.apache.activemq.store.kahadb.disk.index

BTreeVisitor.LTVisitor<Key extends Comparable<Key>,Value> - Class in org.apache.activemq.store.kahadb.disk.index

BTreeVisitor.OrVisitor<Key,Value> - Class in org.apache.activemq.store.kahadb.disk.index

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

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() - Method in interface org.apache.activemq.store.kahadb.KahaDBStore.StoreTask

cancel(Runnable) - Static method in class org.apache.activemq.store.kahadb.disk.util.Scheduler

cancelledTaskModMetric - Static variable in class org.apache.activemq.store.kahadb.KahaDBStore

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

CHUNKED_ZEROS - org.apache.activemq.store.kahadb.disk.journal.Journal.PreallocationStrategy

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

cleanupDirectory(File) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

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() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList

clear() - Method in class org.apache.activemq.util.LFUCache

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(Transaction) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

clearStoreStats(KahaDestination) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

Clear the counter for the destination, if one exists.

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

closeRandomAccessFile(RecoverableRandomAccessFile) - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile

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() - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx

commit(TransactionId, boolean, Runnable, Runnable) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore

commit(TransactionId, boolean, Runnable, Runnable) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore

COMMIT - org.apache.activemq.store.kahadb.MessageDatabase.PurgeRecoveredXATransactionStrategy

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(Object) - Method in class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter

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

configureMetadata() - Method in class org.apache.activemq.store.kahadb.KahaDBStore

configureMetadata() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

contains(int, int) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet

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

containsKey(Object) - Method in class org.apache.activemq.util.LFUCache

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

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.

createJournal() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

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() - Constructor for class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream

Creates WireByteArrayInputStream with a minmalist byte array

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.

DataByteArrayOutputStream - Class in org.apache.activemq.store.kahadb.disk.util

Optimized ByteArrayOutputStream

DataByteArrayOutputStream() - Constructor for class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream

Creates a new byte array output stream.

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.

dataFile - Variable in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch

DataFile - Class in org.apache.activemq.store.kahadb.disk.journal

DataFile

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

decrementAndSubSizeToStoreStat(String, String, long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

decrementAndSubSizeToStoreStat(KahaDestination, String, long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

decrementAndSubSizeToStoreStat(Transaction, String, MessageDatabase.StoredDestination, long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

decrementAndSubSizeToStoreStat(Transaction, KahaDestination, long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

decrementJournalCount(Transaction, HashMap<Integer, Integer>) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl

Removes multiple references for the Journal log file indicated in the given Location map.

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(Long) - Method in class org.apache.activemq.store.kahadb.disk.util.LongMarshaller

deepCopy(String) - Method in class org.apache.activemq.store.kahadb.disk.util.StringMarshaller

deepCopy(Location) - Method in class org.apache.activemq.store.kahadb.disk.util.LocationMarshaller

deepCopy(SequenceSet) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet.Marshaller

deepCopy(MessageDatabase.LastAck) - Method in class org.apache.activemq.store.kahadb.MessageDatabase.LastAckMarshaller

deepCopy(T) - Method in interface org.apache.activemq.store.kahadb.disk.util.Marshaller

deepCopy(T) - Method in class org.apache.activemq.store.kahadb.disk.util.VariableMarshaller

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

deleteAllMessages() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

deleteAllMessages() - Method in class org.apache.activemq.store.kahadb.KahaDBStore

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

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

ENTIRE_JOURNAL - org.apache.activemq.store.kahadb.disk.journal.Journal.PreallocationScope

ENTIRE_JOURNAL_ASYNC - org.apache.activemq.store.kahadb.disk.journal.Journal.PreallocationScope

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(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaDestination

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaLocation

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo

equals(Object) - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand

equals(Object) - 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

equals(KahaAckMessageFileMapCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand

equals(KahaAddMessageCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand

equals(KahaAddScheduledJobCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand

equals(KahaCommitCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand

equals(KahaDestination) - Method in class org.apache.activemq.store.kahadb.data.KahaDestination

equals(KahaDestroySchedulerCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand

equals(KahaLocalTransactionId) - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId

equals(KahaLocation) - Method in class org.apache.activemq.store.kahadb.data.KahaLocation

equals(KahaPrepareCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand

equals(KahaProducerAuditCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand

equals(KahaRemoveDestinationCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand

equals(KahaRemoveMessageCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand

equals(KahaRemoveScheduledJobCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand

equals(KahaRemoveScheduledJobsCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand

equals(KahaRescheduleJobCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand

equals(KahaRewrittenDataFileCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand

equals(KahaRollbackCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand

equals(KahaSubscriptionCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand

equals(KahaTraceCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand

equals(KahaTransactionInfo) - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo

equals(KahaUpdateMessageCommand) - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand

equals(KahaXATransactionId) - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId

exception - Variable in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch

execute(long) - Method in interface org.apache.activemq.store.kahadb.disk.util.Sequence.Closure

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

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(ArrayList<MessageAck>, boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBStore

forgetRecoveredAcks(ArrayList<MessageAck>, boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore

forgetRecoveredAcks(TransactionId, boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore

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

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

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

getAccessorPool() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getAcks() - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx

getActiveBins() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

getAdapters() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

getAllJobs() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl

getAllJobs(long, long) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl

getAllScheduledJobs(Transaction) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl

Walks the Scheduled Job Tree and collects the add location and last update location for all scheduled jobs.

getBinCapacity() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

getBinPageId() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

getBinsActive() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

getBs() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark

getByteSequence() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream

getChannel() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile

getCheckpointInterval() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getCheckpointInterval() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Get the checkpointInterval

getCheckpointInterval() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getChecksum() - Method in class org.apache.activemq.store.kahadb.disk.page.Page

getCleanupInterval() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getCleanupInterval() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getCleanupInterval() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Get the cleanupInterval

getCleanupInterval() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getCleanupInterval() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getCleanupOnStop() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getCleanupOnStop() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

getCleanupOnStop() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getCompactAcksAfterNoGC() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

getCompactAcksAfterNoGC() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getContainingList() - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode

getCorruptedBlocks() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile

getCronEntry() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl

getCurrentDataFile(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getCurrentDataFileId() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getData() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream

getDataFileById(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getDataFileId() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile

getDataFileId() - Method in class org.apache.activemq.store.kahadb.disk.journal.Location

getDefaultDataDirectory() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getDefaultDataDirectory() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl

getDefaultDirectory() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getDelay() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl

getDestination() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore

getDestination() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore

getDestinations() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

getDestinations() - Method in class org.apache.activemq.store.kahadb.KahaDBStore

getDestinations() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

getDestinations() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore

getDirectory() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getDirectory() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getDirectory() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

getDirectory() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Get the directory

getDirectory() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getDirectory() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

getDirectory() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getDirectory() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase

getDirectoryArchive() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getDirectoryArchive() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getDirectoryArchive() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

getDirectoryArchive() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getDiskSize() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getDiskSize() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

getException() - Method in class org.apache.activemq.store.kahadb.disk.journal.Location

getExecutionCount() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl

getExistingStoredDestination(KahaDestination, Transaction) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getFailoverProducersAuditDepth() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

getFailoverProducersAuditDepth() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getFD() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile

getFile() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile

getFile() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

getFile(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

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() - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence

getFirst() - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

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

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() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList

getHead(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex

getHeadNode() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode

getHeadPageId() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex

getIndexCacheSize() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getIndexCacheSize() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Get the indexCacheSize

getIndexCacheSize() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getIndexCacheSize() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getIndexDirectory() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

getIndexDirectory() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getIndexDirectory() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getIndexEnablePageCaching() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getIndexLFUEvictionFactor() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getIndexLFUEvictionFactor() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

getIndexLFUEvictionFactor() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getIndexLock() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getIndexPageSize() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getIndexWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getIndexWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Get the indexWriteBatchSize

getIndexWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getIndexWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getIndexWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase

getInflightWrites() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getInProgressTxLocationRange() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getJobId() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl

getJobScheduler(String) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl

getJobSchedulers() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData

Gets the index of JobScheduler instances that have been created and stored in the JobSchedulerStore instance.

getJournal() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getJournal() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getJournal() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getJournalCleanupInterval() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

getJournalCleanupInterval() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore

getJournalDiskSyncInterval() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

getJournalDiskSyncInterval() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getJournalDiskSyncStrategy() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getJournalDiskSyncStrategy() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

getJournalDiskSyncStrategy() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getJournalDiskSyncStrategyEnum() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

getJournalDiskSyncStrategyEnum() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getJournalFilesBeingReplicated() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getJournalFilesBeingReplicated() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase

getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Get the journalMaxFileLength

getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore

getJournalMaxFileLength() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getJournalMaxWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getJournalMaxWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Get the journalMaxWriteBatchSize

getJournalMaxWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getJournalMaxWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore

getJournalMaxWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

getJournalRC() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData

Gets the index used to track the number of reference to a Journal log file.

getJournalWriteBatchSize() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

getKeyMarshaller() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex

getKeyMarshaller() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

getKeyMarshaller() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex

getLast() - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence

getLast() - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

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

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

getMessages() - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx

getMetadata() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getMetaDataTxId() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData

getMinLeafDepth(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex

getMinLeafDepth(Transaction, int) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode

getMissing(long, long) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet

getName() - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

getName() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl

getNext() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode

getNext() - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode

getNext() - Method in class org.apache.activemq.store.kahadb.disk.page.Page

getNext() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode

getNextCircular() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode

getNextExecutionTime() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl

getNextLocation(Location) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getNextLocation(Location, Location) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getNextScheduleJobs() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl

getNextScheduleTime() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl

getNumber() - Method in enum org.apache.activemq.store.kahadb.data.KahaDestination.DestinationType

getNumber() - Method in enum org.apache.activemq.store.kahadb.data.KahaEntryType

getOffset() - Method in class org.apache.activemq.store.kahadb.disk.journal.Location

getPage() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBMetaData

getPage() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode

getPage() - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode

getPage() - Method in exception org.apache.activemq.store.kahadb.disk.page.Transaction.InvalidPageIOException

getPage() - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData

Gets the Page in the store PageFile where the KahaDBMetaData instance is stored.

getPageCacheSize() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

getPageContentSize() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

getPageCount() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

getPageFile() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getPageFile() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex

getPageFile() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

getPageFile() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex

getPageFile() - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction

getPageFile() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getPageFile() - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase

getPageFileName() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

getPageFileName() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl

getPageId() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex

getPageId() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode

getPageId() - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode

getPageId() - Method in class org.apache.activemq.store.kahadb.disk.page.Page

getPageSize() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

getPageSize() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData

getParent() - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode

getPayload() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl

getPayload(Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl

Retrieve the scheduled Job's byte blob from the journal.

getPeriod() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl

getPersistenceAdapter() - Method in class org.apache.activemq.store.kahadb.FilteredKahaDBPersistenceAdapter

getPersistenceAdapterStatistics() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Get the PersistenceAdapterStatistics

getPersistenceAdapterStatistics() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

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

getPreparedTransaction(TransactionId) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getPrevious() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode

getPreviousCircular() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode

getPurgeRecoveredXATransactionStrategy() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

getPurgeRecoveredXATransactionStrategy() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getPurgeRecoveredXATransactionStrategyEnum() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getRaf() - Method in class org.apache.activemq.util.RecoverableRandomAccessFile

getRawData() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream

getReadDuration() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report

getReads() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report

getReceived() - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet

getRecoveryFile() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

getRecoveryFileMaxPageCount() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

getRecoveryFileMinPageCount() - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

getRemoveLocationTracker() - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData

Gets the index that contains the location tracking information for Jobs that have been removed from the index but whose add operation has yet to be removed from the Journal.

getRepeat() - Method in class org.apache.activemq.store.kahadb.scheduler.JobImpl

getReplicationTarget() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

getSampleInterval() - Method in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark

getSequenceSet(Transaction, MessageDatabase.StoredDestination, String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getSimplePrefix(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"

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

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

getStoredMessageSize(Transaction, MessageDatabase.StoredDestination, String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getStoredMessageSize(Transaction, MessageDatabase.StoredDestination, List<String>) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

Recovers durable subscription pending message size with only 1 pass over the order index on recovery instead of iterating over the index once per subscription

getStoredMessageStoreStatistics(KahaDestination, Transaction) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

getStores() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore.Tx

getStoresMap() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore.Tx

getStoreStats(String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

Locate the storeMessageSize counter for this KahaDestination

getSubStats(String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

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() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList

getTail(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex

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

GTEVisitor(Key) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.GTEVisitor

GTVisitor(Key) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.GTVisitor

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

incrementAndAddSizeToStoreStat(String, String, long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

incrementAndAddSizeToStoreStat(KahaDestination, String, long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

incrementAndAddSizeToStoreStat(Transaction, String, MessageDatabase.StoredDestination, long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

incrementAndAddSizeToStoreStat(Transaction, KahaDestination, long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

Update MessageStoreStatistics

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

InvalidPageIOException(String, long) - Constructor for exception org.apache.activemq.store.kahadb.disk.page.Transaction.InvalidPageIOException

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

isBiggerButNotAdjacentToLast(long) - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence

isCheckForCorruption() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

isCheckForCorruption() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore

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

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

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

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

Deprecated.

use KahaDBPersistenceAdapter.getJournalDiskSyncStrategy() instead

isEnableJournalDiskSyncs() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

Deprecated.

use MessageDatabase.getJournalDiskSyncStrategyEnum() or MessageDatabase.getJournalDiskSyncStrategy() instead

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.

isEnableSubscriptionStatistics() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Whether non-blocking subscription statistics have been enabled

isEnableSubscriptionStatistics() - Method in class org.apache.activemq.store.kahadb.MessageDatabase

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

isFreePage(long) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

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

isPersistNoLocal() - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

isPersistNoLocal() - Method in class org.apache.activemq.store.kahadb.KahaDBStore

isPersistNoLocal() - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

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

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(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex

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) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode

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

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

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.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.WriteKey - Class in org.apache.activemq.store.kahadb.disk.journal

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

KAHA_ACK_MESSAGE_FILE_MAP_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_ADD_MESSAGE_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_ADD_SCHEDULED_JOB_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_COMMIT_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_DESTROY_SCHEDULER_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_PREPARE_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_PRODUCER_AUDIT_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_REMOVE_DESTINATION_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_REMOVE_MESSAGE_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_REMOVE_SCHEDULED_JOB_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_REMOVE_SCHEDULED_JOBS_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_RESCHEDULE_JOB_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_REWRITTEN_DATA_FILE_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_ROLLBACK_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_SUBSCRIPTION_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_TRACE_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

KAHA_UPDATE_MESSAGE_COMMAND - org.apache.activemq.store.kahadb.data.KahaEntryType

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

KahaDBMessageStore(ActiveMQDestination) - Constructor for class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore

KahaDBMessageStore(ActiveMQDestination) - Constructor for class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore

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.StoreTask - Interface in org.apache.activemq.store.kahadb

KahaDBStore.StoreTaskExecutor - Class in org.apache.activemq.store.kahadb

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

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

LastAckMarshaller() - Constructor for class org.apache.activemq.store.kahadb.MessageDatabase.LastAckMarshaller

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(LinkedNodeList<T>) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNode

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

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

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

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

load(long, Marshaller<T>) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction

Loads a page from disk.

load(Location) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

Loads a previously stored JournalMessage

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(Page<T>, Marshaller<T>) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction

Loads a page from disk.

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(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(Transaction) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData

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(int, int) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.Location

Location(Location) - 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

LTEVisitor(Key) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.LTEVisitor

LTVisitor(Key) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.LTVisitor

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

Marshaller() - Constructor for class org.apache.activemq.store.kahadb.disk.util.SequenceSet.Marshaller

Marshaller(BTreeIndex<Key, Value>) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeNode.Marshaller

matched(Key, Value) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.PredicateVisitor

matchType(Destination, KahaDestination.DestinationType) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

Determine whether this Destination matches the DestinationType

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

merge(SequenceSet) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet

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.MessageKeysMarshaller - Class in org.apache.activemq.store.kahadb

MessageDatabase.MessageStoreStatisticsMarshaller - Class in org.apache.activemq.store.kahadb

MessageDatabase.Metadata - Class in org.apache.activemq.store.kahadb

MessageDatabase.PurgeRecoveredXATransactionStrategy - Enum in org.apache.activemq.store.kahadb

MessageDatabase.StoredDestinationMarshaller - Class in org.apache.activemq.store.kahadb

MessageKeysMarshaller() - Constructor for class org.apache.activemq.store.kahadb.MessageDatabase.MessageKeysMarshaller

MessageKeysMarshaller() - Constructor for class org.apache.activemq.store.kahadb.TempMessageDatabase.MessageKeysMarshaller

messageSize() - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

MessageStoreStatisticsMarshaller() - Constructor for class org.apache.activemq.store.kahadb.MessageDatabase.MessageStoreStatisticsMarshaller

metadata - Variable in class org.apache.activemq.store.kahadb.MessageDatabase

Metadata() - Constructor for class org.apache.activemq.store.kahadb.MessageDatabase.Metadata

MetaData() - Constructor for class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData

MetaData(PListStoreImpl) - Constructor for class org.apache.activemq.store.kahadb.plist.PListStoreImpl.MetaData

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

N

nameFromDestinationFilter(ActiveMQDestination) - Static method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

NEVER - org.apache.activemq.store.kahadb.disk.journal.Journal.JournalDiskSyncStrategy

NEVER - org.apache.activemq.store.kahadb.MessageDatabase.PurgeRecoveredXATransactionStrategy

next - Variable in class org.apache.activemq.store.kahadb.disk.util.LinkedNode

NodeMarshaller(Marshaller<Key>, Marshaller<Value>) - Constructor for class org.apache.activemq.store.kahadb.disk.index.ListNode.NodeMarshaller

NONE - org.apache.activemq.store.kahadb.disk.journal.Journal.PreallocationScope

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

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

onLoad(ListNode<String, Location>, Transaction) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

onLoad(ListNode<Key, Value>, Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex

onRemove(Map.Entry<String, Location>) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

onRemove(Map.Entry<Key, Value>) - 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

OrVisitor(List<BTreeVisitor.Predicate<Key>>) - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.OrVisitor

OS_KERNEL_COPY - org.apache.activemq.store.kahadb.disk.journal.Journal.PreallocationStrategy

P

page - Variable in class org.apache.activemq.store.kahadb.MessageDatabase.Metadata

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

pageFile - Variable in class org.apache.activemq.store.kahadb.TempMessageDatabase

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.MetaData - Class in org.apache.activemq.store.kahadb.disk.page

The MetaData object hold the persistent data associated with a PageFile object.

PageOverflowIOException(String) - Constructor for exception org.apache.activemq.store.kahadb.disk.page.Transaction.PageOverflowIOException

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo

parseFramed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand

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

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand

parseFramed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand

parseFramed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId

parseFramed(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand

parseFramed(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo

parseUnframed(byte[]) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand

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

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand

parseUnframed(InputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestination

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaLocation

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo

parseUnframed(Buffer) - Static method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand

parseUnframed(Buffer) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - 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(CodedInputStream) - Static method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId

PERIODIC - org.apache.activemq.store.kahadb.disk.journal.Journal.JournalDiskSyncStrategy

persistCompletion(TransactionId) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore

persistenceAdapterStatistics - Variable in class org.apache.activemq.store.kahadb.MessageDatabase

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

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

PredicateVisitor() - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeVisitor.PredicateVisitor

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, OutputStream) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex

printStructure(Transaction, PrintWriter) - 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(KahaAddMessageCommand, Location, MessageDatabase.IndexAware) - 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(KahaRemoveDestinationCommand) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase

process(KahaRemoveDestinationCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

process(KahaRemoveMessageCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

process(KahaRewrittenDataFileCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

process(KahaRollbackCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

process(KahaSubscriptionCommand) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase

process(KahaSubscriptionCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

process(KahaUpdateMessageCommand, Location) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

process(Location, 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, KahaRemoveScheduledJobsCommand, Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl

Removes all scheduled jobs within a given time range.

process(Transaction, KahaRescheduleJobCommand, Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl

Reschedules a Job after it has be fired.

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(JournalCommand<?>, Location) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl

Called during recovery to allow the store to rebuild from scratch.

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

purgeRecoveredXATransactionStrategy - Variable in class org.apache.activemq.store.kahadb.MessageDatabase

purgeStoreOnStartup - Variable in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

put(Key, Value) - Method in class org.apache.activemq.util.LFUCache

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

putAll(Map<? extends Key, ? extends Value>) - Method in class org.apache.activemq.util.LFUCache

Q

QUEUE - org.apache.activemq.store.kahadb.data.KahaDestination.DestinationType

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() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream

Reads the next byte of data from this input stream.

read(byte[]) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile

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(byte[], int, int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile

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

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[]) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile

readFully(byte[], int, int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream

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

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(MessageRecoveryListener) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore

recover(TransactionRecoveryListener) - Method in class org.apache.activemq.store.kahadb.KahaDBTransactionStore

recover(TransactionRecoveryListener) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore

RecoverableRandomAccessFile - Class in org.apache.activemq.util

RecoverableRandomAccessFile(File, String) - Constructor for class org.apache.activemq.util.RecoverableRandomAccessFile

RecoverableRandomAccessFile(File, String, boolean) - 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

recoverMessageStoreStatistics() - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore

recoverMessageStoreStatistics() - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore

recoverNextMessages(int, MessageRecoveryListener) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore

recoverNextMessages(int, MessageRecoveryListener) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore

recoverRolledBackAcks(String, MessageDatabase.StoredDestination, Transaction, int, MessageRecoveryListener) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore

recoveryCheck(DataFile) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

referenceRemovedLocation(Transaction, Location, List<Integer>) - 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.

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(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(long) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

remove(long) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl

remove(Object) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

remove(Object) - Method in class org.apache.activemq.util.LFUCache

remove(String) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

remove(String) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl

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(Sequence) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet

remove(SequenceSet) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet

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, RandomAccessFile) - 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

Report() - Constructor for class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report

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() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream

restart() - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream

start using a fresh byte array

restart(byte[]) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream

reset the StoreByteArrayInputStream to use an new byte array

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(ByteSequence) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream

reset the StoreByteArrayInputStream to use an new ByteSequence

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

ROLLBACK - org.apache.activemq.store.kahadb.MessageDatabase.PurgeRecoveredXATransactionStrategy

rollbackTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

rollbackTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.KahaDBStore

rollbackTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

rollbackTransaction(ConnectionContext) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore

rolledBackAcksMap - Variable in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore

rotate() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList

Move the head to the tail and returns the new head node.

rotateTo(T) - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList

Move the head to the tail and returns the new head node.

rotateWriteFile() - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

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

Scheduler - Class in org.apache.activemq.store.kahadb.disk.util

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

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

setBatch(DataFileAppender.WriteBatch) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location

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

setCheckForCorruption(boolean) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

setCheckForCorruption(boolean) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore

setCheckForCorruptionOnStartup(boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

setCheckForCorruptJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setCheckForCorruptJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setCheckForCorruptJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setCheckpointInterval(long) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setCheckpointInterval(long) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Set the checkpointInterval

setCheckpointInterval(long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setChecksum(boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

setChecksum(int) - Method in class org.apache.activemq.store.kahadb.disk.page.Page

setChecksumJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setChecksumJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setChecksumJournalFiles(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setCleanShutdown(boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData

setCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

setCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Set the cleanupInterval

setCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

setCleanupOnStop(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setCleanupOnStop(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setCleanupOnStop(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setCompactAcksAfterNoGC(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Sets the number of GC cycles where no journal logs were removed before an attempt to move forward all the acks in the last log that contains them and is otherwise unreferenced.

setCompactAcksAfterNoGC(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

Sets the number of GC cycles where no journal logs were removed before an attempt to move forward all the acks in the last log that contains them and is otherwise unreferenced.

setCompactAcksIgnoresStoreGrowth(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Configure if Ack compaction will occur regardless of continued growth of the journal logs meaning that the store has not run out of space yet.

setCompactAcksIgnoresStoreGrowth(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

Configure if Ack compaction will occur regardless of continued growth of the journal logs meaning that the store has not run out of space yet.

setConcurrentStoreAndDispatchQueues(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setConcurrentStoreAndDispatchQueues(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBStore

setConcurrentStoreAndDispatchTopics(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setConcurrentStoreAndDispatchTopics(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBStore

setContainingList(ListIndex<Key, Value>) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode

setDatabaseLockedWaitDelay(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Deprecated.

use Locker.setLockAcquireSleepInterval(long) instead

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

Deprecated.

use KahaDBPersistenceAdapter.setJournalDiskSyncStrategy(java.lang.String) instead

setEnableJournalDiskSyncs(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

Deprecated.

use MessageDatabase.setEnableJournalDiskSyncs(boolean) instead

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.

setEnableSubscriptionStatistics(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Enable caching statistics for each subscription to allow non-blocking retrieval of metrics.

setEnableSubscriptionStatistics(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

Enable caching statistics for each subscription to allow non-blocking retrieval of metrics.

setEnableWriteThread(boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

setFailIfDatabaseIsLocked(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setFailIfDatabaseIsLocked(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setFailIfDatabaseIsLocked(boolean) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

setFailoverProducersAuditDepth(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

set the audit window depth for duplicate suppression (should exceed the max transaction batch)

setFailoverProducersAuditDepth(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setFilePrefix(String) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

setFileSuffix(String) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

setFileType(String) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData

setFileTypeVersion(String) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData

setFilteredPersistenceAdapters(List) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

Sets the FilteredKahaDBPersistenceAdapter entries

setFirst(long) - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence

setForceRecoverIndex(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setForceRecoverIndex(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setForceRecoverIndex(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBStore

setFreePages(long) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData

setHeadPageId(long) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex

setIgnoreMissingJournalfiles(boolean) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setIgnoreMissingJournalfiles(boolean) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Set the ignoreMissingJournalfiles

setIgnoreMissingJournalfiles(boolean) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setIndexCacheSize(int) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setIndexCacheSize(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Set the indexCacheSize When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used

setIndexCacheSize(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setIndexCacheSize(int) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

setIndexDirectory(File) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Sets the directory where KahaDB index files should be written.

setIndexDirectory(File) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setIndexDirectory(File) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

setIndexEnablePageCaching(boolean) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

setIndexLFUEvictionFactor(float) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setIndexLFUEvictionFactor(float) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setIndexLFUEvictionFactor(float) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setIndexPageSize(int) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

setIndexWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setIndexWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Set the indexWriteBatchSize When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used

setIndexWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setIndexWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

setIndexWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.TempMessageDatabase

setJournalCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

setJournalCleanupInterval(long) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore

setJournalDiskSyncInterval(long) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setJournalDiskSyncInterval(long) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setJournalDiskSyncStrategy(String) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setJournalDiskSyncStrategy(String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setJournalDiskSyncStrategy(Journal.JournalDiskSyncStrategy) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used

setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

Set the max file length of the transaction journal When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used

setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore

setJournalMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

setJournalMaxWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

setJournalMaxWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Set the journalMaxWriteBatchSize * When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used

setJournalMaxWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setJournalMaxWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore

setJournalMaxWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

setJournalWriteBatchSize(int) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBPersistenceAdapter

Set the max write batch size of the transaction journal When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used

setKeyMarshaller(Marshaller<Key>) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex

setKeyMarshaller(Marshaller<Key>) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

Set the marshaller for key objects

setKeyMarshaller(Marshaller<Key>) - Method in interface org.apache.activemq.store.kahadb.disk.index.Index

Set the marshaller for key objects

setKeyMarshaller(Marshaller<Key>) - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex

setLast(long) - Method in class org.apache.activemq.store.kahadb.disk.util.Sequence

setLastAppendLocation(Location) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

setLastTxId(long) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData

setLastUpdateLocation(Location) - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBMetaData

setLastUpdateLocation(Location) - Method in interface org.apache.activemq.store.kahadb.KahaDBMetaData

Updates the value of the last successful update.

setLazyInit(boolean) - Method in class org.apache.activemq.store.kahadb.plist.PListStoreImpl

setLegacyStoreArchiveDirectory(File) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl

Sets the directory where the legacy scheduler store files are archived before an update attempt is made.

setLength(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFile

setLength(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayInputStream

setLength(long) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile

setLFUEvictionFactor(float) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

setLoadFactor(int) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

setMaxAsyncJobs(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setMaxAsyncJobs(int) - Method in class org.apache.activemq.store.kahadb.KahaDBStore

setMaxFailoverProducersToTrack(int) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

Set the max number of producers (LRU cache) to track for duplicate sends

setMaxFailoverProducersToTrack(int) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setMaxFileLength(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

setMaximumBinCapacity() - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

setMaximumBinCapacity(int) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

setMemoryUsage(MemoryUsage) - Method in class org.apache.activemq.store.kahadb.KahaDBStore.KahaDBMessageStore

setMemoryUsage(MemoryUsage) - Method in class org.apache.activemq.store.kahadb.TempKahaDBStore.KahaDBMessageStore

setMetaDataTxId(long) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile.MetaData

setName(String) - Method in class org.apache.activemq.store.kahadb.plist.PListImpl

setName(String) - Method in class org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl

setNext(long) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeNode

setNext(long) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode

setOffset(int) - Method in class org.apache.activemq.store.kahadb.disk.journal.Location

setOptions(Object, String[]) - Static method in class org.apache.activemq.store.kahadb.disk.util.CommandLineSupport

Sets the properties of an object given the command line args.

setPage(Page<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 class org.apache.activemq.store.kahadb.AbstractKahaDBMetaData

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(String) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setPreallocationScope(String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

setPreallocationScope(Journal.PreallocationScope) - 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

setPreallocationStrategy(Journal.PreallocationStrategy) - Method in class org.apache.activemq.store.kahadb.disk.journal.Journal

setPrefixer(BTreeIndex.Prefixer<Key>) - Method in class org.apache.activemq.store.kahadb.disk.index.BTreeIndex

setPurgeRecoveredXATransactionStrategy(String) - Method in class org.apache.activemq.store.kahadb.KahaDBPersistenceAdapter

setPurgeRecoveredXATransactionStrategy(String) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

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 - Variable in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch

size - Variable in class org.apache.activemq.store.kahadb.disk.util.DiskBenchmark.Report

size() - Method in class org.apache.activemq.store.kahadb.AbstractKahaDBStore

size() - Method in class org.apache.activemq.store.kahadb.disk.index.ListIndex

size() - Method in class org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool

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

size(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

size(Transaction) - Method in class org.apache.activemq.store.kahadb.disk.index.ListNode

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

SPARSE_FILE - org.apache.activemq.store.kahadb.disk.journal.Journal.PreallocationStrategy

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(Page<T>, Marshaller<T>, boolean) - Method in class org.apache.activemq.store.kahadb.disk.page.Transaction

store(Transaction, HashBin<Key, Value>) - Method in class org.apache.activemq.store.kahadb.disk.index.HashIndex

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<?>) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

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<?>, 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(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.

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<?>, Runnable) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

storeCache - Variable in class org.apache.activemq.store.kahadb.MessageDatabase

This is a map to cache MessageStores for a specific KahaDestination key

StoredDestinationMarshaller() - Constructor for class org.apache.activemq.store.kahadb.MessageDatabase.StoredDestinationMarshaller

StoredDestinationMarshaller() - Constructor for class org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestinationMarshaller

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, boolean) - Method in class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender

storeItem(ByteSequence, byte, Runnable) - Method in interface org.apache.activemq.store.kahadb.disk.journal.FileAppender

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

StoreTaskExecutor(int, int, long, TimeUnit, BlockingQueue<Runnable>, ThreadFactory) - Constructor for class org.apache.activemq.store.kahadb.KahaDBStore.StoreTaskExecutor

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

StringPrefixer() - Constructor for class org.apache.activemq.store.kahadb.disk.index.BTreeIndex.StringPrefixer

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

TEMP_QUEUE - org.apache.activemq.store.kahadb.data.KahaDestination.DestinationType

TEMP_TOPIC - org.apache.activemq.store.kahadb.data.KahaDestination.DestinationType

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

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.StoredDestinationMarshaller - Class in org.apache.activemq.store.kahadb

toArrayList() - Method in class org.apache.activemq.store.kahadb.disk.util.LinkedNodeList

Copies the nodes of the LinkedNodeList to an ArrayList.

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

Creates a new ByteSequence that represents the marshaled form of the given Journal Command.

toByteSequence(JournalCommand<?>) - Method in class org.apache.activemq.store.kahadb.MessageDatabase

toOffset(long) - Method in class org.apache.activemq.store.kahadb.disk.page.PageFile

TOPIC - org.apache.activemq.store.kahadb.data.KahaDestination.DestinationType

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

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand

toString() - 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() - 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() - Method in class org.apache.activemq.store.kahadb.data.KahaLocation

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo

toString() - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand

toString() - 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

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaAddMessageCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaAddScheduledJobCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaCommitCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaDestination

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaDestroySchedulerCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaLocalTransactionId

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaLocation

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaPrepareCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRemoveScheduledJobsCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRescheduleJobCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaRollbackCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaTraceCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaTransactionInfo

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand

toString(StringBuilder, String) - Method in class org.apache.activemq.store.kahadb.data.KahaXATransactionId

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

trackRecoveredAcks(ArrayList<MessageAck>) - Method in class org.apache.activemq.store.kahadb.KahaDBStore

trackStore(TransactionStore) - Method in class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore.Tx

trackStore(TransactionStore, XATransactionId) - 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.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.

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

Tx() - Constructor for class org.apache.activemq.store.kahadb.KahaDBTransactionStore.Tx

Tx() - Constructor for class org.apache.activemq.store.kahadb.MultiKahaDBTransactionStore.Tx

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(String) - Constructor for exception org.apache.activemq.store.kahadb.scheduler.UnknownStoreVersionException

UnknownStoreVersionException(Throwable) - 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() - 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

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

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(int) - 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.KahaEntryType

Returns the enum constant of this type with the specified name.

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(String) - Static method in enum org.apache.activemq.store.kahadb.data.KahaEntryType

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

valueOf(String) - Static method in enum org.apache.activemq.store.kahadb.MessageDatabase.PurgeRecoveredXATransactionStrategy

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() - Static method in enum org.apache.activemq.store.kahadb.MessageDatabase.PurgeRecoveredXATransactionStrategy

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(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(KahaAckMessageFileMapCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaAddMessageCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaAddScheduledJobCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaCommitCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaDestroySchedulerCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaPrepareCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaProducerAuditCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaRemoveDestinationCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaRemoveMessageCommand) - 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(KahaRescheduleJobCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaRewrittenDataFileCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaRollbackCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaSubscriptionCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaTraceCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

visit(KahaUpdateMessageCommand) - Method in class org.apache.activemq.store.kahadb.Visitor

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(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(Visitor) - Method in interface org.apache.activemq.store.kahadb.JournalCommand

Visitor - Class in org.apache.activemq.store.kahadb

Visitor() - Constructor for class org.apache.activemq.store.kahadb.Visitor

W

write(byte[]) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile

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(byte[], int, int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile

write(int) - Method in class org.apache.activemq.store.kahadb.disk.util.DataByteArrayOutputStream

Writes the specified byte to this byte array output stream.

write(int) - Method in class org.apache.activemq.util.RecoverableRandomAccessFile

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

WriteBatch(DataFile, int) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch

WriteBatch(DataFile, int, Journal.WriteCommand) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender.WriteBatch

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

WriteCommand(Location, ByteSequence, boolean) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.Journal.WriteCommand

WriteCommand(Location, ByteSequence, Runnable) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.Journal.WriteCommand

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

WriteKey(Location) - Constructor for class org.apache.activemq.store.kahadb.disk.journal.Journal.WriteKey

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(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(Long, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.util.LongMarshaller

writePayload(String, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.util.StringMarshaller

Write the payload of this entry to the RawContainer

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(Location, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.util.LocationMarshaller

writePayload(SequenceSet, DataOutput) - Method in class org.apache.activemq.store.kahadb.disk.util.SequenceSet.Marshaller

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

writePayload(MessageStoreStatistics, DataOutput) - Method in class org.apache.activemq.store.kahadb.MessageDatabase.MessageStoreStatisticsMarshaller

writePayload(T, DataOutput) - Method in interface org.apache.activemq.store.kahadb.disk.util.Marshaller

Write the payload of the object to the DataOutput stream.

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

Z

ZEROS - org.apache.activemq.store.kahadb.disk.journal.Journal.PreallocationStrategy

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