Index (ActiveMQ :: JDBC Store 5.11.0.redhat-630371 API)

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

A

AbstractJDBCLocker - Class in org.apache.activemq.store.jdbc
AbstractJDBCLocker() - Constructor for class org.apache.activemq.store.jdbc.AbstractJDBCLocker
acknowledge(TopicMessageStore, String, String, MessageId, MessageAck) - Method in class org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore
acknowledge(ConnectionContext, String, String, MessageId, MessageAck) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
acknowledge(ConnectionContext, String, String, MessageId, MessageAck) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
acknowledge(MessageId, RecordLocation, SubscriptionKey) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
acknowledge(JournalTopicMessageStore, JournalTopicAck, RecordLocation) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
acksPkName - Variable in class org.apache.activemq.store.jdbc.adapter.PostgresqlJDBCAdapter
adapter - Variable in class org.apache.activemq.store.jdbc.JDBCMessageStore
add(JournalMessageStore, Message) - Method in class org.apache.activemq.store.journal.JournalTransactionStore.Tx
add(JournalMessageStore, MessageAck) - Method in class org.apache.activemq.store.journal.JournalTransactionStore.Tx
add(JournalTopicMessageStore, JournalTopicAck) - Method in class org.apache.activemq.store.journal.JournalTransactionStore.Tx
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.journal.JournalMessageStore: Not synchronized since the Journal has better throughput if you increase the number of concurrent writes that it is doing.
addMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
addMessageReference(ConnectionContext, MessageId, long, String) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
addMessageReference(ConnectionContext, MessageId, long, String) - Method in class org.apache.activemq.store.journal.JournalMessageStore
addSubscription(SubscriptionInfo, boolean) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
addSubscription(SubscriptionInfo, boolean) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
allowIOResumption() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
allowIOResumption() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
audit - Variable in class org.apache.activemq.store.jdbc.JDBCMessageStore
audit - Variable in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
auditRecoveryDepth - Variable in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
AxionJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: Axion specific Adapter.
AxionJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.AxionJDBCAdapter

B

batchStatments - Variable in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
BDB - Static variable in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter
begin() - Method in class org.apache.activemq.store.jdbc.TransactionContext
beginTransaction(ConnectionContext) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
beginTransaction(ConnectionContext) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
binaryDataType - Variable in class org.apache.activemq.store.jdbc.Statements
BlobJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: This JDBCAdapter inserts and extracts BLOB data using the getBlob()/setBlob() operations.
BlobJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.BlobJDBCAdapter
BytesJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: This JDBCAdapter inserts and extracts BLOB data using the setBytes()/getBytes() operations.
BytesJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.BytesJDBCAdapter

C

checkpoint(boolean) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
checkpoint() - Method in class org.apache.activemq.store.journal.JournalMessageStore
checkpoint(Callback) - Method in class org.apache.activemq.store.journal.JournalMessageStore
checkpoint(boolean, boolean) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter: When we checkpoint we move all the journalled data to long term storage.
checkpoint(boolean) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
checkpoint() - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
checkpoint() - Method in class org.apache.activemq.store.journal.JournalTransactionStore
cleanup() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
close(Connection) - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
close(Statement) - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
close(PreparedStatement) - Static method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
close(ResultSet) - Static method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
close() - Method in class org.apache.activemq.store.jdbc.TransactionContext
closeDataSource(DataSource) - Method in class org.apache.activemq.store.jdbc.DataSourceServiceSupport
commit() - Method in class org.apache.activemq.store.jdbc.TransactionContext
commit(TransactionId, boolean, Runnable, Runnable) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
commitAdd(ConnectionContext, MessageId, long, long) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
commitLastAck(ConnectionContext, long, long, ActiveMQDestination, String, String) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
commitRemove(ConnectionContext, MessageAck) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
commitTransaction(ConnectionContext) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
complete(String, String) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
configure(PersistenceAdapter) - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
connection - Variable in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
containerNameDataType - Variable in class org.apache.activemq.store.jdbc.Statements
createAdapter() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
createDataSource(String) - Static method in class org.apache.activemq.store.jdbc.DataSourceServiceSupport
createDataSource(String, String) - Static method in class org.apache.activemq.store.jdbc.DataSourceServiceSupport
createDefaultLocker() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
createDefaultLocker() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
createJobSchedulerStore() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
createJobSchedulerStore() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
createJournal() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
createMessageAudit() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
createPersistenceAdapter() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
createQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
createRecoveryFailedException(Exception) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
createTablesOnStartup - Variable in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
createTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
createTransactionStore() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
createTransactionStore() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
createWriteException(DataStructure, Exception) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
createWriteException(String, Exception) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter

D

