public class TempKahaDBStore.KahaDBMessageStore extends AbstractMessageStore
| Modifier and Type | Field and Description |
|---|---|
protected org.apache.activemq.store.kahadb.data.KahaDestination |
dest |
destination, FUTURE, 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 memoeyUSage) |
void |
start() |
void |
stop() |
addMessage, asyncAddQueueMessage, asyncAddQueueMessage, asyncAddTopicMessage, asyncAddTopicMessage, dispose, isEmpty, isPrioritizedMessages, removeAsyncMessage, setPrioritizedMessagespublic TempKahaDBStore.KahaDBMessageStore(ActiveMQDestination destination)
public ActiveMQDestination getDestination()
MessageStoregetDestination in interface MessageStoregetDestination in class AbstractMessageStorepublic 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 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.ExceptionCopyright © 2005-2013 Red Hat, Inc.. All Rights Reserved.