|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.activemq.kaha.impl.KahaStore
public class KahaStore
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(File directory,
String mode)
|
|
KahaStore(File directory,
String mode,
AtomicLong storeSize)
|
|
KahaStore(String name,
String mode)
|
|
KahaStore(String name,
String mode,
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(Object id)
delete a ListContainer from the default container |
void |
deleteListContainer(Object id,
String containerName)
delete a ListContainer from the named container |
void |
deleteMapContainer(ContainerId containerId)
Delete Map container |
void |
deleteMapContainer(Object id)
delete a container from the default container |
void |
deleteMapContainer(Object id,
String containerName)
delete a MapContainer from the name container |
boolean |
doesListContainerExist(Object id)
Checks if a ListContainer exists in the default container |
boolean |
doesListContainerExist(Object id,
String containerName)
Checks if a ListContainer exists in the named container |
boolean |
doesMapContainerExist(Object id)
Checks if a MapContainer exists in the default container |
boolean |
doesMapContainerExist(Object id,
String containerName)
Checks if a MapContainer exists in the named container |
void |
force()
Force all writes to disk |
DataManager |
getDataManager(String name)
|
String |
getDefaultContainerName()
|
IndexManager |
getIndexManager(DataManager dm,
String name)
|
String |
getIndexTypeAsString()
|
ListContainer |
getListContainer(Object id)
Get a ListContainer with the given id and creates it if it doesn't exist |
ListContainer |
getListContainer(Object id,
String containerName)
Get a ListContainer with the given id and creates it if it doesn't exist |
ListContainer |
getListContainer(Object id,
String containerName,
boolean persistentIndex)
Get a ListContainer with the given id and creates it if it doesn't exist |
Set<ContainerId> |
getListContainerIds()
Get a Set of call ListContainer Ids |
org.apache.activemq.kaha.impl.IndexRootContainer |
getListsContainer()
|
MapContainer |
getMapContainer(Object id)
Get a MapContainer with the given id - the MapContainer is created if needed |
MapContainer |
getMapContainer(Object id,
String containerName)
Get a MapContainer with the given id - the MapContainer is created if needed |
MapContainer |
getMapContainer(Object id,
String containerName,
boolean persistentIndex)
Get a MapContainer with the given id - the MapContainer is created if needed |
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(String defaultContainerName)
set the default container name |
void |
setIndexTypeAsString(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 |
---|
public KahaStore(String name, String mode) throws IOException
IOException
public KahaStore(File directory, String mode) throws IOException
IOException
public KahaStore(String name, String mode, AtomicLong storeSize) throws IOException
IOException
public KahaStore(File directory, String mode, AtomicLong storeSize) throws IOException
IOException
Method Detail |
---|
public void close() throws IOException
Store
close
in interface Store
IOException
public void force() throws IOException
Store
force
in interface Store
IOException
public void clear() throws IOException
Store
clear
in interface Store
IOException
public boolean delete() throws IOException
Store
delete
in interface Store
IOException
public boolean isInitialized()
isInitialized
in interface Store
public boolean doesMapContainerExist(Object id) throws IOException
Store
doesMapContainerExist
in interface Store
IOException
public boolean doesMapContainerExist(Object id, String containerName) throws IOException
Store
doesMapContainerExist
in interface Store
IOException
public MapContainer getMapContainer(Object id) throws IOException
Store
getMapContainer
in interface Store
IOException
public MapContainer getMapContainer(Object id, String containerName) throws IOException
Store
getMapContainer
in interface Store
IOException
public MapContainer getMapContainer(Object id, String containerName, boolean persistentIndex) throws IOException
Store
getMapContainer
in interface Store
IOException
public void deleteMapContainer(Object id) throws IOException
Store
deleteMapContainer
in interface Store
IOException
public void deleteMapContainer(Object id, String containerName) throws IOException
Store
deleteMapContainer
in interface Store
IOException
public void deleteMapContainer(ContainerId containerId) throws IOException
Store
deleteMapContainer
in interface Store
IOException
public Set<ContainerId> getMapContainerIds() throws IOException
Store
getMapContainerIds
in interface Store
IOException
public boolean doesListContainerExist(Object id) throws IOException
Store
doesListContainerExist
in interface Store
IOException
public boolean doesListContainerExist(Object id, String containerName) throws IOException
Store
doesListContainerExist
in interface Store
IOException
public ListContainer getListContainer(Object id) throws IOException
Store
getListContainer
in interface Store
IOException
public ListContainer getListContainer(Object id, String containerName) throws IOException
Store
getListContainer
in interface Store
IOException
public ListContainer getListContainer(Object id, String containerName, boolean persistentIndex) throws IOException
Store
getListContainer
in interface Store
IOException
public void deleteListContainer(Object id) throws IOException
Store
deleteListContainer
in interface Store
IOException
public void deleteListContainer(Object id, String containerName) throws IOException
Store
deleteListContainer
in interface Store
IOException
public void deleteListContainer(ContainerId containerId) throws IOException
Store
deleteListContainer
in interface Store
IOException
public Set<ContainerId> getListContainerIds() throws IOException
Store
getListContainerIds
in interface Store
IOException
public org.apache.activemq.kaha.impl.IndexRootContainer getListsContainer()
public org.apache.activemq.kaha.impl.IndexRootContainer getMapsContainer()
public DataManager getDataManager(String name) throws IOException
IOException
public IndexManager getIndexManager(DataManager dm, String name) throws IOException
IOException
public boolean isLogIndexChanges()
public void setLogIndexChanges(boolean logIndexChanges)
public long getMaxDataFileLength()
getMaxDataFileLength
in interface Store
public void setMaxDataFileLength(long maxDataFileLength)
setMaxDataFileLength
in interface Store
maxDataFileLength
- the maxDataFileLength to setpublic String getIndexTypeAsString()
public void setIndexTypeAsString(String type)
type
- "PERSISTENT" or "VM"public boolean isPersistentIndex()
isPersistentIndex
in interface Store
public void setPersistentIndex(boolean persistentIndex)
Store
setPersistentIndex
in interface Store
public boolean isUseAsyncDataManager()
public void setUseAsyncDataManager(boolean useAsyncWriter)
public long size()
size
in interface Store
Store.size()
public String getDefaultContainerName()
getDefaultContainerName
in interface Store
public void setDefaultContainerName(String defaultContainerName)
Store
setDefaultContainerName
in interface Store
public void initialize() throws IOException
Store
initialize
in interface Store
IOException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |