public class JournalPersistenceAdapterFactory extends DataSourceServiceSupport implements PersistenceAdapterFactory
brokerService, clockDaemon
Constructor and Description |
---|
JournalPersistenceAdapterFactory() |
Modifier and Type | Method and Description |
---|---|
Locker |
createDefaultLocker() |
protected void |
createJournal() |
PersistenceAdapter |
createPersistenceAdapter() |
protected void |
doStart() |
protected void |
doStop(ServiceStopper stopper) |
JDBCAdapter |
getAdapter() |
long |
getCheckpointInterval() |
JDBCPersistenceAdapter |
getJdbcAdapter() |
org.apache.activeio.journal.Journal |
getJournal() |
File |
getJournalArchiveDirectory() |
int |
getJournalLogFiles() |
int |
getJournalLogFileSize() |
int |
getJournalThreadPriority() |
Statements |
getStatements() |
org.apache.activemq.thread.TaskRunnerFactory |
getTaskRunnerFactory() |
void |
init() |
boolean |
isCreateTablesOnStartup() |
boolean |
isUseDedicatedTaskRunner() |
boolean |
isUseJournal() |
boolean |
isUseQuickJournal() |
void |
setAdapter(JDBCAdapter adapter) |
void |
setCheckpointInterval(long checkpointInterval) |
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(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(org.apache.activemq.thread.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.
|
closeDataSource, createDataSource, createDataSource, getDataDirectory, getDataDirectoryFile, getDataSource, setDataDirectory, setDataDirectoryFile, setDataSource, shutdownDefaultDataSource, toString
getBrokerService, getLocker, getLockKeepAlivePeriod, getScheduledThreadPoolExecutor, isUseLock, keepLockAlive, postStop, preStart, setBrokerService, setLocker, setLockKeepAlivePeriod, setScheduledThreadPoolExecutor, setUseLock, stopBroker
addServiceListener, dispose, isStarted, isStopped, isStopping, removeServiceListener, start, stop
public JournalPersistenceAdapterFactory()
public PersistenceAdapter createPersistenceAdapter() throws IOException
createPersistenceAdapter
in interface PersistenceAdapterFactory
IOException
public int getJournalLogFiles()
public void setJournalLogFiles(int journalLogFiles)
public int getJournalLogFileSize()
public void setJournalLogFileSize(int journalLogFileSize)
public JDBCPersistenceAdapter getJdbcAdapter()
public void setJdbcAdapter(JDBCPersistenceAdapter jdbcAdapter)
public boolean isUseJournal()
public long getCheckpointInterval()
public void setCheckpointInterval(long checkpointInterval)
public void setUseJournal(boolean useJournal)
useJournal
- public boolean isUseDedicatedTaskRunner()
public void setUseDedicatedTaskRunner(boolean useDedicatedTaskRunner)
public org.apache.activemq.thread.TaskRunnerFactory getTaskRunnerFactory()
public void setTaskRunnerFactory(org.apache.activemq.thread.TaskRunnerFactory taskRunnerFactory)
public org.apache.activeio.journal.Journal getJournal() throws IOException
IOException
public void setJournal(org.apache.activeio.journal.Journal journal)
public File getJournalArchiveDirectory()
public void setJournalArchiveDirectory(File journalArchiveDirectory)
public boolean isUseQuickJournal()
public void setUseQuickJournal(boolean useQuickJournal)
public JDBCAdapter getAdapter() throws IOException
IOException
public void setAdapter(JDBCAdapter adapter)
public Statements getStatements()
public void setStatements(Statements statements)
public void setUseDatabaseLock(boolean useDatabaseLock)
public boolean isCreateTablesOnStartup()
public void setCreateTablesOnStartup(boolean createTablesOnStartup)
public int getJournalThreadPriority()
public void setJournalThreadPriority(int journalThreadPriority)
protected void createJournal() throws IOException
IOException
public Locker createDefaultLocker() throws IOException
createDefaultLocker
in interface Lockable
IOException
public void init() throws Exception
init
in class LockableServiceSupport
Exception
protected void doStop(ServiceStopper stopper) throws Exception
doStop
in class ServiceSupport
Exception
protected void doStart() throws Exception
doStart
in class ServiceSupport
Exception
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.