org.apache.activemq.store.amq
Class AMQPersistenceAdapterFactory
java.lang.Object
org.apache.activemq.store.amq.AMQPersistenceAdapterFactory
- All Implemented Interfaces:
- PersistenceAdapterFactory
public class AMQPersistenceAdapterFactory
- extends Object
- implements PersistenceAdapterFactory
An implementation of PersistenceAdapterFactory
- Version:
- $Revision: 1.17 $
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
AMQPersistenceAdapterFactory
public AMQPersistenceAdapterFactory()
createPersistenceAdapter
public PersistenceAdapter createPersistenceAdapter()
- 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
- Returns:
- a AMQPersistenceAdapter
- See Also:
PersistenceAdapterFactory.createPersistenceAdapter()
getCleanupInterval
public long getCleanupInterval()
setCleanupInterval
public void setCleanupInterval(long val)
getDataDirectory
public File getDataDirectory()
- Returns:
- the dataDirectory
setDataDirectory
public void setDataDirectory(File dataDirectory)
- Parameters:
dataDirectory
- the dataDirectory to set
isUseDedicatedTaskRunner
public boolean isUseDedicatedTaskRunner()
setUseDedicatedTaskRunner
public void setUseDedicatedTaskRunner(boolean useDedicatedTaskRunner)
getTaskRunnerFactory
public TaskRunnerFactory getTaskRunnerFactory()
- Returns:
- the taskRunnerFactory
setTaskRunnerFactory
public void setTaskRunnerFactory(TaskRunnerFactory taskRunnerFactory)
- Parameters:
taskRunnerFactory
- the taskRunnerFactory to set
getJournalThreadPriority
public int getJournalThreadPriority()
- Returns:
- the journalThreadPriority
setJournalThreadPriority
public void setJournalThreadPriority(int journalThreadPriority)
- Parameters:
journalThreadPriority
- the journalThreadPriority to set
getBrokerName
public String getBrokerName()
- Returns:
- the brokerName
setBrokerName
public void setBrokerName(String brokerName)
- Parameters:
brokerName
- the brokerName to set
getReferenceStoreAdapter
public ReferenceStoreAdapter getReferenceStoreAdapter()
- Returns:
- the referenceStoreAdapter
setReferenceStoreAdapter
public void setReferenceStoreAdapter(ReferenceStoreAdapter referenceStoreAdapter)
- Parameters:
referenceStoreAdapter
- the referenceStoreAdapter to set
isPersistentIndex
public boolean isPersistentIndex()
setPersistentIndex
public void setPersistentIndex(boolean persistentIndex)
isSyncOnWrite
public boolean isSyncOnWrite()
setSyncOnWrite
public void setSyncOnWrite(boolean syncOnWrite)
isSyncOnTransaction
public boolean isSyncOnTransaction()
setSyncOnTransaction
public void setSyncOnTransaction(boolean syncOnTransaction)
isUseNio
public boolean isUseNio()
setUseNio
public void setUseNio(boolean useNio)
getMaxFileLength
public int getMaxFileLength()
setMaxFileLength
public void setMaxFileLength(int maxFileLength)
getIndexBinSize
public int getIndexBinSize()
- Returns:
- the indexBinSize
setIndexBinSize
public void setIndexBinSize(int indexBinSize)
- Parameters:
indexBinSize
- the indexBinSize to set
getIndexKeySize
public int getIndexKeySize()
- Returns:
- the indexKeySize
setIndexKeySize
public void setIndexKeySize(int indexKeySize)
- Parameters:
indexKeySize
- the indexKeySize to set
getIndexPageSize
public int getIndexPageSize()
- Returns:
- the indexPageSize
setIndexPageSize
public void setIndexPageSize(int indexPageSize)
- Parameters:
indexPageSize
- the indexPageSize to set
getIndexMaxBinSize
public int getIndexMaxBinSize()
- Returns:
- the indexMaxBinSize
setIndexMaxBinSize
public void setIndexMaxBinSize(int indexMaxBinSize)
- Parameters:
indexMaxBinSize
- the indexMaxBinSize to set
getIndexLoadFactor
public int getIndexLoadFactor()
- Returns:
- the indexLoadFactor
setIndexLoadFactor
public void setIndexLoadFactor(int indexLoadFactor)
- Parameters:
indexLoadFactor
- the indexLoadFactor to set
getMaxReferenceFileLength
public int getMaxReferenceFileLength()
- Returns:
- the maxReferenceFileLength
setMaxReferenceFileLength
public void setMaxReferenceFileLength(int maxReferenceFileLength)
- Parameters:
maxReferenceFileLength
- the maxReferenceFileLength to set
isRecoverReferenceStore
public boolean isRecoverReferenceStore()
- Returns:
- the recoverReferenceStore
setRecoverReferenceStore
public void setRecoverReferenceStore(boolean recoverReferenceStore)
- Parameters:
recoverReferenceStore
- the recoverReferenceStore to set
isForceRecoverReferenceStore
public boolean isForceRecoverReferenceStore()
- Returns:
- the forceRecoverReferenceStore
setForceRecoverReferenceStore
public void setForceRecoverReferenceStore(boolean forceRecoverReferenceStore)
- Parameters:
forceRecoverReferenceStore
- the forceRecoverReferenceStore to set
getCheckpointInterval
public long getCheckpointInterval()
- Returns:
- the checkpointInterval
setCheckpointInterval
public void setCheckpointInterval(long checkpointInterval)
- Parameters:
checkpointInterval
- the checkpointInterval to set
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.