org.apache.activemq.kaha.impl.index
public final class IndexManager extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
NAME_PREFIX |
Constructor and Description |
---|
IndexManager(java.io.File directory,
java.lang.String name,
java.lang.String mode,
DataManager redoLog,
java.util.concurrent.atomic.AtomicLong storeSize) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
IndexItem |
createNewIndex() |
boolean |
delete() |
void |
force() |
void |
freeIndex(IndexItem item) |
IndexItem |
getIndex(long offset) |
java.nio.channels.FileLock |
getLock() |
protected void |
initialize() |
boolean |
isEmpty() |
void |
redo(RedoStoreIndexItem redo) |
IndexItem |
refreshIndex(IndexItem item) |
void |
setLength(long value) |
long |
size() |
void |
storeIndex(IndexItem index) |
java.lang.String |
toString() |
void |
updateIndexes(IndexItem index) |
public static final java.lang.String NAME_PREFIX
public IndexManager(java.io.File directory, java.lang.String name, java.lang.String mode, DataManager redoLog, java.util.concurrent.atomic.AtomicLong storeSize) throws java.io.IOException
java.io.IOException
public boolean isEmpty()
public IndexItem getIndex(long offset) throws java.io.IOException
java.io.IOException
public IndexItem refreshIndex(IndexItem item) throws java.io.IOException
java.io.IOException
public void freeIndex(IndexItem item) throws java.io.IOException
java.io.IOException
public void storeIndex(IndexItem index) throws java.io.IOException
java.io.IOException
public void updateIndexes(IndexItem index) throws java.io.IOException
java.io.IOException
public void redo(RedoStoreIndexItem redo) throws java.io.IOException
java.io.IOException
public IndexItem createNewIndex() throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
java.io.IOException
public void force() throws java.io.IOException
java.io.IOException
public boolean delete() throws java.io.IOException
java.io.IOException
public final long size()
public void setLength(long value)
public java.nio.channels.FileLock getLock() throws java.io.IOException
java.io.IOException
public java.lang.String toString()
toString
in class java.lang.Object
protected void initialize() throws java.io.IOException
java.io.IOException
Copyright © 2005-2014. All Rights Reserved.