org.apache.activemq.kaha.impl
BYTES_MARSHALLER, COMMAND_MARSHALLER, DEFAULT_CONTAINER_NAME, MESSAGEID_MARSHALLER, OBJECT_MARSHALLER, STRING_MARSHALLER
Constructor and Description |
---|
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) |
Modifier and Type | Method and Description |
---|---|
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() |
public KahaStore(java.lang.String name, java.lang.String mode) throws java.io.IOException
java.io.IOException
public KahaStore(java.io.File directory, java.lang.String mode) throws java.io.IOException
java.io.IOException
public KahaStore(java.lang.String name, java.lang.String mode, java.util.concurrent.atomic.AtomicLong storeSize) throws java.io.IOException
java.io.IOException
public KahaStore(java.io.File directory, java.lang.String mode, java.util.concurrent.atomic.AtomicLong storeSize) throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
Store
public void force() throws java.io.IOException
Store
public void clear() throws java.io.IOException
Store
public boolean delete() throws java.io.IOException
Store
public boolean isInitialized()
isInitialized
in interface Store
public boolean doesMapContainerExist(java.lang.Object id) throws java.io.IOException
Store
doesMapContainerExist
in interface Store
java.io.IOException
public boolean doesMapContainerExist(java.lang.Object id, java.lang.String containerName) throws java.io.IOException
Store
doesMapContainerExist
in interface Store
java.io.IOException
public MapContainer getMapContainer(java.lang.Object id) throws java.io.IOException
Store
getMapContainer
in interface Store
java.io.IOException
public MapContainer getMapContainer(java.lang.Object id, java.lang.String containerName) throws java.io.IOException
Store
getMapContainer
in interface Store
java.io.IOException
public MapContainer getMapContainer(java.lang.Object id, java.lang.String containerName, boolean persistentIndex) throws java.io.IOException
Store
getMapContainer
in interface Store
java.io.IOException
public void deleteMapContainer(java.lang.Object id) throws java.io.IOException
Store
deleteMapContainer
in interface Store
java.io.IOException
public void deleteMapContainer(java.lang.Object id, java.lang.String containerName) throws java.io.IOException
Store
deleteMapContainer
in interface Store
java.io.IOException
public void deleteMapContainer(ContainerId containerId) throws java.io.IOException
Store
deleteMapContainer
in interface Store
java.io.IOException
public java.util.Set<ContainerId> getMapContainerIds() throws java.io.IOException
Store
getMapContainerIds
in interface Store
java.io.IOException
public boolean doesListContainerExist(java.lang.Object id) throws java.io.IOException
Store
doesListContainerExist
in interface Store
java.io.IOException
public boolean doesListContainerExist(java.lang.Object id, java.lang.String containerName) throws java.io.IOException
Store
doesListContainerExist
in interface Store
java.io.IOException
public ListContainer getListContainer(java.lang.Object id) throws java.io.IOException
Store
getListContainer
in interface Store
java.io.IOException
public ListContainer getListContainer(java.lang.Object id, java.lang.String containerName) throws java.io.IOException
Store
getListContainer
in interface Store
java.io.IOException
public ListContainer getListContainer(java.lang.Object id, java.lang.String containerName, boolean persistentIndex) throws java.io.IOException
Store
getListContainer
in interface Store
java.io.IOException
public void deleteListContainer(java.lang.Object id) throws java.io.IOException
Store
deleteListContainer
in interface Store
java.io.IOException
public void deleteListContainer(java.lang.Object id, java.lang.String containerName) throws java.io.IOException
Store
deleteListContainer
in interface Store
java.io.IOException
public void deleteListContainer(ContainerId containerId) throws java.io.IOException
Store
deleteListContainer
in interface Store
java.io.IOException
public java.util.Set<ContainerId> getListContainerIds() throws java.io.IOException
Store
getListContainerIds
in interface Store
java.io.IOException
public org.apache.activemq.kaha.impl.IndexRootContainer getListsContainer()
public org.apache.activemq.kaha.impl.IndexRootContainer getMapsContainer()
public DataManager getDataManager(java.lang.String name) throws java.io.IOException
java.io.IOException
public IndexManager getIndexManager(DataManager dm, java.lang.String name) throws java.io.IOException
java.io.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 java.lang.String getIndexTypeAsString()
public void setIndexTypeAsString(java.lang.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 java.lang.String getDefaultContainerName()
getDefaultContainerName
in interface Store
public void setDefaultContainerName(java.lang.String defaultContainerName)
Store
setDefaultContainerName
in interface Store
public void initialize() throws java.io.IOException
Store
initialize
in interface Store
java.io.IOException
Copyright © 2005-2014. All Rights Reserved.