|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.store.vm.VMMessageStore
public class VMMessageStore
An implementation of MessageStore
which uses a
Field Summary | |
---|---|
protected MessageIdentity |
lastMessageIdentity
|
protected Map |
messageTable
|
Constructor Summary | |
---|---|
VMMessageStore()
|
|
VMMessageStore(LinkedHashMap messageTable)
|
Method Summary | |
---|---|
void |
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(RecoveryListener listener)
Recover any messages to be delivered. |
void |
removeAllMessages()
Removes all the messages from the message store. |
void |
removeMessage(MessageAck ack)
Removes a message from the message store. |
void |
removeMessage(MessageIdentity msgId)
|
void |
start()
Called to start the service |
void |
stop()
Called to shutdown the service |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected Map messageTable
protected MessageIdentity lastMessageIdentity
Constructor Detail |
---|
public VMMessageStore()
public VMMessageStore(LinkedHashMap messageTable)
Method Detail |
---|
public void addMessage(ActiveMQMessage message) throws JMSException
MessageStore
addMessage
in interface MessageStore
JMSException
public ActiveMQMessage getMessage(MessageIdentity identity) throws JMSException
MessageStore
getMessage
in interface MessageStore
identity
- which contains either the messageID or the messageNumber
JMSException
public void removeMessage(MessageAck ack) throws JMSException
MessageStore
removeMessage
in interface MessageStore
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.
JMSException
public void removeMessage(MessageIdentity msgId) throws JMSException
JMSException
public void recover(RecoveryListener listener) throws JMSException
MessageStore
recover
in interface MessageStore
JMSException
public void start() throws JMSException
Service
start
in interface Service
JMSException
public void stop() throws JMSException
Service
stop
in interface Service
JMSException
public void removeAllMessages() throws JMSException
MessageStore
removeAllMessages
in interface MessageStore
JMSException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |