org.apache.activemq.store.kahadb
Class TempMessageDatabase
java.lang.Object
org.apache.activemq.store.kahadb.TempMessageDatabase
- Direct Known Subclasses:
- TempKahaDBStore
public class TempMessageDatabase
- extends java.lang.Object
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
CLOSED_STATE
public static final int CLOSED_STATE
- See Also:
- Constant Field Values
OPEN_STATE
public static final int OPEN_STATE
- See Also:
- Constant Field Values
destinations
protected BTreeIndex<java.lang.String,org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination> destinations
pageFile
protected PageFile pageFile
directory
protected java.io.File directory
started
protected java.util.concurrent.atomic.AtomicBoolean started
opened
protected java.util.concurrent.atomic.AtomicBoolean opened
indexMutex
protected final java.lang.Object indexMutex
inflightTransactions
protected final java.util.LinkedHashMap<TransactionId,java.util.ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> inflightTransactions
preparedTransactions
protected final java.util.LinkedHashMap<TransactionId,java.util.ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> preparedTransactions
TempMessageDatabase
public TempMessageDatabase()
start
public void start()
throws java.lang.Exception
- Throws:
java.lang.Exception
stop
public void stop()
throws java.lang.Exception
- Throws:
java.lang.Exception
open
public void open()
throws java.io.IOException
- Throws:
java.io.IOException
load
public void load()
throws java.io.IOException
- Throws:
java.io.IOException
close
public void close()
throws java.io.IOException,
java.lang.InterruptedException
- Throws:
java.io.IOException
java.lang.InterruptedException
unload
public void unload()
throws java.io.IOException,
java.lang.InterruptedException
- Throws:
java.io.IOException
java.lang.InterruptedException
processAdd
public void processAdd(org.apache.activemq.store.kahadb.data.KahaAddMessageCommand command,
TransactionId txid,
ByteSequence data)
throws java.io.IOException
- Throws:
java.io.IOException
processRemove
public void processRemove(org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand command,
TransactionId txid)
throws java.io.IOException
- Throws:
java.io.IOException
process
public void process(org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand command)
throws java.io.IOException
- Throws:
java.io.IOException
process
public void process(org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand command)
throws java.io.IOException
- Throws:
java.io.IOException
processCommit
public void processCommit(TransactionId key)
throws java.io.IOException
- Throws:
java.io.IOException
processPrepare
public void processPrepare(TransactionId key)
processRollback
public void processRollback(TransactionId key)
getJournalFilesBeingReplicated
public java.util.HashSet<java.lang.Integer> getJournalFilesBeingReplicated()
getStoredDestination
protected org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination getStoredDestination(org.apache.activemq.store.kahadb.data.KahaDestination destination,
Transaction tx)
throws java.io.IOException
- Throws:
java.io.IOException
getDirectory
public java.io.File getDirectory()
setDirectory
public void setDirectory(java.io.File directory)
setIndexWriteBatchSize
public void setIndexWriteBatchSize(int setIndexWriteBatchSize)
getIndexWriteBatchSize
public int getIndexWriteBatchSize()
setEnableIndexWriteAsync
public void setEnableIndexWriteAsync(boolean enableIndexWriteAsync)
getPageFile
public PageFile getPageFile()
Copyright © 2005-2012. All Rights Reserved.