org.apache.activemq.kaha.impl
Class KahaStore

java.lang.Object
  org.apache.activemq.kaha.impl.KahaStore

All Implemented Interfaces:

Store

public class KahaStore
extends java.lang.Object
implements Store

Store Implementation

Field Summary

Fields inherited from interface org.apache.activemq.kaha.Store

BYTES_MARSHALLER, COMMAND_MARSHALLER, DEFAULT_CONTAINER_NAME, MESSAGEID_MARSHALLER, OBJECT_MARSHALLER, STRING_MARSHALLER

Constructor Summary

KahaStore(java.io.File directory, java.lang.String mode)

KahaStore(java.io.File directory, java.lang.String mode, java.util.concurrent.atomic.AtomicLong storeSize)

KahaStore(java.lang.String name, java.lang.String mode)

KahaStore(java.lang.String name, java.lang.String mode, java.util.concurrent.atomic.AtomicLong storeSize)

Method Summary

void	clear() empty all the contents of the store
void	close() close the store
boolean	delete() delete the store
void	deleteListContainer(ContainerId containerId) delete a list container
void	deleteListContainer(java.lang.Object id) delete a ListContainer from the default container
void	deleteListContainer(java.lang.Object id, java.lang.String containerName) delete a ListContainer from the named container
void	deleteMapContainer(ContainerId containerId) Delete Map container
void	deleteMapContainer(java.lang.Object id) delete a container from the default container
void	deleteMapContainer(java.lang.Object id, java.lang.String containerName) delete a MapContainer from the name container
boolean	doesListContainerExist(java.lang.Object id) Checks if a ListContainer exists in the default container
boolean	doesListContainerExist(java.lang.Object id, java.lang.String containerName) Checks if a ListContainer exists in the named container
boolean	doesMapContainerExist(java.lang.Object id) Checks if a MapContainer exists in the default container
boolean	doesMapContainerExist(java.lang.Object id, java.lang.String containerName) Checks if a MapContainer exists in the named container
void	force() Force all writes to disk
DataManager	getDataManager(java.lang.String name)
java.lang.String	getDefaultContainerName()
IndexManager	getIndexManager(DataManager dm, java.lang.String name)
java.lang.String	getIndexTypeAsString()
ListContainer	getListContainer(java.lang.Object id) Get a ListContainer with the given id and creates it if it doesn't exist
ListContainer	getListContainer(java.lang.Object id, java.lang.String containerName) Get a ListContainer with the given id and creates it if it doesn't exist
ListContainer	getListContainer(java.lang.Object id, java.lang.String containerName, boolean persistentIndex) Get a ListContainer with the given id and creates it if it doesn't exist
java.util.Set<ContainerId>	getListContainerIds() Get a Set of call ListContainer Ids
org.apache.activemq.kaha.impl.IndexRootContainer	getListsContainer()
MapContainer	getMapContainer(java.lang.Object id) Get a MapContainer with the given id - the MapContainer is created if needed
MapContainer	getMapContainer(java.lang.Object id, java.lang.String containerName) Get a MapContainer with the given id - the MapContainer is created if needed
MapContainer	getMapContainer(java.lang.Object id, java.lang.String containerName, boolean persistentIndex) Get a MapContainer with the given id - the MapContainer is created if needed
java.util.Set<ContainerId>	getMapContainerIds() Get a Set of call MapContainer Ids
org.apache.activemq.kaha.impl.IndexRootContainer	getMapsContainer()
long	getMaxDataFileLength()
void	initialize() An explict call to initialize - this will also be called implicitly for any other operation on the store.
boolean	isInitialized()
boolean	isLogIndexChanges()
boolean	isPersistentIndex()
boolean	isUseAsyncDataManager()
void	setDefaultContainerName(java.lang.String defaultContainerName) set the default container name
void	setIndexTypeAsString(java.lang.String type) Set the default index type
void	setLogIndexChanges(boolean logIndexChanges)
void	setMaxDataFileLength(long maxDataFileLength)
void	setPersistentIndex(boolean persistentIndex) Set a persistent index as the default if the parameter is true
void	setUseAsyncDataManager(boolean useAsyncWriter)
long	size()

Methods inherited from class java.lang.Object

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

Constructor Detail

KahaStore

public KahaStore(java.lang.String name,
                 java.lang.String mode)
          throws java.io.IOException

Throws:

java.io.IOException

KahaStore

public KahaStore(java.io.File directory,
                 java.lang.String mode)
          throws java.io.IOException

Throws:

java.io.IOException

KahaStore

