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(KahaDestination destination,
Transaction tx) |
void |
load() |
void |
open() |
void |
process(KahaRemoveDestinationCommand command) |
void |
process(KahaSubscriptionCommand command) |
void |
processAdd(KahaAddMessageCommand command,
TransactionId txid,
ByteSequence data) |
void |
processCommit(TransactionId key) |
void |
processPrepare(TransactionId key) |
void |
processRemove(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 PageFile pageFile
protected File directory
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 void open() throws IOException
IOException
public void load() throws IOException
IOException
public void close() throws IOException, InterruptedException
IOException
InterruptedException
public void unload() throws IOException, InterruptedException
IOException
InterruptedException
public void processAdd(KahaAddMessageCommand command, TransactionId txid, ByteSequence data) throws IOException
IOException
public void processRemove(KahaRemoveMessageCommand command, TransactionId txid) throws IOException
IOException
public void process(KahaRemoveDestinationCommand command) throws IOException
IOException
public void process(KahaSubscriptionCommand command) throws IOException
IOException
public void processCommit(TransactionId key) throws IOException
IOException
public void processPrepare(TransactionId key)
public void processRollback(TransactionId key)
protected org.apache.activemq.store.kahadb.TempMessageDatabase.StoredDestination getStoredDestination(KahaDestination destination, Transaction tx) throws IOException
IOException
public 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-2013 The Apache Software Foundation. All Rights Reserved.