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

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