data - Variable in class org.apache.activemq.store.journal.JournalTransactionStore.TxOperation
DatabaseLocker - Interface in org.apache.activemq.store.jdbc: Deprecated.
As of 5.7.0, use more general Locker instead
dataSource - Variable in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
DataSourceServiceSupport - Class in org.apache.activemq.store.jdbc: A helper class which provides a factory method to create a default {@link DataSource) if one is not provided.
DataSourceServiceSupport() - Constructor for class org.apache.activemq.store.jdbc.DataSourceServiceSupport
DataSourceServiceSupport(DataSource) - Constructor for class org.apache.activemq.store.jdbc.DataSourceServiceSupport
DB2JDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter
DB2JDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.DB2JDBCAdapter
DEFAULT_LOCK_KEEP_ALIVE_PERIOD - Static variable in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
DefaultDatabaseLocker - Class in org.apache.activemq.store.jdbc: Represents an exclusive lock on a database to avoid multiple brokers running against the same logical database.
DefaultDatabaseLocker() - Constructor for class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
DefaultJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.
DefaultJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
deleteAllMessages() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
deleteAllMessages() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
deleteSubscription(String, String) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
deleteSubscription(String, String) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
determineTimeDifference(Connection) - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
diffFromCurrentTime - Variable in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
doAddMessage(TransactionContext, long, MessageId, ActiveMQDestination, byte[], long, byte, XATransactionId) - Method in class org.apache.activemq.store.jdbc.adapter.BlobJDBCAdapter
doAddMessage(TransactionContext, long, MessageId, ActiveMQDestination, byte[], long, byte, XATransactionId) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter: A non null xid indicated the op is part of 2pc prepare, so ops are flagged pending outcome
doAddMessage(TransactionContext, long, MessageId, ActiveMQDestination, byte[], long, byte, XATransactionId) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doAddMessageReference(TransactionContext, long, MessageId, ActiveMQDestination, long, String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doAddMessageReference(TransactionContext, long, MessageId, ActiveMQDestination, long, String) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doCheckpoint() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter: This does the actual checkpoint.
doClearLastAck(TransactionContext, ActiveMQDestination, byte, String, String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doClearLastAck(TransactionContext, ActiveMQDestination, byte, String, String) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doCommitAddOp(TransactionContext, long, long) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doCommitAddOp(TransactionContext, long, long) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doCreateTables(TransactionContext) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doCreateTables(TransactionContext) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doDeleteOldMessages(TransactionContext) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doDeleteOldMessages(TransactionContext) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doDeleteSubscription(TransactionContext, ActiveMQDestination, String, String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doDeleteSubscription(TransactionContext, ActiveMQDestination, String, String) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doDropTables(TransactionContext) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doDropTables(TransactionContext) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doGetAllSubscriptions(TransactionContext, ActiveMQDestination) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doGetAllSubscriptions(TransactionContext, ActiveMQDestination) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doGetDestinations(TransactionContext) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doGetDestinations(TransactionContext) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doGetDurableSubscriberMessageCount(TransactionContext, ActiveMQDestination, String, String, boolean) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doGetDurableSubscriberMessageCount(TransactionContext, ActiveMQDestination, String, String, boolean) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doGetLastAckedDurableSubscriberMessageId(TransactionContext, ActiveMQDestination, String, String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doGetLastAckedDurableSubscriberMessageId(TransactionContext, ActiveMQDestination, String, String) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doGetLastMessageStoreSequenceId(TransactionContext) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doGetLastMessageStoreSequenceId(TransactionContext) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doGetLastProducerSequenceId(TransactionContext, ProducerId) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doGetLastProducerSequenceId(TransactionContext, ProducerId) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doGetMessage(TransactionContext, MessageId) - Method in class org.apache.activemq.store.jdbc.adapter.BlobJDBCAdapter
doGetMessage(TransactionContext, MessageId) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doGetMessage(TransactionContext, MessageId) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doGetMessageById(TransactionContext, long) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doGetMessageById(TransactionContext, long) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doGetMessageCount(TransactionContext, ActiveMQDestination) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doGetMessageCount(TransactionContext, ActiveMQDestination) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doGetMessageReference(TransactionContext, long) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doGetMessageReference(TransactionContext, long) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doGetSubscriberEntry(TransactionContext, ActiveMQDestination, String, String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doGetSubscriberEntry(TransactionContext, ActiveMQDestination, String, String) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doMessageIdScan(TransactionContext, int, JDBCMessageIdScanListener) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doMessageIdScan(TransactionContext, int, JDBCMessageIdScanListener) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doRecordDestination(TransactionContext, ActiveMQDestination) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doRecordDestination(TransactionContext, ActiveMQDestination) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doRecover(TransactionContext, ActiveMQDestination, JDBCMessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doRecover(TransactionContext, ActiveMQDestination, JDBCMessageRecoveryListener) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doRecoverNextMessages(TransactionContext, ActiveMQDestination, String, String, long, long, int, JDBCMessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doRecoverNextMessages(TransactionContext, ActiveMQDestination, long[], long, int, boolean, JDBCMessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doRecoverNextMessages(TransactionContext, ActiveMQDestination, String, String, long, long, int, JDBCMessageRecoveryListener) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doRecoverNextMessages(TransactionContext, ActiveMQDestination, long[], long, int, boolean, JDBCMessageRecoveryListener) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doRecoverNextMessagesWithPriority(TransactionContext, ActiveMQDestination, String, String, long, long, int, JDBCMessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doRecoverNextMessagesWithPriority(TransactionContext, ActiveMQDestination, String, String, long, long, int, JDBCMessageRecoveryListener) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doRecoverPreparedOps(TransactionContext, JdbcMemoryTransactionStore) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doRecoverPreparedOps(TransactionContext, JdbcMemoryTransactionStore) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doRecoverSubscription(TransactionContext, ActiveMQDestination, String, String, JDBCMessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doRecoverSubscription(TransactionContext, ActiveMQDestination, String, String, JDBCMessageRecoveryListener) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doRemoveAllMessages(TransactionContext, ActiveMQDestination) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doRemoveAllMessages(TransactionContext, ActiveMQDestination) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doRemoveMessage(TransactionContext, long, XATransactionId) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter: A non null xid indicated the op is part of 2pc prepare, so ops are flagged pending outcome
doRemoveMessage(TransactionContext, long, XATransactionId) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doSetLastAck(TransactionContext, ActiveMQDestination, XATransactionId, String, String, long, long) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doSetLastAck(TransactionContext, ActiveMQDestination, XATransactionId, String, String, long, long) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doSetLastAckWithPriority(TransactionContext, ActiveMQDestination, XATransactionId, String, String, long, long) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doSetLastAckWithPriority(TransactionContext, ActiveMQDestination, XATransactionId, String, String, long, long) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doSetSubscriberEntry(TransactionContext, SubscriptionInfo, boolean, boolean) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doSetSubscriberEntry(TransactionContext, SubscriptionInfo, boolean, boolean) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
doStart() - Method in class org.apache.activemq.store.jdbc.adapter.TransactDatabaseLocker
doStart() - Method in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
doStart() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
doStart() - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
doStart() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
doStop(ServiceStopper) - Method in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
doStop(ServiceStopper) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
doStop(ServiceStopper) - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
doStop(ServiceStopper) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
doUpdateMessage(TransactionContext, ActiveMQDestination, MessageId, byte[]) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
doUpdateMessage(TransactionContext, ActiveMQDestination, MessageId, byte[]) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
dumpTables(Connection, String, String, String) - Static method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
dumpTables(Connection) - Static method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
durableSubAcksTableName - Variable in class org.apache.activemq.store.jdbc.Statements

E

enableAudit - Variable in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
exceptionHandler - Variable in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
executeBatch() - Method in class org.apache.activemq.store.jdbc.TransactionContext

G

GenerateJDBCStatements - Class in org.apache.activemq.util
GenerateJDBCStatements() - Constructor for class org.apache.activemq.util.GenerateJDBCStatements
getAcks() - Method in class org.apache.activemq.store.journal.JournalTransactionStore.Tx
getAdapter() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getAdapter() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
getAddMessageStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getAddMessageStatement() - Method in class org.apache.activemq.store.jdbc.TransactionContext
getAllSubscriptions() - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
getAllSubscriptions() - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
getAuditRecoveryDepth() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getBinaryData(ResultSet, int) - Method in class org.apache.activemq.store.jdbc.adapter.BytesJDBCAdapter
getBinaryData(ResultSet, int) - Method in class org.apache.activemq.store.jdbc.adapter.DB2JDBCAdapter
getBinaryData(ResultSet, int) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
getBinaryData(ResultSet, int) - Method in class org.apache.activemq.store.jdbc.adapter.OracleBlobJDBCAdapter
getBinaryData(ResultSet, int) - Method in class org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter
getBinaryDataType() - Method in class org.apache.activemq.store.jdbc.Statements
getBrokerService() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getCachedStoreSequenceId(TransactionContext, ActiveMQDestination, MessageId) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
getCheckpointInterval() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
getCheckpointInterval() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
getCleanupPeriod() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getClearDurableLastAckInTxStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getClearXidFlagStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getConnection() - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
getConnection() - Method in class org.apache.activemq.store.jdbc.TransactionContext
getContainerNameDataType() - Method in class org.apache.activemq.store.jdbc.Statements
getCreateDurableSubStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getCreateLockSchemaStatements() - Method in class org.apache.activemq.store.jdbc.Statements
getCreateSchemaStatements() - Method in class org.apache.activemq.store.jdbc.Statements
getCurrentDateTime() - Method in class org.apache.activemq.store.jdbc.Statements
getDatabaseLocker() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: Deprecated.
as of 5.7.0, replaced by LockableServiceSupport.getLocker()
getDataDirectory() - Method in class org.apache.activemq.store.jdbc.DataSourceServiceSupport
getDataDirectoryFile() - Method in class org.apache.activemq.store.jdbc.DataSourceServiceSupport
getDataSource() - Method in class org.apache.activemq.store.jdbc.DataSourceServiceSupport
getDeleteOldMessagesStatementWithPriority() - Method in class org.apache.activemq.store.jdbc.Statements
getDeleteSubscriptionStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getDestinationMessageCountStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getDestinations() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getDestinations() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
getDirectory() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getDirectory() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
getDropAckPKAlterStatementEnd() - Method in class org.apache.activemq.store.jdbc.Statements
getDropSchemaStatements() - Method in class org.apache.activemq.store.jdbc.Statements
getDurableSubAcksTableName() - Method in class org.apache.activemq.store.jdbc.Statements
getDurableSubscriberMessageCountStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getDurableSubscriberMessageCountStatementWithPriority() - Method in class org.apache.activemq.store.jdbc.Statements
getEngineType() - Method in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter
getExceptionHandler() - Method in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
getExclusiveConnection() - Method in class org.apache.activemq.store.jdbc.TransactionContext
getFindAcksPendingOutcomeStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindAllDestinationsStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindAllDurableSubMessagesStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindAllDurableSubsStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindAllMessageIdsStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindAllMessagesStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindDurableSubMessagesByPriorityStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindDurableSubMessagesStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindDurableSubStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindLastSequenceIdInAcksStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindLastSequenceIdInMsgsStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindMessageByIdStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindMessageSequenceIdStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindMessageStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindNextMessagesByPriorityStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindNextMessagesStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindOpsPendingOutcomeStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFindXidByIdStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getFullAckTableName() - Method in class org.apache.activemq.store.jdbc.Statements
getFullLockTableName() - Method in class org.apache.activemq.store.jdbc.Statements
getFullMessageTableName() - Method in class org.apache.activemq.store.jdbc.Statements
getInsertDurablePriorityAckStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getJdbcAdapter() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
getJournal() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
getJournalArchiveDirectory() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
getJournalLogFiles() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
getJournalLogFileSize() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
getJournalThreadPriority() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
getLastAckedDurableSubscriberMessageStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getLastMessageBrokerSequenceId() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getLastMessageBrokerSequenceId() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
getLastProducerSequenceId(ProducerId) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getLastProducerSequenceId(ProducerId) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
getLastProducerSequenceIdStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getLeaseHolderId() - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
getLeaseObtainStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getLeaseOwnerStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getLeaseUpdateStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getLockAcquireSleepInterval() - Method in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
getLockCreateStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getLockDataSource() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getLockTableName() - Method in class org.apache.activemq.store.jdbc.Statements
getLockUpdateStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getLongDataType() - Method in class org.apache.activemq.store.jdbc.Statements
getLongTermMessageStore() - Method in class org.apache.activemq.store.journal.JournalMessageStore
getLongTermPersistence() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
getLongTermTopicMessageStore() - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
getMaxAllowableDiffFromDBTime() - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
getMaxAuditDepth() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getMaxCheckpointMessageAddSize() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
getMaxCheckpointWorkers() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
getMaxProducersToAudit() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getMaxRows() - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
getMaxRows() - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
getMaxRows() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getMessage(MessageId) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
getMessage(MessageId) - Method in class org.apache.activemq.store.journal.JournalMessageStore
getMessageCount() - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
getMessageCount(String, String) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
getMessageCount() - Method in class org.apache.activemq.store.journal.JournalMessageStore
getMessageCount(String, String) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
getMessageReference(MessageId) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
getMessageReference(MessageId) - Method in class org.apache.activemq.store.journal.JournalMessageStore
getMessages() - Method in class org.apache.activemq.store.journal.JournalTransactionStore.Tx
getMessageTableName() - Method in class org.apache.activemq.store.jdbc.Statements
getMsgIdDataType() - Method in class org.apache.activemq.store.jdbc.Statements
getNextDurableSubscriberMessageStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getNextSequenceId() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getOperations() - Method in class org.apache.activemq.store.journal.JournalTransactionStore.Tx
getQueryTimeout() - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
getRemoveAllMessagesStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getRemoveAllSubscriptionsStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getRemovedMessageStatement() - Method in class org.apache.activemq.store.jdbc.TransactionContext
getRemoveMessageStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getScheduledThreadPoolExecutor() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getSelectDurablePriorityAckStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getSequenceDataType() - Method in class org.apache.activemq.store.jdbc.Statements
getStatements() - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
getStatements() - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
getStatements() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getStatements() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
getStoreSequenceId(TransactionContext, ActiveMQDestination, MessageId) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
getStoreSequenceId(TransactionContext, ActiveMQDestination, MessageId) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
getStringIdDataType() - Method in class org.apache.activemq.store.jdbc.Statements
getSubscriptionKey(String, String) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
getTablePrefix() - Method in class org.apache.activemq.store.jdbc.Statements
getTaskRunnerFactory() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
getTransactionContext(ConnectionContext) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getTransactionContext() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getTransactionStore() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
getTx(Object, RecordLocation) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
getTypeStatement() - Method in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter
getUpdateDurableLastAckInTxStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getUpdateDurableLastAckStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getUpdateDurableLastAckWithPriorityInTxStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getUpdateDurableLastAckWithPriorityStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getUpdateLastAckStatement() - Method in class org.apache.activemq.store.jdbc.TransactionContext
getUpdateLastPriorityAckRowOfDurableSubStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getUpdateMessageStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getUpdateXidFlagStatement() - Method in class org.apache.activemq.store.jdbc.Statements
getUsageManager() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
getWireFormat() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
getWireFormat() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter

H

handleStartException - Variable in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
hasLockOwnership() - Method in class org.apache.activemq.store.jdbc.JDBCIOExceptionHandler: Deprecated.
HEAP - Static variable in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter
HsqldbJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter
HsqldbJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.HsqldbJDBCAdapter

I

ImageBasedJDBCAdaptor - Class in org.apache.activemq.store.jdbc.adapter: Provides JDBCAdapter since that uses IMAGE datatype to hold binary data.
ImageBasedJDBCAdaptor() - Constructor for class org.apache.activemq.store.jdbc.adapter.ImageBasedJDBCAdaptor
inFlightTxLocations - Variable in class org.apache.activemq.store.journal.JournalMessageStore
InformixJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: JDBC Adapter for Informix database.
InformixJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.InformixJDBCAdapter
init() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
init() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
initSequenceIdGenerator() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
initTimeDiff(Connection) - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
INNODB - Static variable in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter
ISAM - Static variable in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter
isBatchStatements() - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
isBatchStatments() - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
isChangeAutoCommitAllowed() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
isCreateTablesOnStartup() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
isCreateTablesOnStartup() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
isDoingRecover() - Method in class org.apache.activemq.store.journal.JournalTransactionStore
isEnableAudit() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
isHandleStartException() - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
isUseDedicatedTaskRunner() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
isUseExternalMessageReferences() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
isUseExternalMessageReferences() - Method in class org.apache.activemq.store.jdbc.Statements
isUseExternalMessageReferences() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
isUseJournal() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
isUseLockCreateWhereClause() - Method in class org.apache.activemq.store.jdbc.Statements
isUseQuickJournal() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory

J

jdbcAdapter - Variable in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
JDBCAdapter - Interface in org.apache.activemq.store.jdbc
JDBCIOExceptionHandler - Class in org.apache.activemq.store.jdbc: Deprecated.
JDBCIOExceptionHandler() - Constructor for class org.apache.activemq.store.jdbc.JDBCIOExceptionHandler: Deprecated.
JdbcMemoryTransactionStore - Class in org.apache.activemq.store.jdbc: respect 2pc prepare uses local transactions to maintain prepared state xid column provides transaction flag for additions and removals a commit clears that context and completes the work a rollback clears the flag and removes the additions Essentially a prepare is an insert &| update transaction commit|rollback is an update &| remove
JdbcMemoryTransactionStore(JDBCPersistenceAdapter) - Constructor for class org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore
JDBCMessageIdScanListener - Interface in org.apache.activemq.store.jdbc
JDBCMessageRecoveryListener - Interface in org.apache.activemq.store.jdbc
JDBCMessageStore - Class in org.apache.activemq.store.jdbc
JDBCMessageStore(JDBCPersistenceAdapter, JDBCAdapter, WireFormat, ActiveMQDestination, ActiveMQMessageAudit) - Constructor for class org.apache.activemq.store.jdbc.JDBCMessageStore
JDBCPersistenceAdapter - Class in org.apache.activemq.store.jdbc: A PersistenceAdapter implementation using JDBC for persistence storage.
JDBCPersistenceAdapter() - Constructor for class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
JDBCPersistenceAdapter(DataSource, WireFormat) - Constructor for class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
JDBCTopicMessageStore - Class in org.apache.activemq.store.jdbc
JDBCTopicMessageStore(JDBCPersistenceAdapter, JDBCAdapter, WireFormat, ActiveMQTopic, ActiveMQMessageAudit) - Constructor for class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
JournalMessageStore - Class in org.apache.activemq.store.journal: A MessageStore that uses a Journal to store it's messages.
JournalMessageStore(JournalPersistenceAdapter, MessageStore, ActiveMQDestination) - Constructor for class org.apache.activemq.store.journal.JournalMessageStore
JournalPersistenceAdapter - Class in org.apache.activemq.store.journal: An implementation of PersistenceAdapter designed for use with a Journal and then check pointing asynchronously on a timeout with some other long term persistent storage.
JournalPersistenceAdapter() - Constructor for class org.apache.activemq.store.journal.JournalPersistenceAdapter
JournalPersistenceAdapter(Journal, PersistenceAdapter, TaskRunnerFactory) - Constructor for class org.apache.activemq.store.journal.JournalPersistenceAdapter
JournalPersistenceAdapterFactory - Class in org.apache.activemq.store.journal: Factory class that can create PersistenceAdapter objects.
JournalPersistenceAdapterFactory() - Constructor for class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
JournalTopicMessageStore - Class in org.apache.activemq.store.journal: A MessageStore that uses a Journal to store it's messages.
JournalTopicMessageStore(JournalPersistenceAdapter, TopicMessageStore, ActiveMQTopic) - Constructor for class org.apache.activemq.store.journal.JournalTopicMessageStore
JournalTransactionStore - Class in org.apache.activemq.store.journal
JournalTransactionStore(JournalPersistenceAdapter) - Constructor for class org.apache.activemq.store.journal.JournalTransactionStore
JournalTransactionStore.Tx - Class in org.apache.activemq.store.journal: Operations
JournalTransactionStore.Tx(RecordLocation) - Constructor for class org.apache.activemq.store.journal.JournalTransactionStore.Tx
JournalTransactionStore.TxOperation - Class in org.apache.activemq.store.journal
JournalTransactionStore.TxOperation(byte, JournalMessageStore, Object) - Constructor for class org.apache.activemq.store.journal.JournalTransactionStore.TxOperation

K

keepAlive() - Method in interface org.apache.activemq.store.jdbc.DatabaseLocker: Deprecated.

Used by a timer to keep alive the lock.
keepAlive() - Method in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
keepAlive() - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker

L

lastLocation - Variable in class org.apache.activemq.store.journal.JournalMessageStore
LeaseDatabaseLocker - Class in org.apache.activemq.store.jdbc: Represents an exclusive lease on a database to avoid multiple brokers running against the same logical database.
LeaseDatabaseLocker() - Constructor for class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
leaseHolderId - Variable in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
limitQuery(String) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
limitQuery(String) - Method in class org.apache.activemq.store.jdbc.adapter.OracleJDBCAdapter
limitQuery(String) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
lockCreateStatement - Variable in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
lockTableName - Variable in class org.apache.activemq.store.jdbc.Statements
lockUpdateStatement - Variable in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
log(String, SQLException) - Static method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
longDataType - Variable in class org.apache.activemq.store.jdbc.Statements
longTermStore - Variable in class org.apache.activemq.store.journal.JournalMessageStore
lookupSubscription(String, String) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
lookupSubscription(String, String) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore

M

main(String[]) - Static method in class org.apache.activemq.util.GenerateJDBCStatements
MAX_ROWS - Static variable in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
maxAllowableDiffFromDBTime - Variable in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
maxAuditDepth - Variable in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
MaxDBJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: JDBC Adapter for the MaxDB database.
MaxDBJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.MaxDBJDBCAdapter
maxProducersToAudit - Variable in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
maxRows - Variable in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
maxRows - Variable in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
MERGE - Static variable in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter
messageId(MessageId) - Method in interface org.apache.activemq.store.jdbc.JDBCMessageIdScanListener
messageTableName - Variable in class org.apache.activemq.store.jdbc.Statements
msgIdDataType - Variable in class org.apache.activemq.store.jdbc.Statements
MYISAM - Static variable in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter
MySqlJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter
MySqlJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter

N

NDBCLUSTER - Static variable in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter

O

onAdd(Message, long, byte) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
onAdd(Message, long, byte) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
onCompletion(Runnable) - Method in class org.apache.activemq.store.jdbc.TransactionContext
onRecovered(MemoryTransactionStore.Tx) - Method in class org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore
onUsageChanged(Usage, int, int) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
operationType - Variable in class org.apache.activemq.store.journal.JournalTransactionStore.TxOperation
OracleBlobJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.
OracleBlobJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.OracleBlobJDBCAdapter
OracleJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.
OracleJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.OracleJDBCAdapter
org.apache.activemq.store.jdbc - package org.apache.activemq.store.jdbc: Message persistence implemented using JDBC
org.apache.activemq.store.jdbc.adapter - package org.apache.activemq.store.jdbc.adapter: Implements database/driver apapters to compensate for the wide differences in the BLOB handing of JDBC drivers.
org.apache.activemq.store.journal - package org.apache.activemq.store.journal: Message persistence using a high performance transaction log via the Journal interface.
org.apache.activemq.util - package org.apache.activemq.util
overflowNotification(RecordLocation) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter: The Journal give us a call back so that we can move old data out of the journal.

P

pendingAdditions - Variable in class org.apache.activemq.store.jdbc.JDBCMessageStore
pendingCompletion(String, String, long, byte) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
peristenceAdapter - Variable in class org.apache.activemq.store.journal.JournalMessageStore
persistenceAdapter - Variable in class org.apache.activemq.store.jdbc.JDBCMessageStore
PostgresqlJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: Implements all the default JDBC operations that are used by the JDBCPersistenceAdapter.
PostgresqlJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.PostgresqlJDBCAdapter
prepare(TransactionId) - Method in class org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore
prepare(TransactionId) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
preStart() - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
printQuery(Connection, String, PrintStream) - Static method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
printQuery(PreparedStatement, PrintStream) - Static method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
prioritizedMessages - Variable in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
PROPERTY_SEQUENCE_ID_CACHE_SIZE - Static variable in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore

Q

queryTimeout - Variable in class org.apache.activemq.store.jdbc.AbstractJDBCLocker

R

readCommand(RecordLocation) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
recover(TransactionRecoveryListener) - Method in class org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore
recover(MessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
recover(JdbcMemoryTransactionStore) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
recover(MessageRecoveryListener) - Method in class org.apache.activemq.store.journal.JournalMessageStore: Replays the checkpointStore first as those messages are the oldest ones, then messages are replayed from the transaction log and then the cache is updated.
recover(TransactionRecoveryListener) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
recoverAck(long, byte[], byte[]) - Method in class org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore
recoverAdd(long, byte[]) - Method in class org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore
recoverLastAck(byte[], ActiveMQDestination, String, String) - Method in class org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore
recoverMessage(long, byte[]) - Method in interface org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener
recoverMessageReference(String) - Method in interface org.apache.activemq.store.jdbc.JDBCMessageRecoveryListener
recoverNextMessages(int, MessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
recoverNextMessages(String, String, int, MessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
recoverNextMessages(int, MessageRecoveryListener) - Method in class org.apache.activemq.store.journal.JournalMessageStore
recoverNextMessages(String, String, int, MessageRecoveryListener) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
recoverSubscription(String, String, MessageRecoveryListener) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
recoverSubscription(String, String, MessageRecoveryListener) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
removeAllMessages(ConnectionContext) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
removeAllMessages(ConnectionContext) - Method in class org.apache.activemq.store.journal.JournalMessageStore
removeMessage(ConnectionContext, MessageAck) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
removeMessage(ConnectionContext, MessageAck) - Method in class org.apache.activemq.store.journal.JournalMessageStore
removeMessage(JournalMessageStore, MessageAck, RecordLocation) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
removeQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: Cleanup method to remove any state associated with the given destination
removeQueueMessageStore(ActiveMQQueue) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter: Cleanup method to remove any state associated with the given destination
removeTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: Cleanup method to remove any state associated with the given destination No state retained....
removeTopicMessageStore(ActiveMQTopic) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter: Cleanup method to remove any state associated with the given destination
replayAcknowledge(ConnectionContext, String, String, MessageId) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
replayAddMessage(ConnectionContext, Message) - Method in class org.apache.activemq.store.journal.JournalMessageStore
replayCommit(TransactionId, boolean) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
replayPrepare(TransactionId) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
replayRemoveMessage(ConnectionContext, MessageAck) - Method in class org.apache.activemq.store.journal.JournalMessageStore
replayRollback(TransactionId) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
resetBatching() - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
resetBatching(String, String) - Method in class org.apache.activemq.store.jdbc.JDBCTopicMessageStore
resetBatching() - Method in class org.apache.activemq.store.journal.JournalMessageStore
resetBatching(String, String) - Method in class org.apache.activemq.store.journal.JournalTopicMessageStore
returnStatement(Object) - Static method in class org.apache.activemq.util.GenerateJDBCStatements
rollback(TransactionId) - Method in class org.apache.activemq.store.jdbc.JdbcMemoryTransactionStore
rollback() - Method in class org.apache.activemq.store.jdbc.TransactionContext
rollback(TransactionId) - Method in class org.apache.activemq.store.journal.JournalTransactionStore
rollbackLastAck(ConnectionContext, JDBCTopicMessageStore, MessageAck, String, String) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
rollbackLastAck(ConnectionContext, byte, ActiveMQDestination, String, String) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
rollbackTransaction(ConnectionContext) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
rollbackTransaction(ConnectionContext) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
rolledBackAcks - Variable in class org.apache.activemq.store.jdbc.JDBCMessageStore

S

scheduler - Variable in class org.apache.activemq.store.journal.JournalPersistenceAdapter
sequenceDataType - Variable in class org.apache.activemq.store.jdbc.Statements
sequenceGenerator - Variable in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setAcksPkName(String) - Method in class org.apache.activemq.store.jdbc.adapter.PostgresqlJDBCAdapter
setAdapter(JDBCAdapter) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setAdapter(JDBCAdapter) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
setAddMessageStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setAddMessageStatement(PreparedStatement) - Method in class org.apache.activemq.store.jdbc.TransactionContext
setAuditRecoveryDepth(int) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setBatch(MessageId) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
setBatch(MessageId) - Method in class org.apache.activemq.store.journal.JournalMessageStore
setBatchStatements(boolean) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter: Set the number of statements to process as a single batch DB update
setBatchStatments(boolean) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter: Deprecated.
setBinaryData(PreparedStatement, int, byte[]) - Method in class org.apache.activemq.store.jdbc.adapter.BytesJDBCAdapter
setBinaryData(PreparedStatement, int, byte[]) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
setBinaryData(PreparedStatement, int, byte[]) - Method in class org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter
setBinaryDataType(String) - Method in class org.apache.activemq.store.jdbc.Statements
setBrokerName(String) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setBrokerName(String) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
setBrokerService(BrokerService) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
setChangeAutoCommitAllowed(boolean) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: Whether the JDBC driver allows to set the auto commit.
setCheckpointInterval(long) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
setCheckpointInterval(long) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
setCleanupPeriod(int) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: Sets the number of milliseconds until the database is attempted to be cleaned up for durable topics
setClearDurableLastAckInTxStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setClearXidFlagStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setContainerNameDataType(String) - Method in class org.apache.activemq.store.jdbc.Statements
setCreateDurableSubStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setCreateLockSchemaStatements(String[]) - Method in class org.apache.activemq.store.jdbc.Statements
setCreateSchemaStatements(String[]) - Method in class org.apache.activemq.store.jdbc.Statements
setCreateTablesOnStartup(boolean) - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
setCreateTablesOnStartup(boolean) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: Sets whether or not tables are created on startup
setCreateTablesOnStartup(boolean) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: Sets whether or not tables are created on startup
setCurrentDateTimeStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setDatabaseLocker(Locker) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: Deprecated.
as of 5.7.0, replaced by LockableServiceSupport.setLocker(org.apache.activemq.broker.Locker)
setDataDirectory(String) - Method in class org.apache.activemq.store.jdbc.DataSourceServiceSupport
setDataDirectoryFile(File) - Method in class org.apache.activemq.store.jdbc.DataSourceServiceSupport
setDataSource(DataSource) - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
setDataSource(DataSource) - Method in class org.apache.activemq.store.jdbc.DataSourceServiceSupport
setDeleteOldMessagesStatementWithPriority(String) - Method in class org.apache.activemq.store.jdbc.Statements
setDeleteSubscriptionStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setDestinationMessageCountStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setDirectory(File) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setDirectory(File) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
setDropAckPKAlterStatementEnd(String) - Method in class org.apache.activemq.store.jdbc.Statements
setDropSchemaStatements(String[]) - Method in class org.apache.activemq.store.jdbc.Statements
setDurableSubAcksTableName(String) - Method in class org.apache.activemq.store.jdbc.Statements
setDurableSubscriberMessageCountStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setDurableSubscriberMessageCountStatementWithPriority(String) - Method in class org.apache.activemq.store.jdbc.Statements
setEnableAudit(boolean) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setEngineType(String) - Method in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter
setExceptionHandler(Handler) - Method in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
setFindAcksPendingOutcomeStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindAllDestinationsStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindAllDurableSubMessagesStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindAllDurableSubsStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindAllMessageIdsStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindAllMessagesStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindDurableSubMessagesStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindDurableSubStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindLastSequenceIdInAcksStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindLastSequenceIdInMsgsStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindMessageByIdStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindMessageSequenceIdStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindMessageStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindNextMessagesByPriorityStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindNextMessagesStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindOpsPendingOutcomeStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setFindXidByIdStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setHandleStartException(boolean) - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
setInsertDurablePriorityAckStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setJdbcAdapter(JDBCPersistenceAdapter) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
setJournal(Journal) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
setJournal(Journal) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
setJournalArchiveDirectory(File) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
setJournalLogFiles(int) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: Sets the number of journal log files to use
setJournalLogFileSize(int) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: Sets the size of the journal log files When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used
setJournalThreadPriority(int) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: Sets the thread priority of the journal thread
setLastAckedDurableSubscriberMessageStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setLastProducerSequenceIdStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setLeaseHolderId(String) - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
setLeaseObtainStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setLeaseOwnerStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setLeaseUpdateStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setLockAcquireSleepInterval(long) - Method in interface org.apache.activemq.store.jdbc.DatabaseLocker: Deprecated.

set the delay interval in milliseconds between lock acquire attempts
setLockAcquireSleepInterval(long) - Method in class org.apache.activemq.store.jdbc.DefaultDatabaseLocker
setLockAcquireSleepInterval(long) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: Deprecated.
use Locker.setLockAcquireSleepInterval(long) instead millisecond interval between lock acquire attempts, applied to newly created DefaultDatabaseLocker not applied if DataBaseLocker is injected.
setLockCreateStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setLockDataSource(DataSource) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setLockTableName(String) - Method in class org.apache.activemq.store.jdbc.Statements
setLockUpdateStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setLongDataType(String) - Method in class org.apache.activemq.store.jdbc.Statements
setMaxAllowableDiffFromDBTime(int) - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
setMaxAuditDepth(int) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setMaxCheckpointMessageAddSize(int) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
setMaxCheckpointWorkers(int) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
setMaxProducersToAudit(int) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setMaxRows(int) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter: the max value for statement maxRows, used to limit jdbc queries
setMaxRows(int) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
setMaxRows(int) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setMemoryUsage(MemoryUsage) - Method in class org.apache.activemq.store.journal.JournalMessageStore
setMessageTableName(String) - Method in class org.apache.activemq.store.jdbc.Statements
setMsgIdDataType(String) - Method in class org.apache.activemq.store.jdbc.Statements
setNextDurableSubscriberMessageStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setPersistenceAdapter(JDBCPersistenceAdapter) - Method in interface org.apache.activemq.store.jdbc.DatabaseLocker: Deprecated.

allow the injection of a jdbc persistence adapter
setPersistenceAdapter(PersistenceAdapter) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
setPrioritizedMessages(boolean) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
setQueryTimeout(Statement) - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
setQueryTimeout(int) - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
setRemoveAllMessagesStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setRemoveAllSubscriptionsStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setRemovedMessageStatement(PreparedStatement) - Method in class org.apache.activemq.store.jdbc.TransactionContext
setRemoveMessageStatment(String) - Method in class org.apache.activemq.store.jdbc.Statements
setSelectDurablePriorityAckStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setSequenceDataType(String) - Method in class org.apache.activemq.store.jdbc.Statements
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.AbstractJDBCLocker
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.AxionJDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.BlobJDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.DB2JDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.HsqldbJDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.ImageBasedJDBCAdaptor
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.InformixJDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.MaxDBJDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.OracleBlobJDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.OracleJDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.PostgresqlJDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.SybaseJDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.adapter.TransactJDBCAdapter
setStatements(Statements) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setStatements(Statements) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
setStringIdDataType(String) - Method in class org.apache.activemq.store.jdbc.Statements
setTablePrefix(String) - Method in class org.apache.activemq.store.jdbc.Statements
setTaskRunnerFactory(TaskRunnerFactory) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
setTaskRunnerFactory(TaskRunnerFactory) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
setTransactionIsolation(int) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: set the Transaction isolation level to something other that TRANSACTION_READ_UNCOMMITTED This allowable dirty isolation level may not be achievable in clustered DB environments so a more restrictive and expensive option may be needed like TRANSACTION_REPEATABLE_READ see isolation level constants in Connection
setTransactionIsolation(int) - Method in class org.apache.activemq.store.jdbc.TransactionContext
setTypeStatement(String) - Method in class org.apache.activemq.store.jdbc.adapter.MySqlJDBCAdapter
setUpdateDurableLastAckInTxStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setUpdateDurableLastAckStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setUpdateDurableLastAckWithPriorityInTxStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setUpdateDurableLastAckWithPriorityStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setUpdateLastAckStatement(PreparedStatement) - Method in class org.apache.activemq.store.jdbc.TransactionContext
setUpdateLastPriorityAckRowOfDurableSubStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setUpdateMessageStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setUpdateXidFlagStatement(String) - Method in class org.apache.activemq.store.jdbc.Statements
setUsageManager(SystemUsage) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setUsageManager(SystemUsage) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
setUseDatabaseLock(boolean) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter: Deprecated.
use LockableServiceSupport.setUseLock(boolean) instead Sets whether or not an exclusive database lock should be used to enable JDBC Master/Slave. Enabled by default.
setUseDatabaseLock(boolean) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: Sets whether or not an exclusive database lock should be used to enable JDBC Master/Slave.
setUseDedicatedTaskRunner(boolean) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
setUseExternalMessageReferences(boolean) - Method in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
setUseExternalMessageReferences(boolean) - Method in interface org.apache.activemq.store.jdbc.JDBCAdapter
setUseExternalMessageReferences(boolean) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
setUseExternalMessageReferences(boolean) - Method in class org.apache.activemq.store.jdbc.Statements
setUseExternalMessageReferences(boolean) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
setUseJournal(boolean) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: Enables or disables the use of the journal.
setUseLockCreateWhereClause(boolean) - Method in class org.apache.activemq.store.jdbc.Statements
setUseQuickJournal(boolean) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapterFactory: Enables or disables the use of quick journal, which keeps messages in the journal and just stores a reference to the messages in JDBC.
setWireFormat(WireFormat) - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
shutdownDefaultDataSource(DataSource) - Static method in class org.apache.activemq.store.jdbc.DataSourceServiceSupport
size() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
size() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
start() - Method in class org.apache.activemq.store.journal.JournalMessageStore
start() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
start() - Method in class org.apache.activemq.store.journal.JournalTransactionStore
statements - Variable in class org.apache.activemq.store.jdbc.adapter.DefaultJDBCAdapter
Statements - Class in org.apache.activemq.store.jdbc
Statements() - Constructor for class org.apache.activemq.store.jdbc.Statements
stop() - Method in class org.apache.activemq.store.journal.JournalMessageStore
stop() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
stop() - Method in class org.apache.activemq.store.journal.JournalTransactionStore
store - Variable in class org.apache.activemq.store.journal.JournalTransactionStore.TxOperation
storeCache - Variable in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
StreamJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: This JDBCAdapter inserts and extracts BLOB data using the setBinaryStream()/getBinaryStream() operations.
StreamJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.StreamJDBCAdapter
stringIdDataType - Variable in class org.apache.activemq.store.jdbc.Statements
SybaseJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: A JDBC Adapter for Sybase databases
SybaseJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.SybaseJDBCAdapter

T

toByteSequence(Packet) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
toPacket(ByteSequence) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
toString() - Method in class org.apache.activemq.store.jdbc.DataSourceServiceSupport
toString() - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
toString() - Method in class org.apache.activemq.store.jdbc.JDBCPersistenceAdapter
toString() - Method in class org.apache.activemq.store.jdbc.LeaseDatabaseLocker
toString() - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter
trackRollbackAck(Message) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
TransactDatabaseLocker - Class in org.apache.activemq.store.jdbc.adapter: Represents an exclusive lock on a database to avoid multiple brokers running against the same logical database.
TransactDatabaseLocker() - Constructor for class org.apache.activemq.store.jdbc.adapter.TransactDatabaseLocker
TransactionContext - Class in org.apache.activemq.store.jdbc: Helps keep track of the current transaction/JDBC connection.
TransactionContext(JDBCPersistenceAdapter) - Constructor for class org.apache.activemq.store.jdbc.TransactionContext
transactionStore - Variable in class org.apache.activemq.store.journal.JournalMessageStore
transactionTemplate - Variable in class org.apache.activemq.store.journal.JournalMessageStore
TransactJDBCAdapter - Class in org.apache.activemq.store.jdbc.adapter: A JDBC Adapter for Transact-SQL based databases such as SQL Server or Sybase
TransactJDBCAdapter() - Constructor for class org.apache.activemq.store.jdbc.adapter.TransactJDBCAdapter

U

updateMessage(Message) - Method in class org.apache.activemq.store.jdbc.JDBCMessageStore
useExternalMessageReferences - Variable in class org.apache.activemq.store.jdbc.Statements

W

wireFormat - Variable in class org.apache.activemq.store.jdbc.JDBCMessageStore
writeCommand(DataStructure, boolean) - Method in class org.apache.activemq.store.journal.JournalPersistenceAdapter

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