public class KahaDBStore.KahaDBMessageStore extends AbstractMessageStore
Modifier and Type | Field and Description |
---|---|
protected HashMap<String,Set<String>> |
ackedAndPreparedMap |
protected Map<org.apache.activemq.store.kahadb.KahaDBStore.AsyncJobKey,KahaDBStore.StoreTask> |
asyncTaskMap |
protected KahaDestination |
dest |
protected HashMap<String,Set<String>> |
rolledBackAcksMap |
destination, FUTURE, indexListener, prioritizedMessages
Constructor and Description |
---|
KahaDBStore.KahaDBMessageStore(org.apache.activemq.command.ActiveMQDestination destination) |
Modifier and Type | Method and Description |
---|---|
protected void |
acquireLocalAsyncLock() |
void |
addMessage(ConnectionContext context,
org.apache.activemq.command.Message message) |
ListenableFuture<Object> |
asyncAddQueueMessage(ConnectionContext context,
org.apache.activemq.command.Message message) |
void |
forgetRecoveredAcks(ArrayList<org.apache.activemq.command.MessageAck> acks,
boolean rollback) |
org.apache.activemq.command.ActiveMQDestination |
getDestination() |
org.apache.activemq.command.Message |
getMessage(org.apache.activemq.command.MessageId identity) |
int |
getMessageCount() |
boolean |
isEmpty() |
protected void |
lockAsyncJobQueue() |
void |
recover(MessageRecoveryListener listener) |
void |
recoverNextMessages(int maxReturned,
MessageRecoveryListener listener) |
protected int |
recoverRolledBackAcks(String recoveredTxStateMapKey,
org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd,
Transaction tx,
int maxReturned,
MessageRecoveryListener listener) |
protected void |
releaseLocalAsyncLock() |
void |
removeAllMessages(ConnectionContext context) |
void |
removeAsyncMessage(ConnectionContext context,
org.apache.activemq.command.MessageAck ack) |
void |
removeMessage(ConnectionContext context,
org.apache.activemq.command.MessageAck ack) |
void |
resetBatching() |
void |
setBatch(org.apache.activemq.command.MessageId identity) |
void |
setMemoryUsage(MemoryUsage memoryUsage) |
void |
start() |
void |
stop() |
String |
toString() |
void |
trackRecoveredAcks(ArrayList<org.apache.activemq.command.MessageAck> acks) |
protected void |
unlockAsyncJobQueue() |
void |
updateMessage(org.apache.activemq.command.Message message) |
addMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getIndexListener, isPrioritizedMessages, registerIndexListener, setPrioritizedMessages
protected final Map<org.apache.activemq.store.kahadb.KahaDBStore.AsyncJobKey,KahaDBStore.StoreTask> asyncTaskMap
protected KahaDestination dest
protected final HashMap<String,Set<String>> ackedAndPreparedMap
protected final HashMap<String,Set<String>> rolledBackAcksMap
public KahaDBStore.KahaDBMessageStore(org.apache.activemq.command.ActiveMQDestination destination)
public org.apache.activemq.command.ActiveMQDestination getDestination()
getDestination
in interface MessageStore
getDestination
in class AbstractMessageStore
public void trackRecoveredAcks(ArrayList<org.apache.activemq.command.MessageAck> acks)
public void forgetRecoveredAcks(ArrayList<org.apache.activemq.command.MessageAck> acks, boolean rollback) throws IOException
IOException
public ListenableFuture<Object> asyncAddQueueMessage(ConnectionContext context, org.apache.activemq.command.Message message) throws IOException
asyncAddQueueMessage
in interface MessageStore
asyncAddQueueMessage
in class AbstractMessageStore
IOException
public void removeAsyncMessage(ConnectionContext context, org.apache.activemq.command.MessageAck ack) throws IOException
removeAsyncMessage
in interface MessageStore
removeAsyncMessage
in class AbstractMessageStore
IOException
public void addMessage(ConnectionContext context, org.apache.activemq.command.Message message) throws IOException
IOException
public void updateMessage(org.apache.activemq.command.Message message) throws IOException
updateMessage
in interface MessageStore
updateMessage
in class AbstractMessageStore
IOException
public void removeMessage(ConnectionContext context, org.apache.activemq.command.MessageAck ack) throws IOException
IOException
public void removeAllMessages(ConnectionContext context) throws IOException
IOException
public org.apache.activemq.command.Message getMessage(org.apache.activemq.command.MessageId identity) throws IOException
IOException
public int getMessageCount() throws IOException
IOException
public boolean isEmpty() throws IOException
isEmpty
in interface MessageStore
isEmpty
in class AbstractMessageStore
IOException
public void recover(MessageRecoveryListener listener) throws Exception
Exception
public void recoverNextMessages(int maxReturned, MessageRecoveryListener listener) throws Exception
Exception
protected int recoverRolledBackAcks(String recoveredTxStateMapKey, org.apache.activemq.store.kahadb.MessageDatabase.StoredDestination sd, Transaction tx, int maxReturned, MessageRecoveryListener listener) throws Exception
Exception
public void resetBatching()
public void setBatch(org.apache.activemq.command.MessageId identity) throws IOException
setBatch
in interface MessageStore
setBatch
in class AbstractMessageStore
IOException
public void setMemoryUsage(MemoryUsage memoryUsage)
setMemoryUsage
in interface MessageStore
setMemoryUsage
in class AbstractMessageStore
public void start() throws Exception
start
in interface org.apache.activemq.Service
start
in class AbstractMessageStore
Exception
public void stop() throws Exception
stop
in interface org.apache.activemq.Service
stop
in class AbstractMessageStore
Exception
protected void lockAsyncJobQueue()
protected void unlockAsyncJobQueue()
protected void acquireLocalAsyncLock()
protected void releaseLocalAsyncLock()
Copyright © 2005–2021 FuseSource, Corp.. All rights reserved.