Package org.apache.activemq.store.kahadb.plist

Class PListStoreImpl

java.lang.Object
org.apache.activemq.util.ServiceSupport
org.apache.activemq.store.kahadb.plist.PListStoreImpl
All Implemented Interfaces:
Runnable, org.apache.activemq.broker.BrokerServiceAware, org.apache.activemq.Service, org.apache.activemq.store.JournaledStore, org.apache.activemq.store.PListStore
public class PListStoreImpl extends org.apache.activemq.util.ServiceSupport implements org.apache.activemq.broker.BrokerServiceAware, Runnable, org.apache.activemq.store.PListStore, org.apache.activemq.store.JournaledStore

  • Constructor Details

    • PListStoreImpl

      public PListStoreImpl()

  • Method Details

    • getIndexLock

      public Object getIndexLock()

    • setBrokerService

      public void setBrokerService(org.apache.activemq.broker.BrokerService brokerService)
      Specified by:
      setBrokerService in interface org.apache.activemq.broker.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 org.apache.activemq.store.PListStore

    • setDirectory

      public void setDirectory(File directory)
      Specified by:
      setDirectory in interface org.apache.activemq.store.PListStore

    • getIndexDirectory

      public File getIndexDirectory()

    • setIndexDirectory

      public void setIndexDirectory(File indexDirectory)

    • size

      public long size()
      Specified by:
      size in interface org.apache.activemq.store.PListStore

    • getPList

      public PListImpl getPList(String name) throws Exception
      Specified by:
      getPList in interface org.apache.activemq.store.PListStore
      Throws:
      Exception

    • removePList

      public boolean removePList(String name) throws Exception
      Specified by:
      removePList in interface org.apache.activemq.store.PListStore
      Throws:
      Exception

    • intialize

      protected void intialize() throws Exception
      Throws:
      Exception

    • getDefaultDirectory

      protected File getDefaultDirectory()

    • cleanupDirectory

      protected void cleanupDirectory(File dir)

    • doStart

      protected void doStart() throws Exception
      Specified by:
      doStart in class org.apache.activemq.util.ServiceSupport
      Throws:
      Exception

    • doStop

      protected void doStop(org.apache.activemq.util.ServiceStopper stopper) throws Exception
      Specified by:
      doStop in class org.apache.activemq.util.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 org.apache.activemq.store.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