org.apache.activemq.kaha.impl.index

Class IndexManager

java.lang.Object

org.apache.activemq.kaha.impl.index.IndexManager

public final class IndexManager
extends java.lang.Object

Optimized Store reader

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	NAME_PREFIX

Constructor Summary

Constructors

Constructor and Description
IndexManager(java.io.File directory, java.lang.String name, java.lang.String mode, DataManager redoLog, java.util.concurrent.atomic.AtomicLong storeSize)

Method Summary

Methods

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)

Methods inherited from class java.lang.Object

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

Field Detail

NAME_PREFIX

public static final java.lang.String NAME_PREFIX

See Also:

Constant Field Values

Constructor Detail

IndexManager

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

Throws:

java.io.IOException

Method Detail

isEmpty

public boolean isEmpty()

getIndex

public IndexItem getIndex(long offset)
                   throws java.io.IOException

Throws:

java.io.IOException

refreshIndex

public IndexItem refreshIndex(IndexItem item)
                       throws java.io.IOException

Throws:

java.io.IOException

freeIndex

public void freeIndex(IndexItem item)
               throws java.io.IOException

Throws:

java.io.IOException

storeIndex

public void storeIndex(IndexItem index)
                throws java.io.IOException

Throws:

java.io.IOException

updateIndexes

public void updateIndexes(IndexItem index)
                   throws java.io.IOException

Throws:

java.io.IOException

redo

public void redo(RedoStoreIndexItem redo)
          throws java.io.IOException

Throws:

java.io.IOException

createNewIndex

public IndexItem createNewIndex()
                         throws java.io.IOException

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Throws:

java.io.IOException

force

public void force()
           throws java.io.IOException

Throws:

java.io.IOException

delete

public boolean delete()
               throws java.io.IOException

Throws:

java.io.IOException

size

public final long size()

setLength

public void setLength(long value)

getLock

public java.nio.channels.FileLock getLock()
                                   throws java.io.IOException

Throws:

java.io.IOException

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

initialize

protected void initialize()
                   throws java.io.IOException

Throws:

java.io.IOException