public KahaStore(java.lang.String name,
                 java.lang.String mode,
                 java.util.concurrent.atomic.AtomicLong storeSize)
          throws java.io.IOException

Throws:

java.io.IOException

KahaStore

public KahaStore(java.io.File directory,
                 java.lang.String mode,
                 java.util.concurrent.atomic.AtomicLong storeSize)
          throws java.io.IOException

Throws:

java.io.IOException

Method Detail

close

public void close()
           throws java.io.IOException

Description copied from interface: Store

close the store

Specified by:

close in interface Store

Throws:

java.io.IOException

force

public void force()
           throws java.io.IOException

Description copied from interface: Store

Force all writes to disk

Specified by:

force in interface Store

Throws:

java.io.IOException

clear

public void clear()
           throws java.io.IOException

Description copied from interface: Store

empty all the contents of the store

Specified by:

clear in interface Store

Throws:

java.io.IOException

delete

public boolean delete()
               throws java.io.IOException

Description copied from interface: Store

delete the store

Specified by:

delete in interface Store

Returns:

true if the delete was successful

Throws:

java.io.IOException

isInitialized

public boolean isInitialized()

Specified by:

isInitialized in interface Store

Returns:

true if the store has been initialized

doesMapContainerExist

public boolean doesMapContainerExist(java.lang.Object id)
                              throws java.io.IOException

Description copied from interface: Store

Checks if a MapContainer exists in the default container

Specified by:

doesMapContainerExist in interface Store

Returns:

new MapContainer

Throws:

java.io.IOException

doesMapContainerExist

public boolean doesMapContainerExist(java.lang.Object id,
                                     java.lang.String containerName)
                              throws java.io.IOException

Description copied from interface: Store

Checks if a MapContainer exists in the named container

Specified by:

doesMapContainerExist in interface Store

Returns:

new MapContainer

Throws:

java.io.IOException

getMapContainer

public MapContainer getMapContainer(java.lang.Object id)
                             throws java.io.IOException

Description copied from interface: Store

Get a MapContainer with the given id - the MapContainer is created if needed

Specified by:

getMapContainer in interface Store

Returns:

container for the associated id or null if it doesn't exist

Throws:

java.io.IOException

getMapContainer

public MapContainer getMapContainer(java.lang.Object id,
                                    java.lang.String containerName)
                             throws java.io.IOException

Description copied from interface: Store

Get a MapContainer with the given id - the MapContainer is created if needed

Specified by:

getMapContainer in interface Store

Returns:

container for the associated id or null if it doesn't exist

Throws:

java.io.IOException

getMapContainer

public MapContainer getMapContainer(java.lang.Object id,
                                    java.lang.String containerName,
                                    boolean persistentIndex)
                             throws java.io.IOException

Description copied from interface: Store

Get a MapContainer with the given id - the MapContainer is created if needed

Specified by:

getMapContainer in interface Store

Returns:

container for the associated id or null if it doesn't exist

Throws:

java.io.IOException

deleteMapContainer

public void deleteMapContainer(java.lang.Object id)
                        throws java.io.IOException

Description copied from interface: Store

delete a container from the default container

Specified by:

deleteMapContainer in interface Store

Throws:

java.io.IOException

deleteMapContainer

public void deleteMapContainer(java.lang.Object id,
                               java.lang.String containerName)
                        throws java.io.IOException

Description copied from interface: Store

delete a MapContainer from the name container

Specified by:

deleteMapContainer in interface Store

Throws:

java.io.IOException

deleteMapContainer

public void deleteMapContainer(ContainerId containerId)
                        throws java.io.IOException

Description copied from interface: Store

Delete Map container

Specified by:

deleteMapContainer in interface Store

Throws:

java.io.IOException

getMapContainerIds

public java.util.Set<ContainerId> getMapContainerIds()
                                              throws java.io.IOException

Description copied from interface: Store

Get a Set of call MapContainer Ids

Specified by:

getMapContainerIds in interface Store

Returns:

the set of ids

Throws:

java.io.IOException

doesListContainerExist

public boolean doesListContainerExist(java.lang.Object id)
                               throws java.io.IOException

Description copied from interface: Store

Checks if a ListContainer exists in the default container

Specified by:

doesListContainerExist in interface Store

Returns:

new MapContainer

Throws:

java.io.IOException

doesListContainerExist

public boolean doesListContainerExist(java.lang.Object id,
                                      java.lang.String containerName)
                               throws java.io.IOException

Description copied from interface: Store

Checks if a ListContainer exists in the named container

Specified by:

doesListContainerExist in interface Store

Returns:

new MapContainer

Throws:

java.io.IOException

getListContainer

