org.apache.activemq.store.kahadb.plist
Class PListStore
java.lang.Object
org.apache.activemq.util.ServiceSupport
org.apache.activemq.store.kahadb.plist.PListStore
- All Implemented Interfaces:
- java.lang.Runnable, BrokerServiceAware, Service
public class PListStore
- extends ServiceSupport
- implements BrokerServiceAware, java.lang.Runnable
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
PListStore
public PListStore()
getIndexLock
public java.lang.Object getIndexLock()
setBrokerService
public void setBrokerService(BrokerService brokerService)
- Specified by:
setBrokerService
in interface BrokerServiceAware
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 java.io.File getDirectory()
setDirectory
public void setDirectory(java.io.File directory)
size
public long size()
getPList
public PList getPList(java.lang.String name)
throws java.lang.Exception
- Throws:
java.lang.Exception
removePList
public boolean removePList(java.lang.String name)
throws java.lang.Exception
- Throws:
java.lang.Exception
intialize
protected void intialize()
throws java.lang.Exception
- Throws:
java.lang.Exception
doStart
protected void doStart()
throws java.lang.Exception
- Specified by:
doStart
in class ServiceSupport
- Throws:
java.lang.Exception
doStop
protected void doStop(ServiceStopper stopper)
throws java.lang.Exception
- Specified by:
doStop
in class ServiceSupport
- Throws:
java.lang.Exception
run
public void run()
- Specified by:
run
in interface java.lang.Runnable
isFailIfDatabaseIsLocked
public boolean isFailIfDatabaseIsLocked()
setFailIfDatabaseIsLocked
public void setFailIfDatabaseIsLocked(boolean failIfDatabaseIsLocked)
getJournalMaxFileLength
public int getJournalMaxFileLength()
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)
toString
public java.lang.String toString()
- Overrides:
toString
in class java.lang.Object
Copyright © 2005-2016. All Rights Reserved.