public class KahaDBStore.KahaDBMessageStore extends AbstractMessageStore
| Modifier and Type | Field and Description |
|---|---|
protected java.util.Map<org.apache.activemq.store.kahadb.KahaDBStore.AsyncJobKey,KahaDBStore.StoreTask> |
asyncTaskMap |
protected org.apache.activemq.store.kahadb.data.KahaDestination |
dest |
destination, FUTURE, prioritizedMessages| Constructor and Description |
|---|
KahaDBStore.KahaDBMessageStore(ActiveMQDestination destination) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
acquireLocalAsyncLock() |
void |
addMessage(ConnectionContext context,
Message message)
Adds a message to the message store
|
java.util.concurrent.Future<java.lang.Object> |
asyncAddQueueMessage(ConnectionContext context,
Message message)
Adds a message to the message store
|
ActiveMQDestination |
getDestination()
The destination that the message store is holding messages for.
|
Message |
getMessage(MessageId identity)
Looks up a message using either the String messageID or the
messageNumber.
|
int |
getMessageCount() |
boolean |
isEmpty()
flag to indicate if the store is empty
|
protected void |
lockAsyncJobQueue() |
void |
recover(MessageRecoveryListener listener)
Recover any messages to be delivered.
|
void |
recoverNextMessages(int maxReturned,
MessageRecoveryListener listener) |
protected void |
releaseLocalAsyncLock() |
void |
removeAllMessages(ConnectionContext context)
Removes all the messages from the message store.
|
void |
removeAsyncMessage(ConnectionContext context,
MessageAck ack) |
void |
removeMessage(ConnectionContext context,
MessageAck ack)
Removes a message from the message store.
|
void |
resetBatching()
A hint to the Store to reset any batching state for the Destination
|
void |
setBatch(MessageId identity)
allow caching cursors to set the current batch offset when cache is exhausted
|
void |
setMemoryUsage(MemoryUsage memoeyUSage) |
void |
start() |
void |
stop() |
protected void |
unlockAsyncJobQueue() |
addMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, isPrioritizedMessages, setPrioritizedMessagesprotected final java.util.Map<org.apache.activemq.store.kahadb.KahaDBStore.AsyncJobKey,KahaDBStore.StoreTask> asyncTaskMap
protected org.apache.activemq.store.kahadb.data.KahaDestination dest
public KahaDBStore.KahaDBMessageStore(ActiveMQDestination destination)
public ActiveMQDestination getDestination()
MessageStoregetDestination in interface MessageStoregetDestination in class AbstractMessageStorepublic java.util.concurrent.Future<java.lang.Object> asyncAddQueueMessage(ConnectionContext context, Message message) throws java.io.IOException
MessageStoreasyncAddQueueMessage in interface MessageStoreasyncAddQueueMessage in class AbstractMessageStorecontext - contextjava.io.IOExceptionpublic void removeAsyncMessage(ConnectionContext context, MessageAck ack) throws java.io.IOException
removeAsyncMessage in interface MessageStoreremoveAsyncMessage in class AbstractMessageStorejava.io.IOExceptionpublic void addMessage(ConnectionContext context, Message message) throws java.io.IOException
MessageStorecontext - contextjava.io.IOExceptionpublic void removeMessage(ConnectionContext context, MessageAck ack) throws java.io.IOException
MessageStoreack - the ack request that cause the message to be removed. It
conatins the identity which contains the messageID of the
message that needs to be removed.java.io.IOExceptionpublic void removeAllMessages(ConnectionContext context) throws java.io.IOException
MessageStorejava.io.IOExceptionpublic Message getMessage(MessageId identity) throws java.io.IOException
MessageStoreidentity - which contains either the messageID or the messageNumberjava.io.IOExceptionpublic int getMessageCount()
throws java.io.IOException
java.io.IOExceptionpublic boolean isEmpty()
throws java.io.IOException
AbstractMessageStoreisEmpty in interface MessageStoreisEmpty in class AbstractMessageStorejava.io.IOExceptionpublic void recover(MessageRecoveryListener listener) throws java.lang.Exception
MessageStorejava.lang.Exceptionpublic void recoverNextMessages(int maxReturned,
MessageRecoveryListener listener)
throws java.lang.Exception
java.lang.Exceptionpublic void resetBatching()
MessageStorepublic void setBatch(MessageId identity) throws java.io.IOException
MessageStoresetBatch in interface MessageStoresetBatch in class AbstractMessageStorejava.io.IOExceptionpublic void setMemoryUsage(MemoryUsage memoeyUSage)
setMemoryUsage in interface MessageStoresetMemoryUsage in class AbstractMessageStorememoeyUSage - The SystemUsage that is controlling the
destination's memory usage.public void start()
throws java.lang.Exception
start in interface Servicestart in class AbstractMessageStorejava.lang.Exceptionpublic void stop()
throws java.lang.Exception
stop in interface Servicestop in class AbstractMessageStorejava.lang.Exceptionprotected void lockAsyncJobQueue()
protected void unlockAsyncJobQueue()
protected void acquireLocalAsyncLock()
protected void releaseLocalAsyncLock()
Copyright © 2005-2013 Red Hat, Inc.. All Rights Reserved.