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:

  • Constructor Details

    • DatabaseStorageConfiguration

      public DatabaseStorageConfiguration()

  • Method Details

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

    • getDataSourceProperties

      public Map<String,Object> getDataSourceProperties()

    • 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