public class AMQPersistenceAdapterFactory extends java.lang.Object implements PersistenceAdapterFactory
PersistenceAdapterFactory
Constructor and Description |
---|
AMQPersistenceAdapterFactory() |
Modifier and Type | Method and Description |
---|---|
PersistenceAdapter |
createPersistenceAdapter()
Creates a persistence Adapter that can use a given directory to store it's data.
|
java.lang.String |
getBrokerName() |
long |
getCheckpointInterval() |
long |
getCleanupInterval() |
java.io.File |
getDataDirectory() |
int |
getIndexBinSize() |
int |
getIndexKeySize() |
int |
getIndexLoadFactor() |
int |
getIndexMaxBinSize() |
int |
getIndexPageSize() |
int |
getJournalThreadPriority() |
int |
getMaxFileLength() |
int |
getMaxReferenceFileLength() |
ReferenceStoreAdapter |
getReferenceStoreAdapter() |
TaskRunnerFactory |
getTaskRunnerFactory() |
boolean |
isForceRecoverReferenceStore() |
boolean |
isPersistentIndex() |
boolean |
isRecoverReferenceStore() |
boolean |
isSyncOnTransaction() |
boolean |
isSyncOnWrite() |
boolean |
isUseDedicatedTaskRunner() |
boolean |
isUseNio() |
void |
setBrokerName(java.lang.String brokerName) |
void |
setCheckpointInterval(long checkpointInterval) |
void |
setCleanupInterval(long val) |
void |
setDataDirectory(java.io.File dataDirectory) |
void |
setForceRecoverReferenceStore(boolean forceRecoverReferenceStore) |
void |
setIndexBinSize(int indexBinSize) |
void |
setIndexKeySize(int indexKeySize) |
void |
setIndexLoadFactor(int indexLoadFactor) |
void |
setIndexMaxBinSize(int indexMaxBinSize) |
void |
setIndexPageSize(int indexPageSize) |
void |
setJournalThreadPriority(int journalThreadPriority) |
void |
setMaxFileLength(int maxFileLength) |
void |
setMaxReferenceFileLength(int maxReferenceFileLength) |
void |
setPersistentIndex(boolean persistentIndex) |
void |
setRecoverReferenceStore(boolean recoverReferenceStore) |
void |
setReferenceStoreAdapter(ReferenceStoreAdapter referenceStoreAdapter) |
void |
setSyncOnTransaction(boolean syncOnTransaction) |
void |
setSyncOnWrite(boolean syncOnWrite) |
void |
setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory) |
void |
setUseDedicatedTaskRunner(boolean useDedicatedTaskRunner) |
void |
setUseNio(boolean useNio) |
public AMQPersistenceAdapterFactory()
public PersistenceAdapter createPersistenceAdapter()
PersistenceAdapterFactory
createPersistenceAdapter
in interface PersistenceAdapterFactory
PersistenceAdapterFactory.createPersistenceAdapter()
public long getCleanupInterval()
public void setCleanupInterval(long val)
public java.io.File getDataDirectory()
public void setDataDirectory(java.io.File dataDirectory)
dataDirectory
- the dataDirectory to setpublic boolean isUseDedicatedTaskRunner()
public void setUseDedicatedTaskRunner(boolean useDedicatedTaskRunner)
public TaskRunnerFactory getTaskRunnerFactory()
public void setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory)
taskRunnerFactory
- the taskRunnerFactory to setpublic int getJournalThreadPriority()
public void setJournalThreadPriority(int journalThreadPriority)
journalThreadPriority
- the journalThreadPriority to setpublic java.lang.String getBrokerName()
public void setBrokerName(java.lang.String brokerName)
brokerName
- the brokerName to setpublic ReferenceStoreAdapter getReferenceStoreAdapter()
public void setReferenceStoreAdapter(ReferenceStoreAdapter referenceStoreAdapter)
referenceStoreAdapter
- the referenceStoreAdapter to setpublic boolean isPersistentIndex()
public void setPersistentIndex(boolean persistentIndex)
public boolean isSyncOnWrite()
public void setSyncOnWrite(boolean syncOnWrite)
public boolean isSyncOnTransaction()
public void setSyncOnTransaction(boolean syncOnTransaction)
public boolean isUseNio()
public void setUseNio(boolean useNio)
public int getMaxFileLength()
public void setMaxFileLength(int maxFileLength)
public int getIndexBinSize()
public void setIndexBinSize(int indexBinSize)
indexBinSize
- the indexBinSize to setpublic int getIndexKeySize()
public void setIndexKeySize(int indexKeySize)
indexKeySize
- the indexKeySize to setpublic int getIndexPageSize()
public void setIndexPageSize(int indexPageSize)
indexPageSize
- the indexPageSize to setpublic int getIndexMaxBinSize()
public void setIndexMaxBinSize(int indexMaxBinSize)
indexMaxBinSize
- the indexMaxBinSize to setpublic int getIndexLoadFactor()
public void setIndexLoadFactor(int indexLoadFactor)
indexLoadFactor
- the indexLoadFactor to setpublic int getMaxReferenceFileLength()
public void setMaxReferenceFileLength(int maxReferenceFileLength)
maxReferenceFileLength
- the maxReferenceFileLength to setpublic boolean isRecoverReferenceStore()
public void setRecoverReferenceStore(boolean recoverReferenceStore)
recoverReferenceStore
- the recoverReferenceStore to setpublic boolean isForceRecoverReferenceStore()
public void setForceRecoverReferenceStore(boolean forceRecoverReferenceStore)
forceRecoverReferenceStore
- the forceRecoverReferenceStore to setpublic long getCheckpointInterval()
public void setCheckpointInterval(long checkpointInterval)
checkpointInterval
- the checkpointInterval to setCopyright © 2005-2017. All Rights Reserved.