public class TempMessageDatabase extends java.lang.Object
Modifier and Type | Class and Description |
---|---|
protected static class |
TempMessageDatabase.MessageKeysMarshaller |
protected class |
TempMessageDatabase.StoredDestinationMarshaller |
Modifier and Type | Field and Description |
---|---|
static int |
CLOSED_STATE |
protected BTreeIndex<java.lang.String,org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination> |
destinations |
protected java.io.File |
directory |
protected java.lang.Object |
indexMutex |
protected java.util.LinkedHashMap<TransactionId,java.util.ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> |
inflightTransactions |
static int |
OPEN_STATE |
protected java.util.concurrent.atomic.AtomicBoolean |
opened |
protected PageFile |
pageFile |
protected java.util.LinkedHashMap<TransactionId,java.util.ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> |
preparedTransactions |
protected java.util.concurrent.atomic.AtomicBoolean |
started |
Constructor and Description |
---|
TempMessageDatabase() |
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.io.File |
getDirectory() |
int |
getIndexWriteBatchSize() |
java.util.HashSet<java.lang.Integer> |
getJournalFilesBeingReplicated() |
PageFile |
getPageFile() |
protected org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination |
getStoredDestination(org.apache.activemq.store.kahadb.data.KahaDestination destination,
Transaction tx) |
void |
load() |
void |
open() |
void |
process(org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand command) |
void |
process(org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand command) |
void |
processAdd(org.apache.activemq.store.kahadb.data.KahaAddMessageCommand command,
TransactionId txid,
ByteSequence data) |
void |
processCommit(TransactionId key) |
void |
processPrepare(TransactionId key) |
void |
processRemove(org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand command,
TransactionId txid) |
void |
processRollback(TransactionId key) |
void |
setDirectory(java.io.File directory) |
void |
setEnableIndexWriteAsync(boolean enableIndexWriteAsync) |
void |
setIndexWriteBatchSize(int setIndexWriteBatchSize) |
void |
start() |
void |
stop() |
void |
unload() |
public static final int CLOSED_STATE
public static final int OPEN_STATE
protected BTreeIndex<java.lang.String,org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination> destinations
protected java.io.File directory
protected java.util.concurrent.atomic.AtomicBoolean started
protected java.util.concurrent.atomic.AtomicBoolean opened
protected final java.lang.Object indexMutex
protected final java.util.LinkedHashMap<TransactionId,java.util.ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> inflightTransactions
protected final java.util.LinkedHashMap<TransactionId,java.util.ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> preparedTransactions
public TempMessageDatabase()
public void start() throws java.lang.Exception
java.lang.Exception
public void stop() throws java.lang.Exception
java.lang.Exception
public void open() throws java.io.IOException
java.io.IOException
public void load() throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void unload() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public void processAdd(org.apache.activemq.store.kahadb.data.KahaAddMessageCommand command, TransactionId txid, ByteSequence data) throws java.io.IOException
java.io.IOException
public void processRemove(org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand command, TransactionId txid) throws java.io.IOException
java.io.IOException
public void process(org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand command) throws java.io.IOException
java.io.IOException
public void process(org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand command) throws java.io.IOException
java.io.IOException
public void processCommit(TransactionId key) throws java.io.IOException
java.io.IOException
public void processPrepare(TransactionId key)
public void processRollback(TransactionId key)
public java.util.HashSet<java.lang.Integer> getJournalFilesBeingReplicated()
protected org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination getStoredDestination(org.apache.activemq.store.kahadb.data.KahaDestination destination, Transaction tx) throws java.io.IOException
java.io.IOException
public java.io.File getDirectory()
public void setDirectory(java.io.File directory)
public void setIndexWriteBatchSize(int setIndexWriteBatchSize)
public int getIndexWriteBatchSize()
public void setEnableIndexWriteAsync(boolean enableIndexWriteAsync)
public PageFile getPageFile()
Copyright © 2005-2012. All Rights Reserved.