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:

Runnable, BrokerServiceAware, Service

public class PListStore
extends ServiceSupport
implements BrokerServiceAware, Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	PListStore.MetaData

Constructor Summary

Constructors

Constructor and Description
PListStore()

Method Summary

Modifier and Type	Method and Description
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()
PList	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, removeServiceListener, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

PListStore

public PListStore()

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()

setDirectory

public void setDirectory(File directory)

size

public long size()

getPList

public PList getPList(String name)
               throws Exception

Throws:

Exception

removePList

public boolean removePList(String name)
                    throws Exception

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()

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