org.apache.activemq.store.amq
Class AMQPersistenceAdapterFactory

java.lang.Object
  extended by org.apache.activemq.store.amq.AMQPersistenceAdapterFactory
All Implemented Interfaces:
PersistenceAdapterFactory

public class AMQPersistenceAdapterFactory
extends Object
implements PersistenceAdapterFactory

An implementation of PersistenceAdapterFactory


Constructor Summary
AMQPersistenceAdapterFactory()
           
 
Method Summary
 PersistenceAdapter createPersistenceAdapter()
          Creates a persistence Adapter that can use a given directory to store it's data.
 String getBrokerName()
           
 long getCheckpointInterval()
           
 long getCleanupInterval()
           
 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(String brokerName)
           
 void setCheckpointInterval(long checkpointInterval)
           
 void setCleanupInterval(long val)
           
 void setDataDirectory(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)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

AMQPersistenceAdapterFactory

public AMQPersistenceAdapterFactory()
Method Detail

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-2012 The Apache Software Foundation. All Rights Reserved.