|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface MessageStore
Represents a message store which is used by the persistent implementations
Method Summary | |
---|---|
void |
addMessage(ConnectionContext context,
Message message)
Adds a message to the message store |
void |
dispose(ConnectionContext context)
|
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 |
void |
recover(MessageRecoveryListener container)
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 messageId)
allow caching cursors to set the current batch offset when cache is exhausted |
void |
setMemoryUsage(MemoryUsage memoeyUSage)
|
Methods inherited from interface org.apache.activemq.Service |
---|
start, stop |
Method Detail |
---|
void addMessage(ConnectionContext context, Message message) throws IOException
context
- contextmessage
-
IOException
Message getMessage(MessageId identity) throws IOException
identity
- which contains either the messageID or the messageNumber
IOException
void removeMessage(ConnectionContext context, MessageAck ack) throws IOException
context
- ack
- 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.
IOException
void removeAllMessages(ConnectionContext context) throws IOException
context
-
IOException
void recover(MessageRecoveryListener container) throws Exception
container
-
Exception
ActiveMQDestination getDestination()
void setMemoryUsage(MemoryUsage memoeyUSage)
memoeyUSage
- The SystemUsage that is controlling the
destination's memory usage.int getMessageCount() throws IOException
IOException
void resetBatching()
void recoverNextMessages(int maxReturned, MessageRecoveryListener listener) throws Exception
Exception
void dispose(ConnectionContext context)
void setBatch(MessageId messageId) throws Exception
messageId
-
Exception
boolean isEmpty() throws Exception
Exception
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |