public class TempMessageDatabase extends 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<String,org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination> |
destinations |
protected File |
directory |
protected Object |
indexMutex |
protected LinkedHashMap<TransactionId,ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> |
inflightTransactions |
static int |
OPEN_STATE |
protected AtomicBoolean |
opened |
protected PageFile |
pageFile |
protected LinkedHashMap<TransactionId,ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> |
preparedTransactions |
protected AtomicBoolean |
started |
| Constructor and Description |
|---|
TempMessageDatabase() |
| Modifier and Type | Method and Description |
|---|---|
void |
close() |
File |
getDirectory() |
int |
getIndexWriteBatchSize() |
HashSet<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(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<String,org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination> destinations
protected AtomicBoolean started
protected AtomicBoolean opened
protected final Object indexMutex
protected final LinkedHashMap<TransactionId,ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> inflightTransactions
protected final LinkedHashMap<TransactionId,ArrayList<org.apache.activemq.store.kahadb.TempMessageDatabase.Operation>> preparedTransactions
public TempMessageDatabase()
public void open() throws IOException
IOExceptionpublic void load() throws IOException
IOExceptionpublic void close() throws IOException, InterruptedException
IOExceptionInterruptedExceptionpublic void unload() throws IOException, InterruptedException
IOExceptionInterruptedExceptionpublic void processAdd(org.apache.activemq.store.kahadb.data.KahaAddMessageCommand command, TransactionId txid, ByteSequence data) throws IOException
IOExceptionpublic void processRemove(org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand command, TransactionId txid) throws IOException
IOExceptionpublic void process(org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand command) throws IOException
IOExceptionpublic void process(org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand command) throws IOException
IOExceptionpublic void processCommit(TransactionId key) throws IOException
IOExceptionpublic void processPrepare(TransactionId key)
public void processRollback(TransactionId key)
public HashSet<Integer> getJournalFilesBeingReplicated()
protected org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination getStoredDestination(org.apache.activemq.store.kahadb.data.KahaDestination destination, Transaction tx) throws IOException
IOExceptionpublic File getDirectory()
public void setDirectory(File directory)
public void setIndexWriteBatchSize(int setIndexWriteBatchSize)
public int getIndexWriteBatchSize()
public void setEnableIndexWriteAsync(boolean enableIndexWriteAsync)
public PageFile getPageFile()
Copyright © 2005–2015 FuseSource, Corp.. All rights reserved.