public class TempKahaDBStore.KahaDBMessageStore extends AbstractMessageStore
| Modifier and Type | Field and Description |
|---|---|
protected org.apache.activemq.store.kahadb.data.KahaDestination |
dest |
destination, FUTURE, indexListener, prioritizedMessages| Constructor and Description |
|---|
TempKahaDBStore.KahaDBMessageStore(ActiveMQDestination destination) |
| Modifier and Type | Method and Description |
|---|---|
void |
addMessage(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() |
void |
recover(MessageRecoveryListener listener)
Recover any messages to be delivered.
|
void |
recoverNextMessages(int maxReturned,
MessageRecoveryListener listener) |
void |
removeAllMessages(ConnectionContext context)
Removes all the messages from the message store.
|
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 memoryUsage) |
void |
start() |
void |
stop() |
addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, getIndexListener, isEmpty, isPrioritizedMessages, registerIndexListener, removeAsyncMessage, setPrioritizedMessages, updateMessageprotected org.apache.activemq.store.kahadb.data.KahaDestination dest
public TempKahaDBStore.KahaDBMessageStore(ActiveMQDestination destination)
public ActiveMQDestination getDestination()
MessageStoregetDestination in interface MessageStoregetDestination in class AbstractMessageStorepublic void addMessage(ConnectionContext context, Message message) throws IOException
MessageStorecontext - contextIOExceptionpublic void removeMessage(ConnectionContext context, MessageAck ack) throws 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.IOExceptionpublic void removeAllMessages(ConnectionContext context) throws IOException
MessageStoreIOExceptionpublic Message getMessage(MessageId identity) throws IOException
MessageStoreidentity - which contains either the messageID or the messageNumberIOExceptionpublic int getMessageCount() throws IOException
IOExceptionpublic void recover(MessageRecoveryListener listener) throws Exception
MessageStoreExceptionpublic void recoverNextMessages(int maxReturned, MessageRecoveryListener listener) throws Exception
Exceptionpublic void resetBatching()
MessageStorepublic void setBatch(MessageId identity) throws IOException
MessageStoresetBatch in interface MessageStoresetBatch in class AbstractMessageStoreIOExceptionpublic void setMemoryUsage(MemoryUsage memoryUsage)
setMemoryUsage in interface MessageStoresetMemoryUsage in class AbstractMessageStorememoryUsage - The SystemUsage that is controlling the
destination's memory usage.public void start() throws Exception
start in interface Servicestart in class AbstractMessageStoreExceptionCopyright © 2005–2015 FuseSource, Corp.. All rights reserved.