org.apache.activemq.store.kahadb.plist
Class PListStoreImpl

java.lang.Object
  extended by org.apache.activemq.util.ServiceSupport
      extended by 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
protected  class PListStoreImpl.MetaData
           
 
Constructor Summary
PListStoreImpl()
           
 
Method Summary
protected  void doStart()
           
protected  void doStop(ServiceStopper stopper)
           
 long getCleanupInterval()
           
 File getDirectory()
           
 int getIndexCacheSize()
           
 boolean getIndexEnablePageCaching()
           
 Object getIndexLock()
           
 int getIndexPageSize()
           
 int getIndexWriteBatchSize()
           
 Journal getJournal()
           
 int getJournalMaxFileLength()
           
 int getJournalMaxWriteBatchSize()
           
 PListImpl getPList(String name)
           
protected  void intialize()
           
 boolean isEnableIndexWriteAsync()
           
 boolean isFailIfDatabaseIsLocked()
           
 boolean isLazyInit()
           
 boolean removePList(String name)
           
 void run()
           
 void setBrokerService(BrokerService brokerService)
           
 void setCleanupInterval(long cleanupInterval)
           
 void setDirectory(File directory)
           
 void setEnableIndexWriteAsync(boolean enableIndexWriteAsync)
           
 void setFailIfDatabaseIsLocked(boolean failIfDatabaseIsLocked)
           
 void setIndexCacheSize(int indexCacheSize)
           
 void setIndexEnablePageCaching(boolean indexEnablePageCaching)
           
 void setIndexPageSize(int indexPageSize)
           
 void setIndexWriteBatchSize(int indexWriteBatchSize)
           
 void setJournalMaxFileLength(int journalMaxFileLength)
           
 void setJournalMaxWriteBatchSize(int journalMaxWriteBatchSize)
           
 void setLazyInit(boolean lazyInit)
           
 long size()
           
 String toString()
           
 
Methods inherited from class org.apache.activemq.util.ServiceSupport
addServiceListener, dispose, isStarted, isStopped, isStopping, postStop, preStart, removeServiceListener, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface org.apache.activemq.Service
start, stop
 

Constructor Detail

PListStoreImpl

public PListStoreImpl()
Method Detail

getIndexLock

public 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 File getDirectory()
Specified by:
getDirectory in interface PListStore

setDirectory

public void setDirectory(File directory)
Specified by:
setDirectory in interface PListStore

size

public long size()
Specified by:
size in interface PListStore

getPList

public PListImpl getPList(String name)
                   throws Exception
Specified by:
getPList in interface PListStore
Throws:
Exception

removePList

public boolean removePList(String name)
                    throws Exception
Specified by:
removePList in interface PListStore
Throws:
Exception

intialize

protected void intialize()
                  throws Exception
Throws:
Exception

doStart

protected void doStart()
                throws Exception
Specified by:
doStart in class ServiceSupport
Throws:
Exception

doStop

protected void doStop(ServiceStopper stopper)
               throws Exception
Specified by:
doStop in class ServiceSupport
Throws:
Exception

run

public void run()
Specified by:
run in interface Runnable

isFailIfDatabaseIsLocked

public boolean isFailIfDatabaseIsLocked()

setFailIfDatabaseIsLocked

public void setFailIfDatabaseIsLocked(boolean failIfDatabaseIsLocked)

getJournalMaxFileLength

public int getJournalMaxFileLength()
Specified by:
getJournalMaxFileLength in interface JournaledStore

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 String toString()
Overrides:
toString in class Object


Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.