org.apache.activemq.store.journal
Class JournalPersistenceAdapterFactory

java.lang.Object
  extended by org.apache.activemq.store.jdbc.DataSourceSupport
      extended by org.apache.activemq.store.journal.JournalPersistenceAdapterFactory
All Implemented Interfaces:
PersistenceAdapterFactory
Direct Known Subclasses:
PersistenceAdapterFactoryBean

public class JournalPersistenceAdapterFactory
extends DataSourceSupport
implements PersistenceAdapterFactory

Factory class that can create PersistenceAdapter objects.


Constructor Summary
JournalPersistenceAdapterFactory()
           
 
Method Summary
protected  void createJournal()
           
 PersistenceAdapter createPersistenceAdapter()
          Creates a persistence Adapter that can use a given directory to store it's data.
 JDBCAdapter getAdapter()
           
 JDBCPersistenceAdapter getJdbcAdapter()
           
 org.apache.activeio.journal.Journal getJournal()
           
 java.io.File getJournalArchiveDirectory()
           
 int getJournalLogFiles()
           
 int getJournalLogFileSize()
           
 int getJournalThreadPriority()
           
 Statements getStatements()
           
 TaskRunnerFactory getTaskRunnerFactory()
           
 boolean isCreateTablesOnStartup()
           
 boolean isUseDatabaseLock()
           
 boolean isUseDedicatedTaskRunner()
           
 boolean isUseJournal()
           
 boolean isUseQuickJournal()
           
 void setAdapter(JDBCAdapter adapter)
           
 void setCreateTablesOnStartup(boolean createTablesOnStartup)
          Sets whether or not tables are created on startup
 void setJdbcAdapter(JDBCPersistenceAdapter jdbcAdapter)
           
 void setJournal(org.apache.activeio.journal.Journal journal)
           
 void setJournalArchiveDirectory(java.io.File journalArchiveDirectory)
           
 void setJournalLogFiles(int journalLogFiles)
          Sets the number of journal log files to use
 void setJournalLogFileSize(int journalLogFileSize)
          Sets the size of the journal log files When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used
 void setJournalThreadPriority(int journalThreadPriority)
          Sets the thread priority of the journal thread
 void setStatements(Statements statements)
           
 void setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory)
           
 void setUseDatabaseLock(boolean useDatabaseLock)
          Sets whether or not an exclusive database lock should be used to enable JDBC Master/Slave.
 void setUseDedicatedTaskRunner(boolean useDedicatedTaskRunner)
           
 void setUseJournal(boolean useJournal)
          Enables or disables the use of the journal.
 void setUseQuickJournal(boolean useQuickJournal)
          Enables or disables the use of quick journal, which keeps messages in the journal and just stores a reference to the messages in JDBC.
 
Methods inherited from class org.apache.activemq.store.jdbc.DataSourceSupport
createDataSource, getDataDirectory, getDataDirectoryFile, getDataSource, setDataDirectory, setDataDirectoryFile, setDataSource, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

JournalPersistenceAdapterFactory

public JournalPersistenceAdapterFactory()
Method Detail

createPersistenceAdapter

public PersistenceAdapter createPersistenceAdapter()
                                            throws java.io.IOException
Description copied from interface: PersistenceAdapterFactory
Creates a persistence Adapter that can use a given directory to store it's data.

Specified by:
createPersistenceAdapter in interface PersistenceAdapterFactory
Throws:
java.io.IOException

getJournalLogFiles

public int getJournalLogFiles()

setJournalLogFiles

public void setJournalLogFiles(int journalLogFiles)
Sets the number of journal log files to use


getJournalLogFileSize

public int getJournalLogFileSize()

setJournalLogFileSize

public void setJournalLogFileSize(int journalLogFileSize)
Sets the size of the journal log files When set using Xbean, values of the form "20 Mb", "1024kb", and "1g" can be used


getJdbcAdapter

public JDBCPersistenceAdapter getJdbcAdapter()

setJdbcAdapter

public void setJdbcAdapter(JDBCPersistenceAdapter jdbcAdapter)

isUseJournal

public boolean isUseJournal()

setUseJournal

public void setUseJournal(boolean useJournal)
Enables or disables the use of the journal. The default is to use the journal

Parameters:
useJournal -

isUseDedicatedTaskRunner

public boolean isUseDedicatedTaskRunner()

setUseDedicatedTaskRunner

public void setUseDedicatedTaskRunner(boolean useDedicatedTaskRunner)

getTaskRunnerFactory

public TaskRunnerFactory getTaskRunnerFactory()

setTaskRunnerFactory

public void setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory)

getJournal

public org.apache.activeio.journal.Journal getJournal()
                                               throws java.io.IOException
Throws:
java.io.IOException

setJournal

public void setJournal(org.apache.activeio.journal.Journal journal)

getJournalArchiveDirectory

public java.io.File getJournalArchiveDirectory()

setJournalArchiveDirectory

public void setJournalArchiveDirectory(java.io.File journalArchiveDirectory)

isUseQuickJournal

public boolean isUseQuickJournal()

setUseQuickJournal

public void setUseQuickJournal(boolean useQuickJournal)
Enables or disables the use of quick journal, which keeps messages in the journal and just stores a reference to the messages in JDBC. Defaults to false so that messages actually reside long term in the JDBC database.


getAdapter

public JDBCAdapter getAdapter()
                       throws java.io.IOException
Throws:
java.io.IOException

setAdapter

public void setAdapter(JDBCAdapter adapter)

getStatements

public Statements getStatements()

setStatements

public void setStatements(Statements statements)

isUseDatabaseLock

public boolean isUseDatabaseLock()

setUseDatabaseLock

public void setUseDatabaseLock(boolean useDatabaseLock)
Sets whether or not an exclusive database lock should be used to enable JDBC Master/Slave. Enabled by default.


isCreateTablesOnStartup

public boolean isCreateTablesOnStartup()

setCreateTablesOnStartup

public void setCreateTablesOnStartup(boolean createTablesOnStartup)
Sets whether or not tables are created on startup


getJournalThreadPriority

public int getJournalThreadPriority()

setJournalThreadPriority

public void setJournalThreadPriority(int journalThreadPriority)
Sets the thread priority of the journal thread


createJournal

protected void createJournal()
                      throws java.io.IOException
Throws:
java.io.IOException


Copyright © 2005-2011 FuseSource, Corp.. All Rights Reserved.