Package org.apache.activemq.artemis.core.config.storage

Class DatabaseStorageConfiguration

java.lang.Object

org.apache.activemq.artemis.core.config.storage.DatabaseStorageConfiguration

All Implemented Interfaces:

Serializable, StoreConfiguration

public class DatabaseStorageConfiguration
extends Object
implements StoreConfiguration

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.activemq.artemis.core.config.StoreConfiguration

StoreConfiguration.StoreType

Constructor Summary

Constructors

Constructor	Description
DatabaseStorageConfiguration()

Method Summary

Modifier and Type	Method	Description
void	addDataSourceProperty(String key, String value)
DatabaseStorageConfiguration	clearConnectionProviderNetworkTimeout()
int	getAllowedPageSize(int pageSize)
String	getBindingsTableName()
org.apache.activemq.artemis.jdbc.store.drivers.JDBCConnectionProvider	getConnectionProvider()
String	getDataSourceClassName()
String	getDataSourceProperty(String key)
long	getJdbcAllowedTimeDiff()
String	getJdbcConnectionUrl()
String	getJdbcDriverClassName()
long	getJdbcJournalSyncPeriodMillis()
long	getJdbcLockAcquisitionTimeoutMillis()
long	getJdbcLockExpirationMillis()
long	getJdbcLockRenewPeriodMillis()
int	getJdbcNetworkTimeout()
String	getJdbcPassword()
String	getJdbcUser()
String	getLargeMessageTableName()
int	getMaxPageSizeBytes()
String	getMessageTableName()
String	getNodeManagerStoreTableName()
String	getPageStoreTableName()
org.apache.activemq.artemis.jdbc.store.sql.SQLProvider.Factory	getSqlProviderFactory()	The SQLProvider.Factory used to communicate with the JDBC data store.
StoreConfiguration.StoreType	getStoreType()
void	setBindingsTableName(String bindingsTableName)
DatabaseStorageConfiguration	setConnectionProviderNetworkTimeout(Executor executor, int ms)
void	setDataSource(DataSource dataSource)	Configure the DataSource to use to store Artemis data in the data store.
void	setDataSourceClassName(String dataSourceClassName)
void	setJdbcAllowedTimeDiff(long jdbcAllowedTimeDiff)
void	setJdbcConnectionUrl(String jdbcConnectionUrl)
void	setJdbcDriverClassName(String jdbcDriverClassName)
void	setJdbcJournalSyncPeriodMillis(long jdbcJournalSyncPeriodMillis)
void	setJdbcLockAcquisitionTimeoutMillis(long jdbcLockAcquisitionTimeoutMillis)
void	setJdbcLockExpirationMillis(long jdbcLockExpirationMillis)
void	setJdbcLockRenewPeriodMillis(long jdbcLockRenewPeriodMillis)
void	setJdbcNetworkTimeout(int jdbcNetworkTimeout)
void	setJdbcPassword(String jdbcPassword)
void	setJdbcUser(String jdbcUser)
void	setLargeMessageTableName(String largeMessagesTableName)
DatabaseStorageConfiguration	setMaxPageSizeBytes(int maxPageSizeBytes)
void	setMessageTableName(String messageTableName)
void	setNodeManagerStoreTableName(String nodeManagerStoreTableName)
void	setPageStoreTableName(String pageStoreTableName)
void	setSqlProvider(org.apache.activemq.artemis.jdbc.store.sql.SQLProvider.Factory sqlProviderFactory)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DatabaseStorageConfiguration

public DatabaseStorageConfiguration()

Method Detail

getStoreType

public StoreConfiguration.StoreType getStoreType()

Specified by:

getStoreType in interface StoreConfiguration

getMessageTableName

public String getMessageTableName()

setMessageTableName

public void setMessageTableName(String messageTableName)

getBindingsTableName

public String getBindingsTableName()

setBindingsTableName

public void setBindingsTableName(String bindingsTableName)

getLargeMessageTableName

public String getLargeMessageTableName()

setLargeMessageTableName

public void setLargeMessageTableName(String largeMessagesTableName)

getPageStoreTableName

public String getPageStoreTableName()

