|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
Represents a message store which is used by the persistent MessageContainer
implementations
Method Summary | |
MessageIdentity |
addMessage(ActiveMQMessage message)
Adds a message to the message store |
ActiveMQMessage |
getMessage(MessageIdentity identity)
Looks up a message using either the String messageID or the messageNumber. |
void |
recover(QueueMessageContainer container)
Recover any messages to be delivered onto the dispatch queue. |
void |
removeAllMessages()
Removes all the messages from the message store. |
void |
removeMessage(MessageIdentity identity,
MessageAck ack)
Removes a message from the message store. |
Methods inherited from interface org.codehaus.activemq.service.Service |
start, stop |
Method Detail |
public MessageIdentity addMessage(ActiveMQMessage message) throws JMSException
JMSException
public ActiveMQMessage getMessage(MessageIdentity identity) throws JMSException
identity
- which contains either the messageID or the messageNumber
JMSException
public void removeMessage(MessageIdentity identity, MessageAck ack) throws JMSException
identity
- which contains either the messageID or the messageNumberack
- the ack request that cause the message to be removed.
JMSException
public void removeAllMessages() throws JMSException
JMSException
public void recover(QueueMessageContainer container) throws JMSException
container
-
JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |