Class PListStoreImpl
- java.lang.Object
-
- org.apache.activemq.util.ServiceSupport
-
- org.apache.activemq.store.kahadb.plist.PListStoreImpl
-
- All Implemented Interfaces:
Runnable
,BrokerServiceAware
,Service
,JournaledStore
,PListStore
public class PListStoreImpl extends ServiceSupport implements BrokerServiceAware, Runnable, PListStore, JournaledStore
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description protected class
PListStoreImpl.MetaData
-
Constructor Summary
Constructors Constructor Description PListStoreImpl()
-
Method Summary
-
Methods inherited from class org.apache.activemq.util.ServiceSupport
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
-
-
-
-
Method Detail
-
getIndexLock
public Object getIndexLock()
-
setBrokerService
public void setBrokerService(BrokerService brokerService)
- Specified by:
setBrokerService
in interfaceBrokerServiceAware
-
getIndexPageSize
public int getIndexPageSize()
-
getIndexCacheSize
public int getIndexCacheSize()
-
getIndexWriteBatchSize
public int getIndexWriteBatchSize()
-
setIndexPageSize
public void setIndexPageSize(int indexPageSize)
-
setIndexCacheSize
public void setIndexCacheSize(int indexCacheSize)
-
setIndexWriteBatchSize
public void setIndexWriteBatchSize(int indexWriteBatchSize)
-
getIndexEnablePageCaching
public boolean getIndexEnablePageCaching()
-
setIndexEnablePageCaching
public void setIndexEnablePageCaching(boolean indexEnablePageCaching)
-
getJournal
public Journal getJournal()
-
getDirectory
public File getDirectory()
- Specified by:
getDirectory
in interfacePListStore
-
setDirectory
public void setDirectory(File directory)
- Specified by:
setDirectory
in interfacePListStore
-
getIndexDirectory
public File getIndexDirectory()
-
setIndexDirectory
public void setIndexDirectory(File indexDirectory)
-
size
public long size()
- Specified by:
size
in interfacePListStore
-
getPList
public PListImpl getPList(String name) throws Exception
- Specified by:
getPList
in interfacePListStore
- Throws:
Exception
-
removePList
public boolean removePList(String name) throws Exception
- Specified by:
removePList
in interfacePListStore
- Throws:
Exception
-
getDefaultDirectory
protected File getDefaultDirectory()
-
cleanupDirectory
protected void cleanupDirectory(File dir)
-
doStart
protected void doStart() throws Exception
- Specified by:
doStart
in classServiceSupport
- Throws:
Exception
-
doStop
protected void doStop(ServiceStopper stopper) throws Exception
- Specified by:
doStop
in classServiceSupport
- Throws:
Exception
-
isFailIfDatabaseIsLocked
public boolean isFailIfDatabaseIsLocked()
-
setFailIfDatabaseIsLocked
public void setFailIfDatabaseIsLocked(boolean failIfDatabaseIsLocked)
-
getJournalMaxFileLength
public int getJournalMaxFileLength()
- Specified by:
getJournalMaxFileLength
in interfaceJournaledStore
-
setJournalMaxFileLength
public void setJournalMaxFileLength(int journalMaxFileLength)
-
getJournalMaxWriteBatchSize
public int getJournalMaxWriteBatchSize()
-
setJournalMaxWriteBatchSize
public void setJournalMaxWriteBatchSize(int journalMaxWriteBatchSize)
-
isEnableIndexWriteAsync
public boolean isEnableIndexWriteAsync()
-
setEnableIndexWriteAsync
public void setEnableIndexWriteAsync(boolean enableIndexWriteAsync)
-
getCleanupInterval
public long getCleanupInterval()
-
setCleanupInterval
public void setCleanupInterval(long cleanupInterval)
-
isLazyInit
public boolean isLazyInit()
-
setLazyInit
public void setLazyInit(boolean lazyInit)
-
-