public ListContainer getListContainer(java.lang.Object id)
                               throws java.io.IOException

Description copied from interface: Store

Get a ListContainer with the given id and creates it if it doesn't exist

Specified by:

getListContainer in interface Store

Returns:

container for the associated id or null if it doesn't exist

Throws:

java.io.IOException

getListContainer

public ListContainer getListContainer(java.lang.Object id,
                                      java.lang.String containerName)
                               throws java.io.IOException

Description copied from interface: Store

Get a ListContainer with the given id and creates it if it doesn't exist

Specified by:

getListContainer in interface Store

Returns:

container for the associated id or null if it doesn't exist

Throws:

java.io.IOException

getListContainer

public ListContainer getListContainer(java.lang.Object id,
                                      java.lang.String containerName,
                                      boolean persistentIndex)
                               throws java.io.IOException

Description copied from interface: Store

Get a ListContainer with the given id and creates it if it doesn't exist

Specified by:

getListContainer in interface Store

Returns:

container for the associated id or null if it doesn't exist

Throws:

java.io.IOException

deleteListContainer

public void deleteListContainer(java.lang.Object id)
                         throws java.io.IOException

Description copied from interface: Store

delete a ListContainer from the default container

Specified by:

deleteListContainer in interface Store

Throws:

java.io.IOException

deleteListContainer

public void deleteListContainer(java.lang.Object id,
                                java.lang.String containerName)
                         throws java.io.IOException

Description copied from interface: Store

delete a ListContainer from the named container

Specified by:

deleteListContainer in interface Store

Throws:

java.io.IOException

deleteListContainer

public void deleteListContainer(ContainerId containerId)
                         throws java.io.IOException

Description copied from interface: Store

delete a list container

Specified by:

deleteListContainer in interface Store

Throws:

java.io.IOException

getListContainerIds

public java.util.Set<ContainerId> getListContainerIds()
                                               throws java.io.IOException

Description copied from interface: Store

Get a Set of call ListContainer Ids

Specified by:

getListContainerIds in interface Store

Returns:

the set of ids

Throws:

java.io.IOException

getListsContainer

public org.apache.activemq.kaha.impl.IndexRootContainer getListsContainer()

Returns:

the listsContainer

getMapsContainer

public org.apache.activemq.kaha.impl.IndexRootContainer getMapsContainer()

Returns:

the mapsContainer

getDataManager

public DataManager getDataManager(java.lang.String name)
                           throws java.io.IOException

Throws:

java.io.IOException

getIndexManager

public IndexManager getIndexManager(DataManager dm,
                                    java.lang.String name)
                             throws java.io.IOException

Throws:

java.io.IOException

isLogIndexChanges

public boolean isLogIndexChanges()

setLogIndexChanges

public void setLogIndexChanges(boolean logIndexChanges)

getMaxDataFileLength

public long getMaxDataFileLength()

Specified by:

getMaxDataFileLength in interface Store

Returns:

the maxDataFileLength

setMaxDataFileLength

public void setMaxDataFileLength(long maxDataFileLength)

Specified by:

setMaxDataFileLength in interface Store

Parameters:

maxDataFileLength - the maxDataFileLength to set

getIndexTypeAsString

public java.lang.String getIndexTypeAsString()

Returns:

the default index type

setIndexTypeAsString

public void setIndexTypeAsString(java.lang.String type)

Set the default index type

Parameters:

type - "PERSISTENT" or "VM"

isPersistentIndex

public boolean isPersistentIndex()

Specified by:

isPersistentIndex in interface Store

Returns:

true if persistent indexes are used by default

setPersistentIndex

public void setPersistentIndex(boolean persistentIndex)

Description copied from interface: Store

Set a persistent index as the default if the parameter is true

Specified by:

setPersistentIndex in interface Store

isUseAsyncDataManager

public boolean isUseAsyncDataManager()

setUseAsyncDataManager

public void setUseAsyncDataManager(boolean useAsyncWriter)

size

public long size()

Specified by:

size in interface Store

Returns:

size of store

See Also:

Store.size()

getDefaultContainerName

public java.lang.String getDefaultContainerName()

Specified by:

getDefaultContainerName in interface Store

Returns:

the default container name

setDefaultContainerName

public void setDefaultContainerName(java.lang.String defaultContainerName)

Description copied from interface: Store

set the default container name

Specified by:

setDefaultContainerName in interface Store

initialize

public void initialize()
                throws java.io.IOException

Description copied from interface: Store

An explict call to initialize - this will also be called implicitly for any other operation on the store.

Specified by:

initialize in interface Store

Throws:

java.io.IOException