setNodeManagerStoreTableName

public void setNodeManagerStoreTableName(String nodeManagerStoreTableName)

getNodeManagerStoreTableName

public String getNodeManagerStoreTableName()

setPageStoreTableName

public void setPageStoreTableName(String pageStoreTableName)

setJdbcConnectionUrl

public void setJdbcConnectionUrl(String jdbcConnectionUrl)

getJdbcConnectionUrl

public String getJdbcConnectionUrl()

getJdbcUser

public String getJdbcUser()

setJdbcUser

public void setJdbcUser(String jdbcUser)

getJdbcPassword

public String getJdbcPassword()

setJdbcPassword

public void setJdbcPassword(String jdbcPassword)

setJdbcDriverClassName

public void setJdbcDriverClassName(String jdbcDriverClassName)

getJdbcDriverClassName

public String getJdbcDriverClassName()

getJdbcAllowedTimeDiff

public long getJdbcAllowedTimeDiff()

getMaxPageSizeBytes

public int getMaxPageSizeBytes()

setMaxPageSizeBytes

public DatabaseStorageConfiguration setMaxPageSizeBytes(int maxPageSizeBytes)

setDataSource

public void setDataSource(DataSource dataSource)

Configure the DataSource to use to store Artemis data in the data store.

Parameters:

dataSource -

getConnectionProvider

public org.apache.activemq.artemis.jdbc.store.drivers.JDBCConnectionProvider getConnectionProvider()

setConnectionProviderNetworkTimeout

public DatabaseStorageConfiguration setConnectionProviderNetworkTimeout(Executor executor,
                                                                        int ms)

clearConnectionProviderNetworkTimeout

public DatabaseStorageConfiguration clearConnectionProviderNetworkTimeout()

addDataSourceProperty

public void addDataSourceProperty(String key,
                                  String value)

getDataSourceProperty

public String getDataSourceProperty(String key)

getDataSourceClassName

public String getDataSourceClassName()

setDataSourceClassName

public void setDataSourceClassName(String dataSourceClassName)

getSqlProviderFactory

public org.apache.activemq.artemis.jdbc.store.sql.SQLProvider.Factory getSqlProviderFactory()

The SQLProvider.Factory used to communicate with the JDBC data store. It can be null. If the value is null and dataSource is set, the {@link org.apache.activemq.artemis.jdbc.store.sql.PropertySQLProvider.Factory} will be used, else the type of the factory will be determined based on the jdbcDriverClassName.

Returns:

the factory used to communicate with the JDBC data store.

setSqlProvider

public void setSqlProvider(org.apache.activemq.artemis.jdbc.store.sql.SQLProvider.Factory sqlProviderFactory)

getJdbcNetworkTimeout

public int getJdbcNetworkTimeout()

setJdbcNetworkTimeout

public void setJdbcNetworkTimeout(int jdbcNetworkTimeout)

getJdbcLockRenewPeriodMillis

public long getJdbcLockRenewPeriodMillis()

setJdbcLockRenewPeriodMillis

public void setJdbcLockRenewPeriodMillis(long jdbcLockRenewPeriodMillis)

getJdbcLockExpirationMillis

public long getJdbcLockExpirationMillis()

setJdbcLockExpirationMillis

public void setJdbcLockExpirationMillis(long jdbcLockExpirationMillis)

getJdbcLockAcquisitionTimeoutMillis

public long getJdbcLockAcquisitionTimeoutMillis()

setJdbcLockAcquisitionTimeoutMillis

public void setJdbcLockAcquisitionTimeoutMillis(long jdbcLockAcquisitionTimeoutMillis)

getJdbcJournalSyncPeriodMillis

public long getJdbcJournalSyncPeriodMillis()

setJdbcJournalSyncPeriodMillis

public void setJdbcJournalSyncPeriodMillis(long jdbcJournalSyncPeriodMillis)

setJdbcAllowedTimeDiff

public void setJdbcAllowedTimeDiff(long jdbcAllowedTimeDiff)

getAllowedPageSize

public int getAllowedPageSize(int pageSize)

Specified by:

getAllowedPageSize in interface StoreConfiguration